base

Documentation

Index

• type Transport
  • func NewTransport() *Transport
  • func (t *Transport) Close() error
  • func (t *Transport) HandleMessage(ctx context.Context, body []byte) (*transport.BaseJsonRpcMessage, error)
  • func (t *Transport) Send(ctx context.Context, message *transport.BaseJsonRpcMessage) error
  • func (t *Transport) SetCloseHandler(handler func())
  • func (t *Transport) SetErrorHandler(handler func(error))
  • func (t *Transport) SetMessageHandler(handler func(ctx context.Context, message *transport.BaseJsonRpcMessage))

Types

type Transport

type Transport struct {
	ResponseMap map[int64]chan *transport.BaseJsonRpcMessage
	// contains filtered or unexported fields
}

Transport implements the common functionality for transports

func NewTransport

func NewTransport() *Transport

NewTransport creates a new base transport

func (*Transport) Close

func (t *Transport) Close() error

Close implements Transport.Close

func (*Transport) HandleMessage

func (t *Transport) HandleMessage(ctx context.Context, body []byte) (*transport.BaseJsonRpcMessage, error)

HandleMessage processes an incoming message and returns a response

func (*Transport) Send

func (t *Transport) Send(ctx context.Context, message *transport.BaseJsonRpcMessage) error

Send implements Transport.Send

func (*Transport) SetCloseHandler

func (t *Transport) SetCloseHandler(handler func())

SetCloseHandler implements Transport.SetCloseHandler

func (*Transport) SetErrorHandler

func (t *Transport) SetErrorHandler(handler func(error))

SetErrorHandler implements Transport.SetErrorHandler

func (*Transport) SetMessageHandler

func (t *Transport) SetMessageHandler(handler func(ctx context.Context, message *transport.BaseJsonRpcMessage))

SetMessageHandler implements Transport.SetMessageHandler