consumer

type ConsumerHandler interface {
	Handle(ConsumerMessage) (map[string]interface{}, error)
}

type ConsumerMessage struct {
	QueueMessage *dto.QueueMessage
	// contains filtered or unexported fields
}

type ErrorMessage struct {
	Source        string                 `json:"source,omitempty"`
	Input         map[string]interface{} `json:"input,omitempty"`
	Reason        string                 `json:"reason"`
	Output        map[string]interface{} `json:"output,omitempty"`
	SourceMessage *dto.QueueMessage      `json:"-"`
}

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

type NotifyEventMessageBody struct {
	URL           string                 `json:"url"`
	ClientID      string                 `json:"client_id"`
	AssociationId string                 `json:"association_id"`
	Retries       int                    `json:"retries"`
	AuthProvider  string                 `json:"auth_provider"`
	Body          map[string]interface{} `json:"body"`
}

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

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