client

Documentation

Index

• type Pooling
  • func NewPooling(dialer func(ctx context.Context) (jrpc.Conn, error), max int) *Pooling
  • func (r *Pooling) BatchCall(ctx context.Context, b ...*codec.BatchElem) error
  • func (p *Pooling) Close() error
  • func (p *Pooling) Closed() <-chan struct{}
  • func (r *Pooling) Do(ctx context.Context, result any, method string, params any) error
  • func (p *Pooling) Mount(m codec.Middleware)
• type Reconnecting
  • func NewReconnecting(dialer func(ctx context.Context) (jrpc.Conn, error)) *Reconnecting
  • func (r *Reconnecting) BatchCall(ctx context.Context, b ...*codec.BatchElem) error
  • func (r *Reconnecting) Close() error
  • func (r *Reconnecting) Closed() <-chan struct{}
  • func (r *Reconnecting) Do(ctx context.Context, result any, method string, params any) error
  • func (r *Reconnecting) Mount(m codec.Middleware)

Types

type Pooling

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

func NewPooling

func NewPooling(dialer func(ctx context.Context) (jrpc.Conn, error), max int) *Pooling

func (*Pooling) BatchCall

func (r *Pooling) BatchCall(ctx context.Context, b ...*codec.BatchElem) error

func (*Pooling) Close

func (p *Pooling) Close() error

func (*Pooling) Closed

func (p *Pooling) Closed() <-chan struct{}

func (*Pooling) Do

func (r *Pooling) Do(ctx context.Context, result any, method string, params any) error

func (*Pooling) Mount

func (p *Pooling) Mount(m codec.Middleware)

type Reconnecting

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

func NewReconnecting

func NewReconnecting(dialer func(ctx context.Context) (jrpc.Conn, error)) *Reconnecting

func (*Reconnecting) BatchCall

func (r *Reconnecting) BatchCall(ctx context.Context, b ...*codec.BatchElem) error

func (*Reconnecting) Close

func (r *Reconnecting) Close() error

why would you want to do this....

func (*Reconnecting) Closed

func (r *Reconnecting) Closed() <-chan struct{}

never....

func (*Reconnecting) Do

func (r *Reconnecting) Do(ctx context.Context, result any, method string, params any) error

func (*Reconnecting) Mount

func (r *Reconnecting) Mount(m codec.Middleware)