retry

type Builder interface {
	WithBackoff(subscription.Backoff) Builder
	WithCache(ch cache.ICache) Builder
	WithIntervalFinder(finder subscription.IntervalFinder) Builder
	WithBrokerStore(store brokerstore.IBrokerStore) Builder
	WithSubscription(subs *subscription.Model) Builder
	WithMessageHandler(handler MessageHandler) Builder
	WithSubscriberID(subscriberID string) Builder
	WithErrChan(chan error) Builder
	WithTopicCore(topicCore topic.ICore) Builder
	Build() IRetrier
}

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

type IRetrier interface {
	Handle(context.Context, messagebroker.ReceivedMessage) error
	Start(context.Context) error
	Stop(context.Context)
}

type MessageHandler interface {
	Do(ctx context.Context, msg messagebroker.ReceivedMessage) error
}

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

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