transport

Documentation

Index

• type Connection
  • func Connect(ctx context.Context, logger log.Logger, uri *url.URL) (Connection, error)
• type NatsConnection
  • func (c *NatsConnection) Publish(channel string, data []byte) error
• type NatsSubscription
  • func (ns *NatsSubscription) Receive() chan []byte
  • func (ns *NatsSubscription) Unsubscribe()
• type Subscription
  • func Listen(ctx context.Context, logger log.Logger, uri *url.URL, clientID string) (Subscription, error)

Types

type Connection

type Connection interface {
	Publish(channel string, data []byte) error
}

func Connect

func Connect(ctx context.Context, logger log.Logger, uri *url.URL) (Connection, error)

type NatsConnection

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

func (*NatsConnection) Publish

func (c *NatsConnection) Publish(channel string, data []byte) error

type NatsSubscription

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

func (*NatsSubscription) Receive

func (ns *NatsSubscription) Receive() chan []byte

func (*NatsSubscription) Unsubscribe

func (ns *NatsSubscription) Unsubscribe()

type Subscription

type Subscription interface {
	Unsubscribe()
	Receive() chan []byte
}

func Listen

func Listen(ctx context.Context, logger log.Logger, uri *url.URL, clientID string) (Subscription, error)