messaging

type BrokerOption func(*brokerConfiguration)

type DirectMessaging interface {
	Listen(topic string, handler func(data []byte)) (Subscription, error)
	SendToOther(topic string, data []byte) error
	SendToOtherWithRetry(topic string, data []byte, config RetryConfig) error
	SendToSelf(topic string, data []byte) error
}

type EnqueueOptions struct {
	IdempotententKey string
}

type Message interface {
	Data() []byte
	Headers() map[string][]string
	Subject() string
	Ack() error
	Nak() error
	Term() error
	InProgress() error
	Metadata() (*MessageMetadata, error)
}

type MessageBroker interface {
	PublishMessage(ctx context.Context, subject string, data []byte) error
	CreateSubscription(ctx context.Context, consumerName, subject string, handler func(msg Message)) (MessageSubscription, error)
	GetStreamInfo(ctx context.Context) (*StreamInfo, error)
	FetchMessages(ctx context.Context, consumerName, subject string, batchSize int, handler func(msg Message)) error
	Close() error
}

type MessageMetadata struct {
	Sequence     SequencePair
	NumDelivered int
	Timestamp    time.Time
}

type MessageQueue interface {
	Enqueue(topic string, message []byte, options *EnqueueOptions) error
	Dequeue(topic string, handler func(message []byte) error) error
	Close()
}

type MessageSubscription interface {
	Unsubscribe() error
}

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

type NatsBrokerOption func(*natsBrokerConfiguration)

type NatsMessageBroker interface {
	PublishMessage(ctx context.Context, subject string, data []byte) error
	CreateSubscription(ctx context.Context, consumerName, subject string, handler func(msg jetstream.Msg)) (MessageSubscription, error)
	GetStreamInfo(ctx context.Context) (*jetstream.StreamInfo, error)
	FetchMessages(ctx context.Context, consumerName, subject string, batchSize int, handler func(msg jetstream.Msg)) error
	Close() error
}

type NatsMessageSubscription interface {
	Unsubscribe() error
}

type PubSub interface {
	Publish(topic string, message []byte) error
	PublishWithReply(topic, reply string, data []byte, headers map[string]string) error
	Subscribe(topic string, handler func(msg *nats.Msg)) (Subscription, error)
}

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

type RetryConfig struct {
	RetryAttempt       uint
	ExponentialBackoff bool
	Delay              time.Duration
	OnRetry            func(n uint, err error)
}

type SequencePair struct {
	Consumer uint64
	Stream   uint64
}

type StreamConfig struct {
	Name        string
	Subjects    []string
	Description string
}

type StreamInfo struct {
	Config StreamConfig
	State  StreamState
}

type StreamState struct {
	Messages  uint64
	Bytes     uint64
	FirstSeq  uint64
	LastSeq   uint64
	Consumers int
}

type Subscription interface {
	Unsubscribe() error
}