mbus

type Confirmation struct {
	MessageID string
}

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

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

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