event_handlers

Feb 7, 2023

Changes in this version

+ const ContextKeyAzureClient

+ const ContextKeyAzureParentAdministrativeUnitID

+ const ContextKeyKafkaErrorProducer

+ const ContextKeyKafkaProducer

+ const ContextKeyLogger

+ func CapabilityCreatedHandler(ctx context.Context, event kafkamsgs.Event)

+ func GetAzureParentAdministrativeUnitID(ctx context.Context) string

+ func GetLogger(ctx context.Context) *zap.Logger

+ func PermanentErrorHandler(ctx context.Context, event kafkamsgs.Event, oerr error)

+ type AzureClient interface

+ CreateAdministrativeUnitGroup func(ctx context.Context, requestPayload azure.CreateAdministrativeUnitGroupRequest) (*azure.CreateAdministrativeUnitGroupResponse, error)

+ func GetAzureClient(ctx context.Context) AzureClient

+ type KafkaProducer interface

+ WriteMessages func(ctx context.Context, msgs ...kafka.Message) error

+ func GetKafkaErrorProducer(ctx context.Context) KafkaProducer

+ func GetKafkaProducer(ctx context.Context) KafkaProducer