transport

Documentation

Index

• type Radix
  • func NewRadix(addr string, size int, password *string) (*Radix, error)
  • func (r *Radix) Close() error
  • func (r *Radix) Execute(ctx context.Context, command string, args ...string) ([]byte, error)
  • func (r *Radix) ExecuteStream(ctx context.Context, handler func([]byte) error, command string, ...) error

Types

type Radix

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

Radix is an t38c.Executor implementation based on 'mediocregopher/radix' library.

func NewRadix

func NewRadix(addr string, size int, password *string) (*Radix, error)

NewRadix returns radix transport implementation with provided pool size.

func (*Radix) Close

func (r *Radix) Close() error

Close closes the connections. All future execution calls will return an error.

func (*Radix) Execute

func (r *Radix) Execute(ctx context.Context, command string, args ...string) ([]byte, error)

Execute executes command.

func (*Radix) ExecuteStream

func (r *Radix) 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.