pubsub

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

type AckableMessages []*AckableMessage

type Acknowledger func(*AckableMessage) error

type Config struct {
	Protocol Protocol  `json:"protocol"`
	URLs     []string  `json:"url"`
	TLS      TLSConfig `json:"tls"`
}

type GenericPublisherToSubject[T any] interface {
	Publish(ctx context.Context, data ...T) error
}

type GenericSubscriberToSubject[T any] interface {
	Subscribe(ctx context.Context, handler func(context.Context, T) Acknowledger) (Unsubscribe, error)
}

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

type MessageOption func(*Message)

type Messages []*Message

type MigrationInfo interface {
	MigrationID() string
}

type Migrator interface {
	Migrate(ctx context.Context, migrations []MigrationInfo) error
	IsMigrated(ctx context.Context, migrations []MigrationInfo) (bool, error)
}

type Protocol string

type Publisher interface {
	Publish(ctx context.Context, subject string, msgs ...*Message) error
}

type Subscriber interface {
	Subscribe(
		ctx context.Context,
		subject,
		consumer string,
		handler func(context.Context, *Message) Acknowledger,
	) (Unsubscribe, error)
}

type TLSConfig struct {
	Enabled        bool   `yaml:"enabled"`
	RootCAsFile    string `yaml:"root_cas_file"`
	ClientCertFile string `yaml:"client_cert_file"`
	ClientKeyFile  string `yaml:"client_key_file"`
}

type Unsubscribe func() error