re
/
redis
forked from mirror/redis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Make universal options functions public (#1250) 

* Make universal options functions public
This commit is contained in:
Furkan Senharputlu 2020-01-29 18:36:52 +03:00 committed by GitHub
parent 2f96fd1378
commit 8a0ab1aaa7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
universal.go
View File

@ -49,7 +49,8 @@ type UniversalOptions struct {
MasterName string MasterName string
} }
func (o *UniversalOptions) cluster() *ClusterOptions { // Cluster returns cluster options created from the universal options.
func (o *UniversalOptions) Cluster() *ClusterOptions {
if len(o.Addrs) == 0 { if len(o.Addrs) == 0 {
o.Addrs = []string{"127.0.0.1:6379"} o.Addrs = []string{"127.0.0.1:6379"}
} }
@ -84,7 +85,8 @@ func (o *UniversalOptions) cluster() *ClusterOptions {
} }
} }
func (o *UniversalOptions) failover() *FailoverOptions { // Failover returns failover options created from the universal options.
func (o *UniversalOptions) Failover() *FailoverOptions {
if len(o.Addrs) == 0 { if len(o.Addrs) == 0 {
o.Addrs = []string{"127.0.0.1:26379"} o.Addrs = []string{"127.0.0.1:26379"}
} }
@ -118,7 +120,8 @@ func (o *UniversalOptions) failover() *FailoverOptions {
} }
} }
func (o *UniversalOptions) simple() *Options { // Simple returns basic options created from the universal options.
func (o *UniversalOptions) Simple() *Options {
addr := "127.0.0.1:6379" addr := "127.0.0.1:6379"
if len(o.Addrs) > 0 { if len(o.Addrs) > 0 {
addr = o.Addrs[0] addr = o.Addrs[0]
@ -183,9 +186,9 @@ var _ UniversalClient = (*Ring)(nil)
// 3. otherwise, a single-node redis Client will be returned. // 3. otherwise, a single-node redis Client will be returned.
func NewUniversalClient(opts *UniversalOptions) UniversalClient { func NewUniversalClient(opts *UniversalOptions) UniversalClient {
if opts.MasterName != "" { if opts.MasterName != "" {
return NewFailoverClient(opts.failover()) return NewFailoverClient(opts.Failover())
} else if len(opts.Addrs) > 1 { } else if len(opts.Addrs) > 1 {
return NewClusterClient(opts.cluster()) return NewClusterClient(opts.Cluster())
} }
return NewClient(opts.simple()) return NewClient(opts.Simple())
} }