event

type Event struct {
	ServiceName  string `json:"serviceName"`
	TopicName    string `json:"topicName"`
	IdempotentID string `json:"idempotentId"`
	Object       string `json:"object"`
	Message      string `json:"message"`
}

type EventMirroringServiceInterface interface {
	Consume(ctx *context.Context, topicName string) (*Event, *types.Error)
	IsExist(ctx *context.Context, event *Event) bool
	Publish(ctx *context.Context, params *PublishEventParams) *types.Error
	Acknowledge(ctx *context.Context, event *Event) *types.Error
}

type PublishEventParams struct {
	TopicNames     []string
	Body           []byte
	Metadata       map[string]string
	CallerFunction string
}