amqp

Jan 30, 2019

Changes in this version

type Message

+ func NewProtobufMessage(d interface{}) (*Message, error)

+ type OptionFunc func(*TracedPublisher) error

+ func Timeout(timeout time.Duration) OptionFunc

+ type User struct

+ Firstname *string

+ Lastname *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*User) Descriptor() ([]byte, []int)

+ func (*User) ProtoMessage()

+ func (m *User) GetFirstname() string

+ func (m *User) GetLastname() string

+ func (m *User) Reset()

+ func (m *User) String() string

+ func (m *User) XXX_DiscardUnknown()

+ func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *User) XXX_Merge(src proto.Message)

+ func (m *User) XXX_Size() int

+ func (m *User) XXX_Unmarshal(b []byte) error

Jul 8, 2018

Changes in this version

+ type Message struct

+ func NewJSONMessage(d interface{}) (*Message, error)

+ func NewMessage(ct string, body []byte) *Message

+ type Publisher interface

+ Close func(ctx context.Context) error

+ Publish func(ctx context.Context, msg *Message) error

+ type TracedPublisher struct

+ func NewPublisher(url, exc string) (*TracedPublisher, error)

+ func (tc *TracedPublisher) Close(ctx context.Context) error

+ func (tc *TracedPublisher) Publish(ctx context.Context, msg *Message) error