Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventService ¶
type EventService interface { HandleSinkCreate(ctx context.Context, event maestroredis.SinksUpdateEvent) error HandleSinkUpdate(ctx context.Context, event maestroredis.SinksUpdateEvent) error HandleSinkDelete(ctx context.Context, event maestroredis.SinksUpdateEvent) error HandleSinkActivity(ctx context.Context, event maestroredis.SinkerUpdateEvent) error HandleSinkIdle(ctx context.Context, event maestroredis.SinkerUpdateEvent) error }
EventService will hold the business logic of the handling events from both Listeners
func NewEventService ¶
func NewEventService(logger *zap.Logger, service deployment.Service, sinksGrpcClient *pb.SinkServiceClient) EventService
func NewTracingService ¶
func NewTracingService(logger *zap.Logger, service EventService, counter metrics.Counter, latency metrics.Histogram) EventService
Click to show internal directories.
Click to hide internal directories.