ganyu

type Broker interface {
	CreateTopic(ctx context.Context, topic domain.Topic) error
	Push(ctx context.Context, topic, payload, partitionKey string) error
}

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

type MQRepository interface {
	Push(ctx context.Context, topic, payload string, partition int) error
	Pop(ctx context.Context, topic string, partition int) (string, error)
}

type Option func(opt *BrokerOpts)

type Producer struct {
	Broker Broker
}

type RepositorySet interface {
	TopicRepository
	MQRepository
}

type TopicRepository interface {
	CreateTopic(ctx context.Context, topic domain.Topic) error
	GetTopicPartitions(ctx context.Context, topic string) (int, error)
}