Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
127c57dc3a | |||
d6b0b8ea36 |
@ -23,7 +23,7 @@ type option struct {
|
|||||||
|
|
||||||
func WithName(name string) Option {
|
func WithName(name string) Option {
|
||||||
return func(o *option) {
|
return func(o *option) {
|
||||||
if name == "" {
|
if name != "" {
|
||||||
o.name = name
|
o.name = name
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -31,7 +31,7 @@ func WithName(name string) Option {
|
|||||||
|
|
||||||
func WithVersion(version string) Option {
|
func WithVersion(version string) Option {
|
||||||
return func(o *option) {
|
return func(o *option) {
|
||||||
if version == "" {
|
if version != "" {
|
||||||
o.version = version
|
o.version = version
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -39,7 +39,7 @@ func WithVersion(version string) Option {
|
|||||||
|
|
||||||
func WithAddress(address string) Option {
|
func WithAddress(address string) Option {
|
||||||
return func(o *option) {
|
return func(o *option) {
|
||||||
if address == "" {
|
if address != "" {
|
||||||
o.address = address
|
o.address = address
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
2
database/cache/new.go
vendored
2
database/cache/new.go
vendored
@ -45,7 +45,7 @@ func New(opts ...OptionFn) (Cache, error) {
|
|||||||
Password: password,
|
Password: password,
|
||||||
})
|
})
|
||||||
|
|
||||||
if err = client.Ping(tool.CtxTimeout(cfg.ctx, 5)).Err(); err != nil {
|
if err = client.Ping(tool.TimeoutCtx(cfg.ctx, 5)).Err(); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -23,7 +23,7 @@ func Timeout(seconds ...int) (ctx context.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func CtxTimeout(ctx context.Context, seconds ...int) context.Context {
|
func TimeoutCtx(ctx context.Context, seconds ...int) context.Context {
|
||||||
var (
|
var (
|
||||||
duration time.Duration
|
duration time.Duration
|
||||||
)
|
)
|
||||||
|
Reference in New Issue
Block a user