pb

package
v1.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 27, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPubsubmsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPubsubmsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPubsubmsg = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var IHaveOrWant_Phase_name = map[int32]string{
	0: "IHave",
	1: "IHaveAndIWant",
	2: "IWant",
}
View Source 
var IHaveOrWant_Phase_value = map[string]int32{
	"IHave":         0,
	"IHaveAndIWant": 1,
	"IWant":         2,
}

Functions

This section is empty.

Types

type ApplicationMsg 

type ApplicationMsg struct {
	Topics     []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	Sender     string   `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	MsgSeq     uint64   `protobuf:"varint,3,opt,name=msg_seq,json=msgSeq,proto3" json:"msg_seq,omitempty"`
	MsgBody    []byte   `protobuf:"bytes,4,opt,name=msg_body,json=msgBody,proto3" json:"msg_body,omitempty"`
	SenderKey  []byte   `protobuf:"bytes,5,opt,name=sender_key,json=senderKey,proto3" json:"sender_key,omitempty"`
	SenderSign []byte   `protobuf:"bytes,6,opt,name=sender_sign,json=senderSign,proto3" json:"sender_sign,omitempty"`
	Stations   []string `protobuf:"bytes,7,rep,name=stations,proto3" json:"stations,omitempty"`
}

func (*ApplicationMsg) Descriptor 

func (*ApplicationMsg) Descriptor() ([]byte, []int)

func (*ApplicationMsg) GetMsgBody 

func (m *ApplicationMsg) GetMsgBody() []byte

func (*ApplicationMsg) GetMsgSeq 

func (m *ApplicationMsg) GetMsgSeq() uint64

func (*ApplicationMsg) GetSender 

func (m *ApplicationMsg) GetSender() string

func (*ApplicationMsg) GetSenderKey 

func (m *ApplicationMsg) GetSenderKey() []byte

func (*ApplicationMsg) GetSenderSign 

func (m *ApplicationMsg) GetSenderSign() []byte

func (*ApplicationMsg) GetStations 

func (m *ApplicationMsg) GetStations() []string

func (*ApplicationMsg) GetTopics 

func (m *ApplicationMsg) GetTopics() []string

func (*ApplicationMsg) Marshal 

func (m *ApplicationMsg) Marshal() (dAtA []byte, err error)

func (*ApplicationMsg) MarshalTo 

func (m *ApplicationMsg) MarshalTo(dAtA []byte) (int, error)

func (*ApplicationMsg) MarshalToSizedBuffer 

func (m *ApplicationMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ApplicationMsg) ProtoMessage 

func (*ApplicationMsg) ProtoMessage()

func (*ApplicationMsg) Reset 

func (m *ApplicationMsg) Reset()

func (*ApplicationMsg) Size 

func (m *ApplicationMsg) Size() (n int)

func (*ApplicationMsg) String 

func (m *ApplicationMsg) String() string

func (*ApplicationMsg) Unmarshal 

func (m *ApplicationMsg) Unmarshal(dAtA []byte) error

func (*ApplicationMsg) XXX_DiscardUnknown 

func (m *ApplicationMsg) XXX_DiscardUnknown()

func (*ApplicationMsg) XXX_Marshal 

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

func (*ApplicationMsg) XXX_Merge 

func (m *ApplicationMsg) XXX_Merge(src proto.Message)

func (*ApplicationMsg) XXX_Size 

func (m *ApplicationMsg) XXX_Size() int

func (*ApplicationMsg) XXX_Unmarshal 

func (m *ApplicationMsg) XXX_Unmarshal(b []byte) error

type Heartbeat 

type Heartbeat struct {
	Timestamp    uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TimestampRes uint64 `protobuf:"varint,2,opt,name=timestamp_res,json=timestampRes,proto3" json:"timestamp_res,omitempty"`
}

func (*Heartbeat) Descriptor 

func (*Heartbeat) Descriptor() ([]byte, []int)

func (*Heartbeat) GetTimestamp 

func (m *Heartbeat) GetTimestamp() uint64

func (*Heartbeat) GetTimestampRes 

func (m *Heartbeat) GetTimestampRes() uint64

func (*Heartbeat) Marshal 

func (m *Heartbeat) Marshal() (dAtA []byte, err error)

func (*Heartbeat) MarshalTo 

func (m *Heartbeat) MarshalTo(dAtA []byte) (int, error)

func (*Heartbeat) MarshalToSizedBuffer 

func (m *Heartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset 

func (m *Heartbeat) Reset()

func (*Heartbeat) Size 

func (m *Heartbeat) Size() (n int)

func (*Heartbeat) String 

func (m *Heartbeat) String() string

func (*Heartbeat) Unmarshal 

func (m *Heartbeat) Unmarshal(dAtA []byte) error

func (*Heartbeat) XXX_DiscardUnknown 

func (m *Heartbeat) XXX_DiscardUnknown()

func (*Heartbeat) XXX_Marshal 

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

func (*Heartbeat) XXX_Merge 

func (m *Heartbeat) XXX_Merge(src proto.Message)

func (*Heartbeat) XXX_Size 

func (m *Heartbeat) XXX_Size() int

func (*Heartbeat) XXX_Unmarshal 

func (m *Heartbeat) XXX_Unmarshal(b []byte) error

type IHaveOrWant 

type IHaveOrWant struct {
	Phase IHaveOrWant_Phase `protobuf:"varint,1,opt,name=phase,proto3,enum=pubsub.IHaveOrWant_Phase" json:"phase,omitempty"`
	Have  []*MsgMetadata    `protobuf:"bytes,2,rep,name=have,proto3" json:"have,omitempty"`
	Want  []*MsgMetadata    `protobuf:"bytes,3,rep,name=want,proto3" json:"want,omitempty"`
}

func (*IHaveOrWant) Descriptor 

func (*IHaveOrWant) Descriptor() ([]byte, []int)

func (*IHaveOrWant) GetHave 

func (m *IHaveOrWant) GetHave() []*MsgMetadata

func (*IHaveOrWant) GetPhase 

func (m *IHaveOrWant) GetPhase() IHaveOrWant_Phase

func (*IHaveOrWant) GetWant 

func (m *IHaveOrWant) GetWant() []*MsgMetadata

func (*IHaveOrWant) Marshal 

func (m *IHaveOrWant) Marshal() (dAtA []byte, err error)

func (*IHaveOrWant) MarshalTo 

func (m *IHaveOrWant) MarshalTo(dAtA []byte) (int, error)

func (*IHaveOrWant) MarshalToSizedBuffer 

func (m *IHaveOrWant) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IHaveOrWant) ProtoMessage 

func (*IHaveOrWant) ProtoMessage()

func (*IHaveOrWant) Reset 

func (m *IHaveOrWant) Reset()

func (*IHaveOrWant) Size 

func (m *IHaveOrWant) Size() (n int)

func (*IHaveOrWant) String 

func (m *IHaveOrWant) String() string

func (*IHaveOrWant) Unmarshal 

func (m *IHaveOrWant) Unmarshal(dAtA []byte) error

func (*IHaveOrWant) XXX_DiscardUnknown 

func (m *IHaveOrWant) XXX_DiscardUnknown()

func (*IHaveOrWant) XXX_Marshal 

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

func (*IHaveOrWant) XXX_Merge 

func (m *IHaveOrWant) XXX_Merge(src proto.Message)

func (*IHaveOrWant) XXX_Size 

func (m *IHaveOrWant) XXX_Size() int

func (*IHaveOrWant) XXX_Unmarshal 

func (m *IHaveOrWant) XXX_Unmarshal(b []byte) error

type IHaveOrWant_Phase 

type IHaveOrWant_Phase int32
const (
	IHaveOrWant_IHave         IHaveOrWant_Phase = 0
	IHaveOrWant_IHaveAndIWant IHaveOrWant_Phase = 1
	IHaveOrWant_IWant         IHaveOrWant_Phase = 2
)

func (IHaveOrWant_Phase) EnumDescriptor 

func (IHaveOrWant_Phase) EnumDescriptor() ([]byte, []int)

func (IHaveOrWant_Phase) String 

func (x IHaveOrWant_Phase) String() string

type MsgMetadata 

type MsgMetadata struct {
	Topic  string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	MsgSeq uint64 `protobuf:"varint,3,opt,name=msg_seq,json=msgSeq,proto3" json:"msg_seq,omitempty"`
}

func (*MsgMetadata) Descriptor 

func (*MsgMetadata) Descriptor() ([]byte, []int)

func (*MsgMetadata) GetMsgSeq 

func (m *MsgMetadata) GetMsgSeq() uint64

func (*MsgMetadata) GetSender 

func (m *MsgMetadata) GetSender() string

func (*MsgMetadata) GetTopic 

func (m *MsgMetadata) GetTopic() string

func (*MsgMetadata) Marshal 

func (m *MsgMetadata) Marshal() (dAtA []byte, err error)

func (*MsgMetadata) MarshalTo 

func (m *MsgMetadata) MarshalTo(dAtA []byte) (int, error)

func (*MsgMetadata) MarshalToSizedBuffer 

func (m *MsgMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgMetadata) ProtoMessage 

func (*MsgMetadata) ProtoMessage()

func (*MsgMetadata) Reset 

func (m *MsgMetadata) Reset()

func (*MsgMetadata) Size 

func (m *MsgMetadata) Size() (n int)

func (*MsgMetadata) String 

func (m *MsgMetadata) String() string

func (*MsgMetadata) Unmarshal 

func (m *MsgMetadata) Unmarshal(dAtA []byte) error

func (*MsgMetadata) XXX_DiscardUnknown 

func (m *MsgMetadata) XXX_DiscardUnknown()

func (*MsgMetadata) XXX_Marshal 

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

func (*MsgMetadata) XXX_Merge 

func (m *MsgMetadata) XXX_Merge(src proto.Message)

func (*MsgMetadata) XXX_Size 

func (m *MsgMetadata) XXX_Size() int

func (*MsgMetadata) XXX_Unmarshal 

func (m *MsgMetadata) XXX_Unmarshal(b []byte) error

type PeeringMsg 

type PeeringMsg struct {
	CutOff []string `protobuf:"bytes,1,rep,name=cut_off,json=cutOff,proto3" json:"cut_off,omitempty"`
	JoinUp []string `protobuf:"bytes,2,rep,name=join_up,json=joinUp,proto3" json:"join_up,omitempty"`
	MsgSeq uint64   `protobuf:"varint,3,opt,name=msg_seq,json=msgSeq,proto3" json:"msg_seq,omitempty"`
}

func (*PeeringMsg) Descriptor 

func (*PeeringMsg) Descriptor() ([]byte, []int)

func (*PeeringMsg) GetCutOff 

func (m *PeeringMsg) GetCutOff() []string

func (*PeeringMsg) GetJoinUp 

func (m *PeeringMsg) GetJoinUp() []string

func (*PeeringMsg) GetMsgSeq 

func (m *PeeringMsg) GetMsgSeq() uint64

func (*PeeringMsg) Marshal 

func (m *PeeringMsg) Marshal() (dAtA []byte, err error)

func (*PeeringMsg) MarshalTo 

func (m *PeeringMsg) MarshalTo(dAtA []byte) (int, error)

func (*PeeringMsg) MarshalToSizedBuffer 

func (m *PeeringMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeeringMsg) ProtoMessage 

func (*PeeringMsg) ProtoMessage()

func (*PeeringMsg) Reset 

func (m *PeeringMsg) Reset()

func (*PeeringMsg) Size 

func (m *PeeringMsg) Size() (n int)

func (*PeeringMsg) String 

func (m *PeeringMsg) String() string

func (*PeeringMsg) Unmarshal 

func (m *PeeringMsg) Unmarshal(dAtA []byte) error

func (*PeeringMsg) XXX_DiscardUnknown 

func (m *PeeringMsg) XXX_DiscardUnknown()

func (*PeeringMsg) XXX_Marshal 

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

func (*PeeringMsg) XXX_Merge 

func (m *PeeringMsg) XXX_Merge(src proto.Message)

func (*PeeringMsg) XXX_Size 

func (m *PeeringMsg) XXX_Size() int

func (*PeeringMsg) XXX_Unmarshal 

func (m *PeeringMsg) XXX_Unmarshal(b []byte) error

type PubsubMsg 

type PubsubMsg struct {
	Msg         []*ApplicationMsg `protobuf:"bytes,1,rep,name=msg,proto3" json:"msg,omitempty"`
	SpreadCtrl  *IHaveOrWant      `protobuf:"bytes,2,opt,name=spread_ctrl,json=spreadCtrl,proto3" json:"spread_ctrl,omitempty"`
	TopicCtrl   *TopicMsg         `protobuf:"bytes,3,opt,name=topic_ctrl,json=topicCtrl,proto3" json:"topic_ctrl,omitempty"`
	PeeringCtrl *PeeringMsg       `protobuf:"bytes,4,opt,name=peering_ctrl,json=peeringCtrl,proto3" json:"peering_ctrl,omitempty"`
}

func (*PubsubMsg) Descriptor 

func (*PubsubMsg) Descriptor() ([]byte, []int)

func (*PubsubMsg) GetMsg 

func (m *PubsubMsg) GetMsg() []*ApplicationMsg

func (*PubsubMsg) GetPeeringCtrl 

func (m *PubsubMsg) GetPeeringCtrl() *PeeringMsg

func (*PubsubMsg) GetSpreadCtrl 

func (m *PubsubMsg) GetSpreadCtrl() *IHaveOrWant

func (*PubsubMsg) GetTopicCtrl 

func (m *PubsubMsg) GetTopicCtrl() *TopicMsg

func (*PubsubMsg) Marshal 

func (m *PubsubMsg) Marshal() (dAtA []byte, err error)

func (*PubsubMsg) MarshalTo 

func (m *PubsubMsg) MarshalTo(dAtA []byte) (int, error)

func (*PubsubMsg) MarshalToSizedBuffer 

func (m *PubsubMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PubsubMsg) ProtoMessage 

func (*PubsubMsg) ProtoMessage()

func (*PubsubMsg) Reset 

func (m *PubsubMsg) Reset()

func (*PubsubMsg) Size 

func (m *PubsubMsg) Size() (n int)

func (*PubsubMsg) String 

func (m *PubsubMsg) String() string

func (*PubsubMsg) Unmarshal 

func (m *PubsubMsg) Unmarshal(dAtA []byte) error

func (*PubsubMsg) XXX_DiscardUnknown 

func (m *PubsubMsg) XXX_DiscardUnknown()

func (*PubsubMsg) XXX_Marshal 

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

func (*PubsubMsg) XXX_Merge 

func (m *PubsubMsg) XXX_Merge(src proto.Message)

func (*PubsubMsg) XXX_Size 

func (m *PubsubMsg) XXX_Size() int

func (*PubsubMsg) XXX_Unmarshal 

func (m *PubsubMsg) XXX_Unmarshal(b []byte) error

type TopicMsg 

type TopicMsg struct {
	Subscribed   []string `protobuf:"bytes,1,rep,name=subscribed,proto3" json:"subscribed,omitempty"`
	Unsubscribed []string `protobuf:"bytes,2,rep,name=unsubscribed,proto3" json:"unsubscribed,omitempty"`
	MsgSeq       uint64   `protobuf:"varint,3,opt,name=msg_seq,json=msgSeq,proto3" json:"msg_seq,omitempty"`
}

func (*TopicMsg) Descriptor 

func (*TopicMsg) Descriptor() ([]byte, []int)

func (*TopicMsg) GetMsgSeq 

func (m *TopicMsg) GetMsgSeq() uint64

func (*TopicMsg) GetSubscribed 

func (m *TopicMsg) GetSubscribed() []string

func (*TopicMsg) GetUnsubscribed 

func (m *TopicMsg) GetUnsubscribed() []string

func (*TopicMsg) Marshal 

func (m *TopicMsg) Marshal() (dAtA []byte, err error)

func (*TopicMsg) MarshalTo 

func (m *TopicMsg) MarshalTo(dAtA []byte) (int, error)

func (*TopicMsg) MarshalToSizedBuffer 

func (m *TopicMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TopicMsg) ProtoMessage 

func (*TopicMsg) ProtoMessage()

func (*TopicMsg) Reset 

func (m *TopicMsg) Reset()

func (*TopicMsg) Size 

func (m *TopicMsg) Size() (n int)

func (*TopicMsg) String 

func (m *TopicMsg) String() string

func (*TopicMsg) Unmarshal 

func (m *TopicMsg) Unmarshal(dAtA []byte) error

func (*TopicMsg) XXX_DiscardUnknown 

func (m *TopicMsg) XXX_DiscardUnknown()

func (*TopicMsg) XXX_Marshal 

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

func (*TopicMsg) XXX_Merge 

func (m *TopicMsg) XXX_Merge(src proto.Message)

func (*TopicMsg) XXX_Size 

func (m *TopicMsg) XXX_Size() int

func (*TopicMsg) XXX_Unmarshal 

func (m *TopicMsg) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.