wrpcnats

Documentation

Index

• func ContextWithHeader(ctx context.Context, header nats.Header) context.Context
• func HeaderFromContext(ctx context.Context) (nats.Header, bool)
• type Client
  • func NewClient(conn *nats.Conn, prefix string) *Client
  • func (c *Client) Invoke(ctx context.Context, instance string, name string, ...) (err error)
  • func (c *Client) Serve(instance string, name string, ...) (stop func() error, err error)

Functions

func ContextWithHeader

func ContextWithHeader(ctx context.Context, header nats.Header) context.Context

func HeaderFromContext

func HeaderFromContext(ctx context.Context) (nats.Header, bool)

Types

type Client

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

func NewClient

func NewClient(conn *nats.Conn, prefix string) *Client

func (*Client) Invoke

func (c *Client) Invoke(ctx context.Context, instance string, name string, f func(wrpc.IndexWriter, wrpc.IndexReadCloser) error, subs ...wrpc.SubscribePath) (err error)

func (*Client) Serve

func (c *Client) Serve(instance string, name string, f func(context.Context, wrpc.IndexWriter, wrpc.IndexReadCloser) error, subs ...wrpc.SubscribePath) (stop func() error, err error)