ganyu

Documentation

Index

• type Broker
  • func NewDefaultBroker(cfg redisstorage.PoolOptions, opts ...Option) Broker
• type BrokerOpts
• type MQRepository
• type Option
• type Producer
  • func NewProducer(broker Broker) *Producer
  • func (p *Producer) Produce(ctx context.Context, topic, message string, partitionKey string) error
• type RepositorySet
• type TopicRepository

Types

type Broker

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

func NewDefaultBroker

func NewDefaultBroker(cfg redisstorage.PoolOptions, opts ...Option) Broker

type BrokerOpts

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

type MQRepository

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

type Option func(opt *BrokerOpts)

type Producer

type Producer struct {
	Broker Broker
}

func NewProducer

func NewProducer(broker Broker) *Producer

func (*Producer) Produce

func (p *Producer) Produce(ctx context.Context, topic, message string, partitionKey string) error

type RepositorySet

type RepositorySet interface {
	TopicRepository
	MQRepository
}

type TopicRepository

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