broker

Documentation

Index

• Constants
• func NewNATS(opts *NATSOptions) service.Broker
• type NATS
  • func (broker *NATS) Bind(svc *service.Service)
  • func (broker *NATS) Connect() error
  • func (broker *NATS) Disconnect() error
  • func (broker *NATS) Publish(endpoint string, data interface{}) error
  • func (broker *NATS) Request(endpoint string, data interface{}) (*service.Context, error)
  • func (broker *NATS) Subscribe(channel string, channelHandler service.ChannelHandler) error
  • func (broker *NATS) Unsubscribe(channel string) error
• type NATSOptions

Constants

const (
	ChannelSubscribe   = "channels.create"
	ChannelUnsubscribe = "channels.delete"
)

Functions

func NewNATS

func NewNATS(opts *NATSOptions) service.Broker

Types

type NATS

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

func (*NATS) Bind

func (broker *NATS) Bind(svc *service.Service)

func (*NATS) Connect

func (broker *NATS) Connect() error

func (*NATS) Disconnect

func (broker *NATS) Disconnect() error

func (*NATS) Publish

func (broker *NATS) Publish(endpoint string, data interface{}) error

func (*NATS) Request

func (broker *NATS) Request(endpoint string, data interface{}) (*service.Context, error)

func (*NATS) Subscribe

func (broker *NATS) Subscribe(channel string, channelHandler service.ChannelHandler) error

func (*NATS) Unsubscribe

func (broker *NATS) Unsubscribe(channel string) error

type NATSOptions

type NATSOptions struct {
	URI            string
	NATSOptions    []nats.Option
	RequestTimeout time.Duration
}