pubsub

type ChannelUnsubscribeCallBack func() error

type NatsClient[T any, A any] interface {
	*T
	Connection(*NatsConnection)
	GetConnection() *NatsConnection
	MarshalEventPayload(A) ([]byte, error)
}

type NatsClientFactory[T any, A any, P NatsClient[T, A]] struct {
	// contains filtered or unexported fields
}

type NatsConfig struct {
	NatsUrl string
}

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

type PubSubOpt struct {
	Urls       string
	ClientName string
}

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

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