transport

Documentation

Index

• Variables
• type RadixPool
  • func NewRadixPool(addr string, size int, password *string) (*RadixPool, error)
  • func (rad *RadixPool) Close() error
  • func (rad *RadixPool) Execute(command string, args ...string) ([]byte, error)
  • func (rad *RadixPool) ExecuteStream(ctx context.Context, handler func([]byte) error, command string, ...) error

Variables

var ErrClosedClient = errors.New("closed client")

ErrClosedClient error

Types

type RadixPool

type RadixPool struct {
	// contains filtered or unexported fields
}

RadixPool struct

func NewRadixPool

func NewRadixPool(addr string, size int, password *string) (*RadixPool, error)

NewRadixPool return radix pool dialer with provided pool size.

func (*RadixPool) Close

func (rad *RadixPool) Close() error

Close closes all connections in the pool and rejects future execution calls. Blocks until all streams are closed.

func (*RadixPool) Execute

func (rad *RadixPool) Execute(command string, args ...string) ([]byte, error)

Execute command

func (*RadixPool) ExecuteStream

func (rad *RadixPool) ExecuteStream(ctx context.Context, handler func([]byte) error, command string, args ...string) error

ExecuteStream used for commands with streaming response. Creates a new connection for each stream.