Documentation ¶
Index ¶
Constants ¶
View Source
const DEFAULT_PORT = 8081
Variables ¶
View Source
var GraphSet = wire.NewSet( deps, NewApp, NewEventConsumer, NewConsumerGroup, NewGrpcServer, )
Functions ¶
func NewEventConsumer ¶
func NewEventConsumer(trackingEventSvc service.EventService) sarama.ConsumerGroupHandler
Types ¶
type App ¶
func NewApp ¶
func NewApp( grpcServer *GrpcServer, consumerGroup *ConsumerGroup, ) App
type ConsumerGroup ¶
type ConsumerGroup struct {
// contains filtered or unexported fields
}
func NewConsumerGroup ¶
func NewConsumerGroup( postbackHandler sarama.ConsumerGroupHandler, ) *ConsumerGroup
type EventConsumer ¶
type EventConsumer struct {
// contains filtered or unexported fields
}
func (EventConsumer) Cleanup ¶
func (EventConsumer) Cleanup(_ sarama.ConsumerGroupSession) error
func (EventConsumer) ConsumeClaim ¶
func (h EventConsumer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (EventConsumer) Setup ¶
func (EventConsumer) Setup(sess sarama.ConsumerGroupSession) error
type GrpcServer ¶
func NewGrpcServer ¶
func NewGrpcServer( healthCheckHandler grpc_health_v1.HealthServer, ) *GrpcServer
Click to show internal directories.
Click to hide internal directories.