notification

type AMQPService struct {
	Channel      *rabbitmq.AMQPChannel
	ExchnageName string
	ExchangeType string
	// contains filtered or unexported fields
}

type EventPayload struct {
	// ObjectID is the ID of the object( Organization ID or schema ID or resource ID etc)
	ObjectID string `json:"objectID"`
	// ObjectType is the type of the object("organization", "schema" etc)
	ObjectType string `json:"objectType"`
	// Event is one of "CREATE", "UPDATE" or "DELETE
	Event string `json:"event"`
	// Data holds the additional event data
	Data map[string]interface{} `json:"data"`
	// ErrorMessages is the actual errors if they happen.
	// Event payload in this case is published on error queue along with errors
	ErrorMessages []string `json:"errorMessages"`
}

type ObjectHandler func(amqpChan <-chan amqp.Delivery)

type Service interface {
	// SendObject sends an event obect to the queue to notify for new object event
	SendObject(e *EventPayload) error
	// ReceiveObjects receives platform object payload
	ReceiveObjects() error
	// AddObjectHandler adds new platform object handler
	AddObjectHandler(handler ObjectHandler)
	// SetExchangeName set the exchange name for the notification service
	SetExchangeName(exchnageName string)
	// GetExchangeName return the exchange name of notification service
	GetExchangeName(queueName string) string
}