nats

type Connection struct {
	ConnectionOptions
	// contains filtered or unexported fields
}

type ConnectionOptions struct {
	Endpoint            string
	Name                string
	Logger              *zap.SugaredLogger
	CredentialsFilePath string
	Registerer          prometheus.Registerer
}

type DataServiceListener[T any] struct {
	// contains filtered or unexported fields
}

type DataServiceListenerOptions[T any] struct {
	Name        string
	Kind        string
	Handler     func(t events.DataServiceEvent[T]) error
	BufferSize  int
	WorkerCount int
	Connection  *Connection
}

type EventDisposition string

type MessageHandler func(msg *Msg) (EventDisposition, error)

type Msg = nats.Msg

type SubscriptionOptions struct {
	Name        string
	Topic       string
	Group       string
	Handler     MessageHandler
	BufferSize  int
	WorkerCount int
}