eda

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

type EventPublisherServiceInterface interface {
	Publish(ctx *context.Context, params *PublishEventParams) *types.Error
}

type Message struct {
	Topic                    string     `json:"topic" bson:"topic"`
	Message                  []byte     `json:"message" bson:"message"`
	DistributedTransactionID string     `json:"distributedTransactionId" bson:"distributedTransactionId"`
	UID                      string     `json:"uid" bson:"uid"`
	Path                     string     `json:"path" bson:"path"`
	Method                   string     `json:"method" bson:"method"`
	Action                   string     `json:"action" bson:"action"`
	Status                   string     `json:"status" bson:"status"`
	CollectedAt              *time.Time `json:"collectedAt" bson:"collectedAt"`
	FulfilledAt              *time.Time `json:"fulfilledAt" bson:"fulfilledAt"`
	RetrialAttempts          int        `json:"retrialAttempts" bson:"retrialAttempts"`
	Owner                    *int       `json:"owner" bson:"owner"`
	CreatedAt                time.Time  `json:"createdAt" bson:"createdAt"`
	UpdatedAt                time.Time  `json:"updatedAt" bson:"updatedAt"`
	DeletedAt                *time.Time `json:"deletedAt" bson:"deletedAt"`
}

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