redis

Documentation

Index

• func NewRedis(logger logger.Logger) bindings.OutputBinding
• type Redis
  • func (r *Redis) Close() error
  • func (r *Redis) GetLogger() logger.Logger
  • func (r *Redis) GetRole(ctx context.Context, request *bindings.InvokeRequest, ...) (string, error)
  • func (r *Redis) GetRunningPort() int
  • func (r *Redis) Init(meta bindings.Metadata) (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) LockInstance(ctx context.Context) error
  • func (r *Redis) Ping() error
  • func (r *Redis) UnlockInstance(ctx context.Context) error

Functions

func NewRedis

func NewRedis(logger logger.Logger) bindings.OutputBinding

NewRedis returns a new redis bindings instance.

Types

type Redis

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

Redis is a redis output binding.

func (*Redis) Close

func (r *Redis) Close() error

func (*Redis) GetLogger

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

GetLogger returns the logger, implements BaseInternalOps interface.

func (*Redis) GetRole

func (r *Redis) GetRole(ctx context.Context, request *bindings.InvokeRequest, response *bindings.InvokeResponse) (string, error)

func (*Redis) GetRunningPort

func (r *Redis) GetRunningPort() int

func (*Redis) Init

func (r *Redis) Init(meta bindings.Metadata) (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) LockInstance

func (r *Redis) LockInstance(ctx context.Context) error

func (*Redis) Ping

func (r *Redis) Ping() error

func (*Redis) UnlockInstance

func (r *Redis) UnlockInstance(ctx context.Context) error