rpc

May 9, 2021

Changes in this version

type Client

+ func (p *Client) CloseStream(nid string) error

type Server

+ func (s *Server) CloseStream(nid string) error

May 1, 2021

Changes in this version

+ func Codec() grpc.Codec

+ func CodecWithParent(fallback grpc.Codec) grpc.Codec

+ type Frame struct

+ Payload []byte

+ type RawCodec struct

+ func (c *RawCodec) Marshal(v interface{}) ([]byte, error)

+ func (c *RawCodec) String() string

+ func (c *RawCodec) Unmarshal(data []byte, v interface{}) error

Apr 28, 2021

Changes in this version

type Server

+ func (s *Server) GetServiceInfo() map[string]grpc.ServiceInfo

Mar 8, 2021

Changes in this version

type Client

+ func (p *Client) Close() error

Jan 19, 2021

Changes in this version

+ func SetupConnOptions(opts []nats.Option) []nats.Option

Jan 18, 2021

Changes in this version

+ var ErrIllegalHeaderWrite = errors.New("transport: the stream is done or WriteHeader was already called")

+ type Client struct

+ func NewClient(nc NatsConn, id string) *Client

+ func (c *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error

+ func (c *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)

+ func (p *Client) Stop()

+ type NatsConn interface

+ ChanSubscribe func(subj string, ch chan *nats.Msg) (*nats.Subscription, error)

+ Flush func() error

+ LastError func() error

+ Publish func(subj string, data []byte) error

+ PublishRequest func(subj, reply string, data []byte) error

+ QueueSubscribe func(subj, queue string, cb nats.MsgHandler) (*nats.Subscription, error)

+ Request func(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)

+ SubscribeSync func(subj string) (*nats.Subscription, error)

+ type Server struct

+ func NewServer(nc NatsConn, id string) *Server

+ func (p *Server) RegisterService(sd *grpc.ServiceDesc, ss interface{})

+ func (p *Server) Stop()