protobuf

Documentation

Index

• Variables
• type MsgType
  • func (x MsgType) Enum() *MsgType
  • func (MsgType) EnumDescriptor() ([]byte, []int)
  • func (x MsgType) String() string
  • func (x *MsgType) UnmarshalJSON(data []byte) error
• type PbMessage
  • func (*PbMessage) Descriptor() ([]byte, []int)
  • func (m *PbMessage) GetHistory() []*PbMessage
  • func (m *PbMessage) GetMsgType() MsgType
  • func (m *PbMessage) GetSource() int64
  • func (m *PbMessage) GetStep() int64
  • func (*PbMessage) ProtoMessage()
  • func (m *PbMessage) Reset()
  • func (m *PbMessage) String() string
  • func (m *PbMessage) XXX_DiscardUnknown()
  • func (m *PbMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PbMessage) XXX_Merge(src proto.Message)
  • func (m *PbMessage) XXX_Size() int
  • func (m *PbMessage) XXX_Unmarshal(b []byte) error

Variables

var MsgType_name = map[int32]string{
	0: "Raw",
	1: "Ack",
	2: "Wit",
	3: "Catchup",
}

var MsgType_value = map[string]int32{
	"Raw":     0,
	"Ack":     1,
	"Wit":     2,
	"Catchup": 3,
}

Types

type MsgType

type MsgType int32

const (
	MsgType_Raw     MsgType = 0
	MsgType_Ack     MsgType = 1
	MsgType_Wit     MsgType = 2
	MsgType_Catchup MsgType = 3
)

func (MsgType) Enum

func (x MsgType) Enum() *MsgType

func (MsgType) EnumDescriptor

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

func (MsgType) String

func (x MsgType) String() string

func (*MsgType) UnmarshalJSON

func (x *MsgType) UnmarshalJSON(data []byte) error

type PbMessage

type PbMessage struct {
	MsgType              *MsgType     `protobuf:"varint,1,req,name=Msg_type,json=MsgType,enum=libp2p_pubsub.MsgType" json:"Msg_type,omitempty"`
	Source               *int64       `protobuf:"varint,2,req,name=source" json:"source,omitempty"`
	Step                 *int64       `protobuf:"varint,3,req,name=step" json:"step,omitempty"`
	History              []*PbMessage `protobuf:"bytes,4,rep,name=history" json:"history,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PbMessage) Descriptor

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

func (*PbMessage) GetHistory

func (m *PbMessage) GetHistory() []*PbMessage

func (*PbMessage) GetMsgType

func (m *PbMessage) GetMsgType() MsgType

func (*PbMessage) GetSource

func (m *PbMessage) GetSource() int64

func (*PbMessage) GetStep

func (m *PbMessage) GetStep() int64

func (*PbMessage) ProtoMessage

func (*PbMessage) ProtoMessage()

func (*PbMessage) Reset

func (m *PbMessage) Reset()

func (*PbMessage) String

func (m *PbMessage) String() string

func (*PbMessage) XXX_DiscardUnknown

func (m *PbMessage) XXX_DiscardUnknown()

func (*PbMessage) XXX_Marshal

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

func (*PbMessage) XXX_Merge

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

func (*PbMessage) XXX_Size

func (m *PbMessage) XXX_Size() int

func (*PbMessage) XXX_Unmarshal

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