1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
// Tideland Go Library - Redis Client - Arguments
//
// Copyright (C) 2009-2017 Frank Mueller / Oldenburg / Germany
//
// All rights reserved. Use of this source code is governed
// by the new BSD license.
package redis
//--------------------
// IMPORTS
//--------------------
import (
"time"
"github.com/tideland/golib/errors"
)
//--------------------
// OPTIONS
//--------------------
const (
defaultAddress = "127.0.0.1:6379"
defaultSocket = "/tmp/redis.sock"
defaultNetwork = "unix"
defaultTimeout = 30 * time.Second
defaultIndex = 0
defaultPassword = ""
defaultPoolSize = 10
defaultLogging = false
defaultMonitoring = false
)
// Options is returned when calling Options() on Database to
// provide information about the database configuration.
type Options struct {
Address string
Network string
Timeout time.Duration
Index int
Password string
PoolSize int
Logging bool
Monitoring bool
}
// Option defines a function setting an option.
type Option func(d *Database) error
// TcpConnection sets the connection to use TCP/IP. The default address
// is "127.0.0.1:6379". The default timeout to connect are 30 seconds.
func TcpConnection(address string, timeout time.Duration) Option {
return func(d *Database) error {
if address == "" {
address = defaultAddress
}
d.address = address
d.network = "tcp"
if timeout < 0 {
return errors.New(ErrInvalidConfiguration, errorMessages, "timeout", timeout)
} else if timeout == 0 {
timeout = defaultTimeout
}
d.timeout = timeout
return nil
}
}
// UnixConnection sets the connection to use a Unix socket. The default
// is "/tmp/redis.sock". The default timeout to connect are 30 seconds.
func UnixConnection(socket string, timeout time.Duration) Option {
return func(d *Database) error {
if socket == "" {
socket = defaultSocket
}
d.address = socket
d.network = "unix"
if timeout < 0 {
return errors.New(ErrInvalidConfiguration, errorMessages, "timeout", timeout)
} else if timeout == 0 {
timeout = defaultTimeout
}
d.timeout = timeout
return nil
}
}
// Index selects the database and sets the authentication. The
// default database is the 0, the default password is empty.
func Index(index int, password string) Option {
return func(d *Database) error {
if index < 0 {
return errors.New(ErrInvalidConfiguration, errorMessages, "index", index)
}
d.index = index
d.password = password
return nil
}
}
// PoolSize sets the pool size of the database. The default is 10.
func PoolSize(poolsize int) Option {
return func(d *Database) error {
if poolsize < 0 {
return errors.New(ErrInvalidConfiguration, errorMessages, "pool size", poolsize)
} else if poolsize == 0 {
poolsize = defaultPoolSize
}
d.poolsize = poolsize
return nil
}
}
// Monitoring sets logging and monitoring, logging and
// monitoring are switched off by default.
func Monitoring(logging, monitoring bool) Option {
return func(d *Database) error {
d.logging = logging
d.monitoring = monitoring
return nil
}
}
// EOF
|
