client

Documentation

Index

• type Pooling
  • func NewPooling(ctx context.Context, dialer func(ctx context.Context) (jrpc.Conn, error), ...) (*Pooling, 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 jsonrpc.Middleware)
  • func (p *Pooling) Notify(ctx context.Context, method string, params any) error
  • func (p *Pooling) Subscribe(ctx context.Context, namespace string, channel any, args any) (subscription.ClientSubscription, error)
• type Reconnecting
  • func NewReconnecting(dialer func(ctx context.Context) (jrpc.Conn, error)) *Reconnecting
  • 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 jsonrpc.Middleware)
  • func (r *Reconnecting) Notify(ctx context.Context, method string, params any) error

Types

type Pooling

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

func NewPooling

func NewPooling(ctx context.Context, dialer func(ctx context.Context) (jrpc.Conn, error), max int) (*Pooling, 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 jsonrpc.Middleware)

func (*Pooling) Notify

func (p *Pooling) Notify(ctx context.Context, method string, params any) error

func (*Pooling) Subscribe

func (p *Pooling) Subscribe(ctx context.Context, namespace string, channel any, args any) (subscription.ClientSubscription, error)

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) 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 jsonrpc.Middleware)

func (*Reconnecting) Notify

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