redis

Documentation

Index

• type Redis
  • func NewRedis() *Redis
  • func (r *Redis) Close() error
  • func (r *Redis) GetLogger() logr.Logger
  • func (r *Redis) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)
  • func (r *Redis) GetRunningPort() int
  • func (r *Redis) Init(metadata Properties) (err error)
  • func (r *Redis) InternalExec(ctx context.Context, cmd string) (int64, error)
  • func (r *Redis) InternalQuery(ctx context.Context, cmd string) ([]byte, error)
  • func (r *Redis) Ping() error

Types

type Redis

type Redis struct {
	BaseOperations
	// contains filtered or unexported fields
}

Redis is a redis output binding.

func NewRedis

func NewRedis() *Redis

NewRedis returns a new redis bindings instance.

func (*Redis) Close

func (r *Redis) Close() error

func (*Redis) GetLogger

func (r *Redis) GetLogger() logr.Logger

GetLogger returns the logger, implements BaseInternalOps interface.

func (*Redis) GetRole

func (r *Redis) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)

func (*Redis) GetRunningPort

func (r *Redis) GetRunningPort() int

func (*Redis) Init

func (r *Redis) Init(metadata Properties) (err error)

Init performs metadata parsing and connection creation.

func (*Redis) InternalExec

func (r *Redis) InternalExec(ctx context.Context, cmd string) (int64, error)

InternalExec is used for internal execution, implements BaseInternalOps interface.

func (*Redis) InternalQuery

func (r *Redis) InternalQuery(ctx context.Context, cmd string) ([]byte, error)

InternalQuery is used for internal query, implements BaseInternalOps interface.

func (*Redis) Ping

func (r *Redis) Ping() error