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
Source Files
Click to show internal directories.
Click to hide internal directories.