backends

type Backend interface {
	Publish(ctx context.Context, envelope model.Envelope) error
}

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

type NATSConfig struct {
	Address string `mapstructure:"address"`
	Token   string `mapstructure:"token"`
	Stream  string `mapstructure:"stream"`
	Subject string `mapstructure:"subject"`
	Durable string `mapstructure:"durable"`
	Queue   string `mapstructure:"queue"`
	// Namespace scopes the stream, subject, durable and queue names so
	// environments sharing one NATS server (for example QA, test and dev on the
	// same host) each get their own isolated stream and queue group instead of
	// consuming each other's events. Publisher and consumer must set the same
	// value. Ignored for any name given explicitly above.
	Namespace string `mapstructure:"namespace"`
}

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