flow

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

type BaritoConsumerService interface {
	Start() error
	Close()
	WorkerMap() map[string]ConsumerWorker
	NewTopicEventWorker() ConsumerWorker
}

type ClusterConsumer interface {
	Messages() <-chan *sarama.ConsumerMessage
	Notifications() <-chan *cluster.Notification
	Errors() <-chan error
	MarkOffset(msg *sarama.ConsumerMessage, metadata string)
	Close() error
}

type ConsumerWorker interface {
	Start()
	Stop()
	Halt()
	IsStart() bool
	OnError(f func(error))
	OnSuccess(f func(*sarama.ConsumerMessage))
	OnNotification(f func(*cluster.Notification))
}

type ELasticTestHandler struct {
	ExistAPIStatus  int
	CreateAPIStatus int
	PostAPIStatus   int
	ResponseBody    []byte
	CustomHandler   func(w http.ResponseWriter, r *http.Request)
}

type Elastic interface {
	OnFailure(f func(*pb.Timber))
	Store(ctx context.Context, timber pb.Timber) error
	NewClient()
}

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

type KafkaAdmin interface {
	RefreshTopics() error
	SetTopics([]string)
	Topics() []string
	AddTopic(topic string)
	Exist(topic string) bool
	CreateTopic(topic string, numPartitions int32, replicationFactor int16) error
	Close()
}

type KafkaFactory interface {
	MakeKafkaAdmin() (admin KafkaAdmin, err error)
	MakeClusterConsumer(groupID, topic string, initialOffset int64) (worker ClusterConsumer, err error)
	MakeSyncProducer() (producer sarama.SyncProducer, err error)
}

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

type ProducerService interface {
	pb.ProducerServer
	Start() error
	LaunchREST() error
	Close()
}

type RateLimiter interface {
	IsHitLimit(topic string, count int, maxTokenIfNotExist int32) bool
	Start()
	Stop()
	IsStart() bool
	PutBucket(topic string, bucket *LeakyBucket)
	Bucket(topic string) *LeakyBucket
}