broker

type Broker interface {
	Publish(ctx context.Context, subject string, data []byte) error
	Subscribe(ctx context.Context, subject string, handler func(msg *Message)) (*Subscription, error)
	Request(ctx context.Context, subject string, msg []byte) (*Message, error)
	Drain() error
	Close()
}

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

type Message = nats.Msg

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

type Options struct {
	Servers       []string
	MaxReconnects int
	ReconnectWait time.Duration
}

type Subscription = nats.Subscription