redisfx

Documentation

Index

• Variables
• func AddCheckerForClient(client *redis.Client, v ufx.Prober)
• func AddCheckerForClusterClient(client *redis.ClusterClient, v ufx.Prober)
• func NewClient(opts *redis.Options) (client *redis.Client, err error)
• func NewClusterClient(opts *redis.ClusterOptions) (client *redis.ClusterClient, err error)
• func NewClusterOptions(params ClusterParams) (*redis.ClusterOptions, error)
• func NewOptions(params Params) (*redis.Options, error)
• type ClusterParams
  • func DecodeClusterParams(conf ufx.Conf) (params ClusterParams, err error)
• type Params
  • func DecodeParams(conf ufx.Conf) (params Params, err error)

Variables

var Module = fx.Module(
	"ufx_redisfx",
	fx.Provide(
		DecodeParams,
		NewOptions,
		NewClient,
	),
	fx.Invoke(AddCheckerForClient),
)

var ModuleCluster = fx.Module(
	"ufx_redisfx_cluster",
	fx.Provide(
		DecodeClusterParams,
		NewClusterOptions,
		NewClusterClient,
	),
	fx.Invoke(AddCheckerForClusterClient),
)

Functions

func AddCheckerForClient

func AddCheckerForClient(client *redis.Client, v ufx.Prober)

func AddCheckerForClusterClient

func AddCheckerForClusterClient(client *redis.ClusterClient, v ufx.Prober)

func NewClient

func NewClient(opts *redis.Options) (client *redis.Client, err error)

func NewClusterClient

func NewClusterClient(opts *redis.ClusterOptions) (client *redis.ClusterClient, err error)

func NewClusterOptions

func NewClusterOptions(params ClusterParams) (*redis.ClusterOptions, error)

func NewOptions

func NewOptions(params Params) (*redis.Options, error)

Types

type ClusterParams

type ClusterParams struct {
	URL string `json:"url"`
}

func DecodeClusterParams

func DecodeClusterParams(conf ufx.Conf) (params ClusterParams, err error)

type Params

type Params struct {
	URL string `json:"url" default:"redis://localhost:6379/0" validate:"required,url"`
}

func DecodeParams

func DecodeParams(conf ufx.Conf) (params Params, err error)