brokerstore

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

type IBrokerStore interface {

	// GetConsumer returns for an existing consumer instance, if available returns that else creates as new instance
	GetConsumer(ctx context.Context, op messagebroker.ConsumerClientOptions) (messagebroker.Consumer, error)

	// RemoveConsumer deletes the consumer from the store
	RemoveConsumer(ctx context.Context, op messagebroker.ConsumerClientOptions) bool

	// GetProducer returns for an existing producer instance, if available returns that else creates as new instance
	GetProducer(ctx context.Context, op messagebroker.ProducerClientOptions) (messagebroker.Producer, error)

	// RemoveProducer deletes the producer from the store followed by a shutdown
	RemoveProducer(ctx context.Context, op messagebroker.ProducerClientOptions) bool

	// GetAdmin returns for an existing admin instance, if available returns that else creates as new instance
	GetAdmin(ctx context.Context, op messagebroker.AdminClientOptions) (messagebroker.Admin, error)

	// FlushAllProducers will iterate over the producer map, and flush all messages in the producer buffer
	FlushAllProducers(ctx context.Context)

	// IsTopicCleanUpEnabled returns true if topicCleanUp is enabled in the env
	IsTopicCleanUpEnabled() bool
}

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