pubsub

type Client interface {
	Publisher
	Subscriber
	Health() datasource.Health

	CreateTopic(context context.Context, name string) error
	DeleteTopic(context context.Context, name string) error
	Query(ctx context.Context, query string, args ...any) ([]byte, error)

	Close() error
}

type Committer interface {
	Commit()
}

type Log struct {
	Mode          string `json:"mode"`
	CorrelationID string `json:"correlationID"`
	MessageValue  string `json:"messageValue"`
	Topic         string `json:"topic"`
	Host          string `json:"host"`
	PubSubBackend string `json:"pubSubBackend"`
	Time          int64  `json:"time"`
}

type Logger interface {
	Debugf(format string, args ...any)
	Debug(args ...any)
	Logf(format string, args ...any)
	Log(args ...any)
	Errorf(format string, args ...any)
	Error(args ...any)
}

type Message struct {
	Topic    string
	Value    []byte
	MetaData any

	Committer
	// contains filtered or unexported fields
}

type Publisher interface {
	Publish(ctx context.Context, topic string, message []byte) error
}

type Subscriber interface {
	Subscribe(ctx context.Context, topic string) (*Message, error)
}