transport

package

v0.0.0-...-a4c726f Latest Latest Go to latest Published: Nov 7, 2022 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

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

ErrClosedClient error

This section is empty.

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

RadixPool struct

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

NewRadixPool return radix pool dialer with provided pool size.

func (rad *RadixPool) Close() error

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

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

Execute command

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.