mbus

Documentation

Index

• Constants
• func Register(vendor string, service Service)
• type Confirmation
  • func (c Confirmation) String() string
• type EncodedResource
  • func (e EncodedResource) Decode() (*Resource, error)
• type Message
  • func (m *Message) AddAttribute(name string, value interface{})
  • func (m *Message) Payload() ([]byte, error)
• type Resource
  • func (r *Resource) Init() error
• type Service
  • func Lookup(vendor string) Service

Constants

const (
	ResourceTypeTopic        = "topic"
	ResourceTypeSubscription = "subscription"
	ResourceTypeQueue        = "queue"
)

Functions

func Register

func Register(vendor string, service Service)

Register register vendor service

Types

type Confirmation

type Confirmation struct {
	MessageID string
}

func (Confirmation) String

func (c Confirmation) String() string

type EncodedResource

type EncodedResource string

EncodedResource represents encoded resource

func (EncodedResource) Decode

func (e EncodedResource) Decode() (*Resource, error)

type Message

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

func (*Message) AddAttribute

func (m *Message) AddAttribute(name string, value interface{})

func (*Message) Payload

func (m *Message) Payload() ([]byte, error)

type Resource

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
}

func (*Resource) Init

func (r *Resource) Init() error

type Service

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

func Lookup

func Lookup(vendor string) Service

Lookup lookup