nats

Documentation

Index

• type ClientInterface
  • func Connect(natsURL string) (ClientInterface, error)
• type Msg
• type MsgHandler
• type NatsSubscriptionInterface

Types

type ClientInterface

type ClientInterface interface {
	Subscribe(subj string, cb MsgHandler) (NatsSubscriptionInterface, error)
	QueueSubscribe(subj, queue string, cb MsgHandler) (NatsSubscriptionInterface, error)
	Publish(subj string, data []byte) error
	LastError() error
	Flush() error
	SubscribeSync(reply string) (NatsSubscriptionInterface, error)

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

func Connect

func Connect(natsURL string) (ClientInterface, error)

type Msg

type Msg natspkg.Msg

type MsgHandler

type MsgHandler func(*Msg)

type NatsSubscriptionInterface

type NatsSubscriptionInterface interface {
	AutoUnsubscribe(max int) error
	NextMsg(duration time.Duration) (*Msg, error)
	Unsubscribe() error
}