rpc

Documentation

Index

• Constants
• type Call
• type CallDispatcher
  • func NewCallDispatcher() *CallDispatcher
  • func (d *CallDispatcher) Handle(ctx context.Context, msg stream.Message, reply chan<- stream.Message) error
  • func (d *CallDispatcher) RegisterCallHandler(method CallMethod, handler CallHandler)
• type CallHandler
• type CallID
• type CallMethod

Constants

const (
	MessageTypeCall stream.MessageType = "call"
)

Types

type Call

type Call struct {
	ID     CallID          `json:"id"`
	Method CallMethod      `json:"method"`
	Params json.RawMessage `json:"params"`
}

type CallDispatcher

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

func NewCallDispatcher

func NewCallDispatcher() *CallDispatcher

func (*CallDispatcher) Handle

func (d *CallDispatcher) Handle(
	ctx context.Context,
	msg stream.Message,
	reply chan<- stream.Message,
) error

func (*CallDispatcher) RegisterCallHandler

func (d *CallDispatcher) RegisterCallHandler(method CallMethod, handler CallHandler)

type CallHandler

type CallHandler interface {
	Handle(ctx context.Context, call Call, reply chan<- stream.Message) error
}

type CallID

type CallID string

type CallMethod

type CallMethod string