messaging

type AmpqChannel interface {
	Close() error
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
}

type Channel interface {
	Close() error
	GetType() string
	Accept(event Event) error
}

type Event struct {
	Id          string           `json:"id,omitempty" yaml:"id,omitempty"`
	Type        string           `json:"type,omitempty" yaml:"type,omitempty"`
	Domain      string           `json:"domain,omitempty" yaml:"domain,omitempty"`
	Src         string           `json:"source,omitempty" yaml:"source,omitempty"`
	Version     string           `json:"version,omitempty" yaml:"version,omitempty"`
	Properties  json.RawMessage  `json:"properties,omitempty" yaml:"properties,omitempty"`
	PublishedAt time.ISODatetime `json:"published_at,omitempty" yaml:"published_at,omitempty"`
	TriggeredBy string           `json:"triggered_by,omitempty" yaml:"triggered_by,omitempty"`
}

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

type KafkaProducer interface {
	Close() error
	SendMessage(msg *sarama.ProducerMessage) (partition int32, offset int64, err error)
}

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

type PulsarProducer interface {
	Close() error
	SendAndGetMsgID(context.Context, pulsar.ProducerMessage) (pulsar.MessageID, error)
}

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