gebus_amqp

type ACKingAdapter struct {
	// Deserializer used to deserialize events back to golang struct.
	Deserializer Deserializer

	Channel *amqp.Channel
	// Name of queue to receive from
	Queue string
	// Name of consumer
	Consumer string
	// contains filtered or unexported fields
}

type Client struct {
	Serializer Serializer

	// AMQP channel to use.
	Channel *amqp.Channel

	// ExchangeFunc provides exchange to use for specified event.
	// It's mandatory.
	ExchangeFunc func(ctx context.Context, event interface{}) (exchange string, err error)

	// KeyFunc provides key to use for specified event.
	// It's not mandatory. Default key is blank string.
	// In some exchanges key is ignored, so this is fine.
	KeyFunc func(ctx context.Context, event interface{}) (key string, err error)
}

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

type Deserializer interface {
	DeserializeEvent(ctx context.Context, delivery Delivery) (event interface{}, err error)
}

type Publishing struct {
	ContentType string
	Headers     map[string]string
	Body        []byte
}

type Serializer interface {
	SerializeEvent(ctx context.Context, event interface{}) (pub Publishing, err error)
}