redis

Documentation

Index

• func NewRedisClient(ctx context.Context, retryOpts helper.RetryOptions, d RedisClientDependencies, ...) (contract.RedisClient, error)
• type Blackbox
• type Client
  • func NewClient(d Dependencies, opts ClientOptions) (Client, error)
  • func NewNoopClient() Client
• type ClientOption
  • func WithBatchSize(x int) ClientOption
  • func WithClaimTTL(x time.Duration) ClientOption
  • func WithExpiresAfter(x time.Duration) ClientOption
• type ClientOptions
  • func ApplyClientOptions(opts *ClientOptions, modifiers ...ClientOption) ClientOptions
• type DefaultTool
  • func NewTool(c Client, opts contract.ToolOptions[Client]) *DefaultTool
  • func (d *DefaultTool) Close(ctx context.Context) error
• type Dependencies
• type Loaded
• type RedisClientDependencies
• type RedisClientOptions
• type Tool

Functions

func NewRedisClient

func NewRedisClient(ctx context.Context, retryOpts helper.RetryOptions, d RedisClientDependencies, opts RedisClientOptions) (contract.RedisClient, error)

Types

type Blackbox

type Blackbox interface {
	// contains filtered or unexported methods
}

type Client

type Client interface {
	Blackbox
	contract.RedisOperator
}

func NewClient

func NewClient(d Dependencies, opts ClientOptions) (Client, error)

func NewNoopClient

func NewNoopClient() Client

type ClientOption

type ClientOption = contract.Opt[ClientOptions]

func WithBatchSize

func WithBatchSize(x int) ClientOption

func WithClaimTTL

func WithClaimTTL(x time.Duration) ClientOption

func WithExpiresAfter

func WithExpiresAfter(x time.Duration) ClientOption

type ClientOptions

type ClientOptions struct {
	ExpiresAfter time.Duration
	BatchSize    int
	ClaimTTL     time.Duration
}

func ApplyClientOptions

func ApplyClientOptions(opts *ClientOptions, modifiers ...ClientOption) ClientOptions

type DefaultTool

type DefaultTool struct {
	T *contract.Tool[Client]
}

func NewTool

func NewTool(c Client, opts contract.ToolOptions[Client]) *DefaultTool

func (*DefaultTool) Close

func (d *DefaultTool) Close(ctx context.Context) error

Close closes the underlying client.

type Dependencies

type Dependencies struct {
	C contract.RedisClient
}

type Loaded

type Loaded struct {
	Username string
	Password string
}

type RedisClientDependencies

type RedisClientDependencies struct {
	C contract.CertGenerator
	F contract.FSysFileReader
}

type RedisClientOptions

type RedisClientOptions struct {
	Loaded
	FS        fs.ReadFileFS
	Port      int
	Host      string
	CertPath  string
	KeyPath   string
	CAPath    string
	UseTLS    bool
	MutualTLS bool
}

type Tool

type Tool interface {
	contract.CloserWithCtx
}