mbus

type Acknowledgement struct {
	Error error
	// contains filtered or unexported fields
}

type Confirmation struct {
	MessageID string
}

type EncodedResource string

type Message struct {
	ID         string
	Resource   *Resource
	TraceID    string
	Attributes map[string]interface{}
	Subject    string
	Data       interface{}
}

type Messenger interface {
	//OnMessage handles message
	OnMessage(ctx context.Context, message *Message, ack *Acknowledgement) error
}

type Notifier interface {
	Notify(ctx context.Context, messenger Messenger, options ...NotifierOption) error
}

type NotifierOption func(Notifier *NotifierOptions)

type NotifierOptions struct {
	//MaxPending max messages to process
	MaxPending int
	Resource   *Resource
}

type Resource struct {
	ID          string        `yaml:"ID" json:",omitempty"`
	Name        string        `yaml:"Name"  json:",omitempty"`
	Region      string        `yaml:"Region"  json:",omitempty"`
	Vendor      string        `yaml:"Vendor"  json:",omitempty"`
	URL         string        `yaml:"URL"  json:",omitempty"`
	Credentials *scy.Resource `yaml:"Resource"  json:",omitempty"`
	Type        string        `description:"resource type: topic, subscription" yaml:"Type"  json:",omitempty"`
	Client      interface{}   `description:"client" yaml:"-"`
	sync.Mutex  `yaml:"-" json:"-"`
}

type Service interface {
	Push(ctx context.Context, dest *Resource, message *Message) (*Confirmation, error)
}