rpc

Documentation

Index

• Variables
• type MemoryAdapter
  • func NewMemory() *MemoryAdapter
  • func (m *MemoryAdapter) Reply(ctx context.Context, topic string, ...) error
  • func (m *MemoryAdapter) Request(ctx context.Context, topic string, in any) (json.RawMessage, error)
• type RpcGreetingServiceImpl
  • func (s *RpcGreetingServiceImpl) SayHello(ctx context.Context, name string) (string, error)

Variables

var (
	ErrRpcCallNotFound = errors.New("rpc call not found")
)

Types

type MemoryAdapter

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

func NewMemory

func NewMemory() *MemoryAdapter

func (*MemoryAdapter) Reply

func (m *MemoryAdapter) Reply(ctx context.Context, topic string, fn func(ctx context.Context, in json.RawMessage) (out any, err error)) error

func (*MemoryAdapter) Request

func (m *MemoryAdapter) Request(ctx context.Context, topic string, in any) (json.RawMessage, error)

type RpcGreetingServiceImpl

type RpcGreetingServiceImpl struct {
}

func (*RpcGreetingServiceImpl) SayHello

func (s *RpcGreetingServiceImpl) SayHello(ctx context.Context, name string) (string, error)