Versions in this module Expand all Collapse all v0 v0.12.0 Mar 29, 2021 Changes in this version + var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group") + type Message struct + Channel string + Created int64 + Payload []byte + Protocol string + Publisher string + Subtopic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetChannel() string + func (m *Message) GetCreated() int64 + func (m *Message) GetPayload() []byte + func (m *Message) GetProtocol() string + func (m *Message) GetPublisher() string + func (m *Message) GetSubtopic() string + func (m *Message) Marshal() (dAtA []byte, err error) + func (m *Message) MarshalTo(dAtA []byte) (int, error) + func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message) Reset() + func (m *Message) Size() (n int) + func (m *Message) String() string + func (m *Message) Unmarshal(dAtA []byte) error + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Merge(src proto.Message) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + type MessageHandler func(msg Message) error + type PubSub interface + type Publisher interface + Publish func(topic string, msg Message) error + type Subscriber interface + Subscribe func(topic string, handler MessageHandler) error + Unsubscribe func(topic string) error
Go to main page