examples

Documentation

Overview

Package examples is a generated protocol buffer package.

It is generated from these files:

service.proto

It has these top-level messages:

In
Out

Index

• func SubscribeRPC(ctx context.Context, nc *nats.Conn, subject, queue string, service RPC, ...) (<-chan struct{}, error)
• type In
  • func (*In) Descriptor() ([]byte, []int)
  • func (m *In) GetInput() string
  • func (*In) ProtoMessage()
  • func (m *In) Reset()
  • func (m *In) String() string
• type Out
  • func (*Out) Descriptor() ([]byte, []int)
  • func (m *Out) GetOutput() string
  • func (*Out) ProtoMessage()
  • func (m *Out) Reset()
  • func (m *Out) String() string
• type RPC
  • func NewRPC(nc *nats.Conn, subject string, filters ...nats_protobuf.Filter) RPC

Functions

func SubscribeRPC

func SubscribeRPC(ctx context.Context, nc *nats.Conn, subject, queue string, service RPC, filters ...nats_protobuf.Filter) (<-chan struct{}, error)

Types

type In

type In struct {
	Input string `protobuf:"bytes,1,opt,name=input" json:"input,omitempty"`
}

func (*In) Descriptor

func (*In) Descriptor() ([]byte, []int)

func (*In) GetInput

func (m *In) GetInput() string

func (*In) ProtoMessage

func (*In) ProtoMessage()

func (*In) Reset

func (m *In) Reset()

func (*In) String

func (m *In) String() string

type Out

type Out struct {
	Output string `protobuf:"bytes,1,opt,name=output" json:"output,omitempty"`
}

func (*Out) Descriptor

func (*Out) Descriptor() ([]byte, []int)

func (*Out) GetOutput

func (m *Out) GetOutput() string

func (*Out) ProtoMessage

func (*Out) ProtoMessage()

func (*Out) Reset

func (m *Out) Reset()

func (*Out) String

func (m *Out) String() string

type RPC

type RPC interface {
	InOut(ctx context.Context, in *In) (*Out, error)
}

func NewRPC

func NewRPC(nc *nats.Conn, subject string, filters ...nats_protobuf.Filter) RPC