producer

Documentation

Index

• type Producer
  • func NewMaestroProducer(logger *zap.Logger, streamRedis *redis.Client) Producer
• type SinkStatusEvent
  • func (e SinkStatusEvent) Encode() map[string]interface{}

Types

type Producer

type Producer interface {
	// PublishSinkStatus to be used to publish the sink activity to the sinker
	PublishSinkStatus(ctx context.Context, ownerId string, sinkId string, status string, errorMessage string) error
}

func NewMaestroProducer

func NewMaestroProducer(logger *zap.Logger, streamRedis *redis.Client) Producer

type SinkStatusEvent

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

func (SinkStatusEvent) Encode

func (e SinkStatusEvent) Encode() map[string]interface{}