nats

type AsyncPublisher struct {
	ClientID   string
	Connection stan.Conn

	Addr string
	// contains filtered or unexported fields
}

type Handler interface {
	// Process does something with a received subscription message, then acks it.
	Process(s Subscription, m Message)
}

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

type Message interface {
	Data() []byte
	Ack() error
}

type Publisher interface {
	// Publish a new message to channel
	Publish(subject string, r io.Reader) error
}

type QueueSubscriber struct {
	ClientID   string
	Connection stan.Conn
	Addr       string
}

type Server struct {
	Server *sserver.StanServer
	// contains filtered or unexported fields
}

type Subscriber interface {
	// Subscribe listens to a channel, handling messages with Handler
	Subscribe(subject, group string, handler Handler) error
}

type Subscription interface {
	// Pending returns the number of queued messages and queued bytes for this subscription.
	Pending() (int64, int64, error)

	// Delivered returns the number of delivered messages for this subscription.
	Delivered() (int64, error)

	// Close removes this subscriber
	Close() error
}