messenger

Documentation

Index

• Variables
• type Messenger
• type WireMessenger
  • func (m WireMessenger) Read(ctx context.Context, log *zap.Logger, nc net.Conn, address string, id uint64, ...) ([]*redis.Message, error)
  • func (m WireMessenger) Write(ctx context.Context, log *zap.Logger, wm []*redis.Message, nc net.Conn, ...) error

Variables

var PipelineSignalEndKey = []byte("🔚")

var PipelineSignalStartKey = []byte("🔜")

Types

type Messenger

type Messenger interface {
	Read(ctx context.Context, log *zap.Logger, nc net.Conn, address string, id uint64, readTimeout time.Duration, readMin int, checkPipelineSignals bool, close func() error) ([]*redis.Message, error)
	Write(ctx context.Context, log *zap.Logger, wm []*redis.Message, nc net.Conn, address string, id uint64, writeTimeout time.Duration, wrapPipeline bool, close func() error) error
}

type WireMessenger

type WireMessenger struct{}

func (WireMessenger) Read

func (m WireMessenger) Read(ctx context.Context, log *zap.Logger, nc net.Conn, address string, id uint64, readTimeout time.Duration, readMin int, checkPipelineSignals bool, close func() error) ([]*redis.Message, error)

func (WireMessenger) Write

func (m WireMessenger) Write(ctx context.Context, log *zap.Logger, wm []*redis.Message, nc net.Conn, address string, id uint64, writeTimeout time.Duration, wrapPipeline bool, close func() error) error