Versions in this module Expand all Collapse all v0 v0.0.7 Sep 22, 2021 Changes in this version + var ErrIntOverflowPubsubmsg = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPubsubmsg = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupPubsubmsg = fmt.Errorf("proto: unexpected end of group") + var IHaveOrWant_Phase_name = map[int32]string + var IHaveOrWant_Phase_value = map[string]int32 + type ApplicationMsg struct + MsgBody []byte + MsgSeq uint64 + Sender string + SenderKey []byte + SenderSign []byte + Stations []string + Topics []string + func (*ApplicationMsg) Descriptor() ([]byte, []int) + func (*ApplicationMsg) ProtoMessage() + func (m *ApplicationMsg) GetMsgBody() []byte + func (m *ApplicationMsg) GetMsgSeq() uint64 + func (m *ApplicationMsg) GetSender() string + func (m *ApplicationMsg) GetSenderKey() []byte + func (m *ApplicationMsg) GetSenderSign() []byte + func (m *ApplicationMsg) GetStations() []string + func (m *ApplicationMsg) GetTopics() []string + func (m *ApplicationMsg) Marshal() (dAtA []byte, err error) + func (m *ApplicationMsg) MarshalTo(dAtA []byte) (int, error) + func (m *ApplicationMsg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ApplicationMsg) Reset() + func (m *ApplicationMsg) Size() (n int) + func (m *ApplicationMsg) String() string + func (m *ApplicationMsg) Unmarshal(dAtA []byte) error + func (m *ApplicationMsg) XXX_DiscardUnknown() + func (m *ApplicationMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ApplicationMsg) XXX_Merge(src proto.Message) + func (m *ApplicationMsg) XXX_Size() int + func (m *ApplicationMsg) XXX_Unmarshal(b []byte) error + type Heartbeat struct + Timestamp uint64 + TimestampRes uint64 + func (*Heartbeat) Descriptor() ([]byte, []int) + func (*Heartbeat) ProtoMessage() + func (m *Heartbeat) GetTimestamp() uint64 + func (m *Heartbeat) GetTimestampRes() uint64 + func (m *Heartbeat) Marshal() (dAtA []byte, err error) + func (m *Heartbeat) MarshalTo(dAtA []byte) (int, error) + func (m *Heartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Heartbeat) Reset() + func (m *Heartbeat) Size() (n int) + func (m *Heartbeat) String() string + func (m *Heartbeat) Unmarshal(dAtA []byte) error + func (m *Heartbeat) XXX_DiscardUnknown() + func (m *Heartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Heartbeat) XXX_Merge(src proto.Message) + func (m *Heartbeat) XXX_Size() int + func (m *Heartbeat) XXX_Unmarshal(b []byte) error + type IHaveOrWant struct + Have []*MsgMetadata + Phase IHaveOrWant_Phase + Want []*MsgMetadata + func (*IHaveOrWant) Descriptor() ([]byte, []int) + func (*IHaveOrWant) ProtoMessage() + func (m *IHaveOrWant) GetHave() []*MsgMetadata + func (m *IHaveOrWant) GetPhase() IHaveOrWant_Phase + func (m *IHaveOrWant) GetWant() []*MsgMetadata + func (m *IHaveOrWant) Marshal() (dAtA []byte, err error) + func (m *IHaveOrWant) MarshalTo(dAtA []byte) (int, error) + func (m *IHaveOrWant) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IHaveOrWant) Reset() + func (m *IHaveOrWant) Size() (n int) + func (m *IHaveOrWant) String() string + func (m *IHaveOrWant) Unmarshal(dAtA []byte) error + func (m *IHaveOrWant) XXX_DiscardUnknown() + func (m *IHaveOrWant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IHaveOrWant) XXX_Merge(src proto.Message) + func (m *IHaveOrWant) XXX_Size() int + func (m *IHaveOrWant) XXX_Unmarshal(b []byte) error + type IHaveOrWant_Phase int32 + const IHaveOrWant_IHave + const IHaveOrWant_IHaveAndIWant + const IHaveOrWant_IWant + func (IHaveOrWant_Phase) EnumDescriptor() ([]byte, []int) + func (x IHaveOrWant_Phase) String() string + type MsgMetadata struct + MsgSeq uint64 + Sender string + Topic string + func (*MsgMetadata) Descriptor() ([]byte, []int) + func (*MsgMetadata) ProtoMessage() + func (m *MsgMetadata) GetMsgSeq() uint64 + func (m *MsgMetadata) GetSender() string + func (m *MsgMetadata) GetTopic() string + func (m *MsgMetadata) Marshal() (dAtA []byte, err error) + func (m *MsgMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *MsgMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgMetadata) Reset() + func (m *MsgMetadata) Size() (n int) + func (m *MsgMetadata) String() string + func (m *MsgMetadata) Unmarshal(dAtA []byte) error + func (m *MsgMetadata) XXX_DiscardUnknown() + func (m *MsgMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgMetadata) XXX_Merge(src proto.Message) + func (m *MsgMetadata) XXX_Size() int + func (m *MsgMetadata) XXX_Unmarshal(b []byte) error + type PeeringMsg struct + CutOff []string + JoinUp []string + MsgSeq uint64 + func (*PeeringMsg) Descriptor() ([]byte, []int) + func (*PeeringMsg) ProtoMessage() + func (m *PeeringMsg) GetCutOff() []string + func (m *PeeringMsg) GetJoinUp() []string + func (m *PeeringMsg) GetMsgSeq() uint64 + func (m *PeeringMsg) Marshal() (dAtA []byte, err error) + func (m *PeeringMsg) MarshalTo(dAtA []byte) (int, error) + func (m *PeeringMsg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PeeringMsg) Reset() + func (m *PeeringMsg) Size() (n int) + func (m *PeeringMsg) String() string + func (m *PeeringMsg) Unmarshal(dAtA []byte) error + func (m *PeeringMsg) XXX_DiscardUnknown() + func (m *PeeringMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeeringMsg) XXX_Merge(src proto.Message) + func (m *PeeringMsg) XXX_Size() int + func (m *PeeringMsg) XXX_Unmarshal(b []byte) error + type PubsubMsg struct + Msg []*ApplicationMsg + PeeringCtrl *PeeringMsg + SpreadCtrl *IHaveOrWant + TopicCtrl *TopicMsg + func (*PubsubMsg) Descriptor() ([]byte, []int) + func (*PubsubMsg) ProtoMessage() + func (m *PubsubMsg) GetMsg() []*ApplicationMsg + func (m *PubsubMsg) GetPeeringCtrl() *PeeringMsg + func (m *PubsubMsg) GetSpreadCtrl() *IHaveOrWant + func (m *PubsubMsg) GetTopicCtrl() *TopicMsg + func (m *PubsubMsg) Marshal() (dAtA []byte, err error) + func (m *PubsubMsg) MarshalTo(dAtA []byte) (int, error) + func (m *PubsubMsg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PubsubMsg) Reset() + func (m *PubsubMsg) Size() (n int) + func (m *PubsubMsg) String() string + func (m *PubsubMsg) Unmarshal(dAtA []byte) error + func (m *PubsubMsg) XXX_DiscardUnknown() + func (m *PubsubMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PubsubMsg) XXX_Merge(src proto.Message) + func (m *PubsubMsg) XXX_Size() int + func (m *PubsubMsg) XXX_Unmarshal(b []byte) error + type TopicMsg struct + MsgSeq uint64 + Subscribed []string + Unsubscribed []string + func (*TopicMsg) Descriptor() ([]byte, []int) + func (*TopicMsg) ProtoMessage() + func (m *TopicMsg) GetMsgSeq() uint64 + func (m *TopicMsg) GetSubscribed() []string + func (m *TopicMsg) GetUnsubscribed() []string + func (m *TopicMsg) Marshal() (dAtA []byte, err error) + func (m *TopicMsg) MarshalTo(dAtA []byte) (int, error) + func (m *TopicMsg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TopicMsg) Reset() + func (m *TopicMsg) Size() (n int) + func (m *TopicMsg) String() string + func (m *TopicMsg) Unmarshal(dAtA []byte) error + func (m *TopicMsg) XXX_DiscardUnknown() + func (m *TopicMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TopicMsg) XXX_Merge(src proto.Message) + func (m *TopicMsg) XXX_Size() int + func (m *TopicMsg) XXX_Unmarshal(b []byte) error