msgqueue

type Handler interface {
	Receive(ctx context.Context, data []byte, attributes map[string]string) error
}

type MsgAttributes struct {
	DelayInSeconds int
	MessageType    string
	AggregationID  string
	Original       map[string]string
}

type PublishResult interface {
	GetMessageID(ctx context.Context) (string, error)
}

type Publisher interface {
	io.Closer
	TopicID() string
	Publish(ctx context.Context, data []byte, attributes map[string]string) (PublishResult, error)
}

type PublisherFactory interface {
	NewPublisher(ctx context.Context, projectID string, topicID string) (Publisher, error)
}

type Receiver interface {
	io.Closer
	Run(ctx context.Context, handler Handler) error
}