Documentation ¶
Index ¶
- Variables
- type Buffer
- func (*Buffer) Descriptor() ([]byte, []int)
- func (m *Buffer) GetData() []byte
- func (m *Buffer) Marshal() (dAtA []byte, err error)
- func (m *Buffer) MarshalTo(dAtA []byte) (int, error)
- func (m *Buffer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Buffer) ProtoMessage()
- func (m *Buffer) ProtoSize() (n int)
- func (m *Buffer) Reset()
- func (m *Buffer) String() string
- func (m *Buffer) Unmarshal(dAtA []byte) error
- func (m *Buffer) XXX_DiscardUnknown()
- func (m *Buffer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Buffer) XXX_Merge(src proto.Message)
- func (m *Buffer) XXX_Size() int
- func (m *Buffer) XXX_Unmarshal(b []byte) error
- type MessagePayloadAHeap
- func (*MessagePayloadAHeap) Descriptor() ([]byte, []int)
- func (m *MessagePayloadAHeap) GetPayloads() []*PayloadA
- func (m *MessagePayloadAHeap) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadAHeap) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadAHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadAHeap) ProtoMessage()
- func (m *MessagePayloadAHeap) ProtoSize() (n int)
- func (m *MessagePayloadAHeap) Reset()
- func (m *MessagePayloadAHeap) String() string
- func (m *MessagePayloadAHeap) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadAHeap) XXX_DiscardUnknown()
- func (m *MessagePayloadAHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadAHeap) XXX_Merge(src proto.Message)
- func (m *MessagePayloadAHeap) XXX_Size() int
- func (m *MessagePayloadAHeap) XXX_Unmarshal(b []byte) error
- type MessagePayloadALessHeap
- func (*MessagePayloadALessHeap) Descriptor() ([]byte, []int)
- func (m *MessagePayloadALessHeap) GetPayloads() []PayloadA
- func (m *MessagePayloadALessHeap) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadALessHeap) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadALessHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadALessHeap) ProtoMessage()
- func (m *MessagePayloadALessHeap) ProtoSize() (n int)
- func (m *MessagePayloadALessHeap) Reset()
- func (m *MessagePayloadALessHeap) String() string
- func (m *MessagePayloadALessHeap) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadALessHeap) XXX_DiscardUnknown()
- func (m *MessagePayloadALessHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadALessHeap) XXX_Merge(src proto.Message)
- func (m *MessagePayloadALessHeap) XXX_Size() int
- func (m *MessagePayloadALessHeap) XXX_Unmarshal(b []byte) error
- type MessagePayloadASplit
- func (*MessagePayloadASplit) Descriptor() ([]byte, []int)
- func (m *MessagePayloadASplit) GetDatas() [][]byte
- func (m *MessagePayloadASplit) GetIds() []int64
- func (m *MessagePayloadASplit) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadASplit) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadASplit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadASplit) ProtoMessage()
- func (m *MessagePayloadASplit) ProtoSize() (n int)
- func (m *MessagePayloadASplit) Reset()
- func (m *MessagePayloadASplit) String() string
- func (m *MessagePayloadASplit) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadASplit) XXX_DiscardUnknown()
- func (m *MessagePayloadASplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadASplit) XXX_Merge(src proto.Message)
- func (m *MessagePayloadASplit) XXX_Size() int
- func (m *MessagePayloadASplit) XXX_Unmarshal(b []byte) error
- type MessagePayloadBHeap
- func (*MessagePayloadBHeap) Descriptor() ([]byte, []int)
- func (m *MessagePayloadBHeap) GetPayloads() []*PayloadB
- func (m *MessagePayloadBHeap) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadBHeap) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadBHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadBHeap) ProtoMessage()
- func (m *MessagePayloadBHeap) ProtoSize() (n int)
- func (m *MessagePayloadBHeap) Reset()
- func (m *MessagePayloadBHeap) String() string
- func (m *MessagePayloadBHeap) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadBHeap) XXX_DiscardUnknown()
- func (m *MessagePayloadBHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadBHeap) XXX_Merge(src proto.Message)
- func (m *MessagePayloadBHeap) XXX_Size() int
- func (m *MessagePayloadBHeap) XXX_Unmarshal(b []byte) error
- type MessagePayloadBLessHeap
- func (*MessagePayloadBLessHeap) Descriptor() ([]byte, []int)
- func (m *MessagePayloadBLessHeap) GetPayloads() []PayloadB
- func (m *MessagePayloadBLessHeap) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadBLessHeap) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadBLessHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadBLessHeap) ProtoMessage()
- func (m *MessagePayloadBLessHeap) ProtoSize() (n int)
- func (m *MessagePayloadBLessHeap) Reset()
- func (m *MessagePayloadBLessHeap) String() string
- func (m *MessagePayloadBLessHeap) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadBLessHeap) XXX_DiscardUnknown()
- func (m *MessagePayloadBLessHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadBLessHeap) XXX_Merge(src proto.Message)
- func (m *MessagePayloadBLessHeap) XXX_Size() int
- func (m *MessagePayloadBLessHeap) XXX_Unmarshal(b []byte) error
- type MessagePayloadBSplit
- func (*MessagePayloadBSplit) Descriptor() ([]byte, []int)
- func (m *MessagePayloadBSplit) GetDatas() []Buffer
- func (m *MessagePayloadBSplit) GetIds() []int64
- func (m *MessagePayloadBSplit) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadBSplit) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadBSplit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadBSplit) ProtoMessage()
- func (m *MessagePayloadBSplit) ProtoSize() (n int)
- func (m *MessagePayloadBSplit) Reset()
- func (m *MessagePayloadBSplit) String() string
- func (m *MessagePayloadBSplit) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadBSplit) XXX_DiscardUnknown()
- func (m *MessagePayloadBSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadBSplit) XXX_Merge(src proto.Message)
- func (m *MessagePayloadBSplit) XXX_Size() int
- func (m *MessagePayloadBSplit) XXX_Unmarshal(b []byte) error
- type MessagePayloadCHeap
- func (*MessagePayloadCHeap) Descriptor() ([]byte, []int)
- func (m *MessagePayloadCHeap) GetPayloads() []*PayloadC
- func (m *MessagePayloadCHeap) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadCHeap) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadCHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadCHeap) ProtoMessage()
- func (m *MessagePayloadCHeap) ProtoSize() (n int)
- func (m *MessagePayloadCHeap) Reset()
- func (m *MessagePayloadCHeap) String() string
- func (m *MessagePayloadCHeap) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadCHeap) XXX_DiscardUnknown()
- func (m *MessagePayloadCHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadCHeap) XXX_Merge(src proto.Message)
- func (m *MessagePayloadCHeap) XXX_Size() int
- func (m *MessagePayloadCHeap) XXX_Unmarshal(b []byte) error
- type MessagePayloadCLessHeap
- func (*MessagePayloadCLessHeap) Descriptor() ([]byte, []int)
- func (m *MessagePayloadCLessHeap) GetPayloads() []PayloadC
- func (m *MessagePayloadCLessHeap) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadCLessHeap) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadCLessHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadCLessHeap) ProtoMessage()
- func (m *MessagePayloadCLessHeap) ProtoSize() (n int)
- func (m *MessagePayloadCLessHeap) Reset()
- func (m *MessagePayloadCLessHeap) String() string
- func (m *MessagePayloadCLessHeap) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadCLessHeap) XXX_DiscardUnknown()
- func (m *MessagePayloadCLessHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadCLessHeap) XXX_Merge(src proto.Message)
- func (m *MessagePayloadCLessHeap) XXX_Size() int
- func (m *MessagePayloadCLessHeap) XXX_Unmarshal(b []byte) error
- type MessagePayloadCSplit
- func (*MessagePayloadCSplit) Descriptor() ([]byte, []int)
- func (m *MessagePayloadCSplit) GetDatas() []*Buffer
- func (m *MessagePayloadCSplit) GetIds() []int64
- func (m *MessagePayloadCSplit) Marshal() (dAtA []byte, err error)
- func (m *MessagePayloadCSplit) MarshalTo(dAtA []byte) (int, error)
- func (m *MessagePayloadCSplit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessagePayloadCSplit) ProtoMessage()
- func (m *MessagePayloadCSplit) ProtoSize() (n int)
- func (m *MessagePayloadCSplit) Reset()
- func (m *MessagePayloadCSplit) String() string
- func (m *MessagePayloadCSplit) Unmarshal(dAtA []byte) error
- func (m *MessagePayloadCSplit) XXX_DiscardUnknown()
- func (m *MessagePayloadCSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessagePayloadCSplit) XXX_Merge(src proto.Message)
- func (m *MessagePayloadCSplit) XXX_Size() int
- func (m *MessagePayloadCSplit) XXX_Unmarshal(b []byte) error
- type PayloadA
- func (*PayloadA) Descriptor() ([]byte, []int)
- func (m *PayloadA) GetData() []byte
- func (m *PayloadA) GetId() int64
- func (m *PayloadA) Marshal() (dAtA []byte, err error)
- func (m *PayloadA) MarshalTo(dAtA []byte) (int, error)
- func (m *PayloadA) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PayloadA) ProtoMessage()
- func (m *PayloadA) ProtoSize() (n int)
- func (m *PayloadA) Reset()
- func (m *PayloadA) String() string
- func (m *PayloadA) Unmarshal(dAtA []byte) error
- func (m *PayloadA) XXX_DiscardUnknown()
- func (m *PayloadA) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PayloadA) XXX_Merge(src proto.Message)
- func (m *PayloadA) XXX_Size() int
- func (m *PayloadA) XXX_Unmarshal(b []byte) error
- type PayloadB
- func (*PayloadB) Descriptor() ([]byte, []int)
- func (m *PayloadB) GetData() Buffer
- func (m *PayloadB) GetId() int64
- func (m *PayloadB) Marshal() (dAtA []byte, err error)
- func (m *PayloadB) MarshalTo(dAtA []byte) (int, error)
- func (m *PayloadB) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PayloadB) ProtoMessage()
- func (m *PayloadB) ProtoSize() (n int)
- func (m *PayloadB) Reset()
- func (m *PayloadB) String() string
- func (m *PayloadB) Unmarshal(dAtA []byte) error
- func (m *PayloadB) XXX_DiscardUnknown()
- func (m *PayloadB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PayloadB) XXX_Merge(src proto.Message)
- func (m *PayloadB) XXX_Size() int
- func (m *PayloadB) XXX_Unmarshal(b []byte) error
- type PayloadC
- func (*PayloadC) Descriptor() ([]byte, []int)
- func (m *PayloadC) GetData() *Buffer
- func (m *PayloadC) GetId() int64
- func (m *PayloadC) Marshal() (dAtA []byte, err error)
- func (m *PayloadC) MarshalTo(dAtA []byte) (int, error)
- func (m *PayloadC) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PayloadC) ProtoMessage()
- func (m *PayloadC) ProtoSize() (n int)
- func (m *PayloadC) Reset()
- func (m *PayloadC) String() string
- func (m *PayloadC) Unmarshal(dAtA []byte) error
- func (m *PayloadC) XXX_DiscardUnknown()
- func (m *PayloadC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PayloadC) XXX_Merge(src proto.Message)
- func (m *PayloadC) XXX_Size() int
- func (m *PayloadC) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Buffer ¶
type Buffer struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
func (*Buffer) Descriptor ¶
func (*Buffer) MarshalToSizedBuffer ¶
func (*Buffer) ProtoMessage ¶
func (*Buffer) ProtoMessage()
func (*Buffer) XXX_DiscardUnknown ¶
func (m *Buffer) XXX_DiscardUnknown()
func (*Buffer) XXX_Marshal ¶
func (*Buffer) XXX_Unmarshal ¶
type MessagePayloadAHeap ¶
type MessagePayloadAHeap struct {
Payloads []*PayloadA `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
}
func (*MessagePayloadAHeap) Descriptor ¶
func (*MessagePayloadAHeap) Descriptor() ([]byte, []int)
func (*MessagePayloadAHeap) GetPayloads ¶
func (m *MessagePayloadAHeap) GetPayloads() []*PayloadA
func (*MessagePayloadAHeap) Marshal ¶
func (m *MessagePayloadAHeap) Marshal() (dAtA []byte, err error)
func (*MessagePayloadAHeap) MarshalTo ¶
func (m *MessagePayloadAHeap) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadAHeap) MarshalToSizedBuffer ¶
func (m *MessagePayloadAHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadAHeap) ProtoMessage ¶
func (*MessagePayloadAHeap) ProtoMessage()
func (*MessagePayloadAHeap) ProtoSize ¶
func (m *MessagePayloadAHeap) ProtoSize() (n int)
func (*MessagePayloadAHeap) Reset ¶
func (m *MessagePayloadAHeap) Reset()
func (*MessagePayloadAHeap) String ¶
func (m *MessagePayloadAHeap) String() string
func (*MessagePayloadAHeap) Unmarshal ¶
func (m *MessagePayloadAHeap) Unmarshal(dAtA []byte) error
func (*MessagePayloadAHeap) XXX_DiscardUnknown ¶
func (m *MessagePayloadAHeap) XXX_DiscardUnknown()
func (*MessagePayloadAHeap) XXX_Marshal ¶
func (m *MessagePayloadAHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadAHeap) XXX_Merge ¶
func (m *MessagePayloadAHeap) XXX_Merge(src proto.Message)
func (*MessagePayloadAHeap) XXX_Size ¶
func (m *MessagePayloadAHeap) XXX_Size() int
func (*MessagePayloadAHeap) XXX_Unmarshal ¶
func (m *MessagePayloadAHeap) XXX_Unmarshal(b []byte) error
type MessagePayloadALessHeap ¶
type MessagePayloadALessHeap struct {
Payloads []PayloadA `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads"`
}
func (*MessagePayloadALessHeap) Descriptor ¶
func (*MessagePayloadALessHeap) Descriptor() ([]byte, []int)
func (*MessagePayloadALessHeap) GetPayloads ¶
func (m *MessagePayloadALessHeap) GetPayloads() []PayloadA
func (*MessagePayloadALessHeap) Marshal ¶
func (m *MessagePayloadALessHeap) Marshal() (dAtA []byte, err error)
func (*MessagePayloadALessHeap) MarshalTo ¶
func (m *MessagePayloadALessHeap) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadALessHeap) MarshalToSizedBuffer ¶
func (m *MessagePayloadALessHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadALessHeap) ProtoMessage ¶
func (*MessagePayloadALessHeap) ProtoMessage()
func (*MessagePayloadALessHeap) ProtoSize ¶
func (m *MessagePayloadALessHeap) ProtoSize() (n int)
func (*MessagePayloadALessHeap) Reset ¶
func (m *MessagePayloadALessHeap) Reset()
func (*MessagePayloadALessHeap) String ¶
func (m *MessagePayloadALessHeap) String() string
func (*MessagePayloadALessHeap) Unmarshal ¶
func (m *MessagePayloadALessHeap) Unmarshal(dAtA []byte) error
func (*MessagePayloadALessHeap) XXX_DiscardUnknown ¶
func (m *MessagePayloadALessHeap) XXX_DiscardUnknown()
func (*MessagePayloadALessHeap) XXX_Marshal ¶
func (m *MessagePayloadALessHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadALessHeap) XXX_Merge ¶
func (m *MessagePayloadALessHeap) XXX_Merge(src proto.Message)
func (*MessagePayloadALessHeap) XXX_Size ¶
func (m *MessagePayloadALessHeap) XXX_Size() int
func (*MessagePayloadALessHeap) XXX_Unmarshal ¶
func (m *MessagePayloadALessHeap) XXX_Unmarshal(b []byte) error
type MessagePayloadASplit ¶
type MessagePayloadASplit struct { Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"` Datas [][]byte `protobuf:"bytes,2,rep,name=datas,proto3" json:"datas,omitempty"` }
func (*MessagePayloadASplit) Descriptor ¶
func (*MessagePayloadASplit) Descriptor() ([]byte, []int)
func (*MessagePayloadASplit) GetDatas ¶
func (m *MessagePayloadASplit) GetDatas() [][]byte
func (*MessagePayloadASplit) GetIds ¶
func (m *MessagePayloadASplit) GetIds() []int64
func (*MessagePayloadASplit) Marshal ¶
func (m *MessagePayloadASplit) Marshal() (dAtA []byte, err error)
func (*MessagePayloadASplit) MarshalTo ¶
func (m *MessagePayloadASplit) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadASplit) MarshalToSizedBuffer ¶
func (m *MessagePayloadASplit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadASplit) ProtoMessage ¶
func (*MessagePayloadASplit) ProtoMessage()
func (*MessagePayloadASplit) ProtoSize ¶
func (m *MessagePayloadASplit) ProtoSize() (n int)
func (*MessagePayloadASplit) Reset ¶
func (m *MessagePayloadASplit) Reset()
func (*MessagePayloadASplit) String ¶
func (m *MessagePayloadASplit) String() string
func (*MessagePayloadASplit) Unmarshal ¶
func (m *MessagePayloadASplit) Unmarshal(dAtA []byte) error
func (*MessagePayloadASplit) XXX_DiscardUnknown ¶
func (m *MessagePayloadASplit) XXX_DiscardUnknown()
func (*MessagePayloadASplit) XXX_Marshal ¶
func (m *MessagePayloadASplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadASplit) XXX_Merge ¶
func (m *MessagePayloadASplit) XXX_Merge(src proto.Message)
func (*MessagePayloadASplit) XXX_Size ¶
func (m *MessagePayloadASplit) XXX_Size() int
func (*MessagePayloadASplit) XXX_Unmarshal ¶
func (m *MessagePayloadASplit) XXX_Unmarshal(b []byte) error
type MessagePayloadBHeap ¶
type MessagePayloadBHeap struct {
Payloads []*PayloadB `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
}
func (*MessagePayloadBHeap) Descriptor ¶
func (*MessagePayloadBHeap) Descriptor() ([]byte, []int)
func (*MessagePayloadBHeap) GetPayloads ¶
func (m *MessagePayloadBHeap) GetPayloads() []*PayloadB
func (*MessagePayloadBHeap) Marshal ¶
func (m *MessagePayloadBHeap) Marshal() (dAtA []byte, err error)
func (*MessagePayloadBHeap) MarshalTo ¶
func (m *MessagePayloadBHeap) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadBHeap) MarshalToSizedBuffer ¶
func (m *MessagePayloadBHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadBHeap) ProtoMessage ¶
func (*MessagePayloadBHeap) ProtoMessage()
func (*MessagePayloadBHeap) ProtoSize ¶
func (m *MessagePayloadBHeap) ProtoSize() (n int)
func (*MessagePayloadBHeap) Reset ¶
func (m *MessagePayloadBHeap) Reset()
func (*MessagePayloadBHeap) String ¶
func (m *MessagePayloadBHeap) String() string
func (*MessagePayloadBHeap) Unmarshal ¶
func (m *MessagePayloadBHeap) Unmarshal(dAtA []byte) error
func (*MessagePayloadBHeap) XXX_DiscardUnknown ¶
func (m *MessagePayloadBHeap) XXX_DiscardUnknown()
func (*MessagePayloadBHeap) XXX_Marshal ¶
func (m *MessagePayloadBHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadBHeap) XXX_Merge ¶
func (m *MessagePayloadBHeap) XXX_Merge(src proto.Message)
func (*MessagePayloadBHeap) XXX_Size ¶
func (m *MessagePayloadBHeap) XXX_Size() int
func (*MessagePayloadBHeap) XXX_Unmarshal ¶
func (m *MessagePayloadBHeap) XXX_Unmarshal(b []byte) error
type MessagePayloadBLessHeap ¶
type MessagePayloadBLessHeap struct {
Payloads []PayloadB `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads"`
}
func (*MessagePayloadBLessHeap) Descriptor ¶
func (*MessagePayloadBLessHeap) Descriptor() ([]byte, []int)
func (*MessagePayloadBLessHeap) GetPayloads ¶
func (m *MessagePayloadBLessHeap) GetPayloads() []PayloadB
func (*MessagePayloadBLessHeap) Marshal ¶
func (m *MessagePayloadBLessHeap) Marshal() (dAtA []byte, err error)
func (*MessagePayloadBLessHeap) MarshalTo ¶
func (m *MessagePayloadBLessHeap) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadBLessHeap) MarshalToSizedBuffer ¶
func (m *MessagePayloadBLessHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadBLessHeap) ProtoMessage ¶
func (*MessagePayloadBLessHeap) ProtoMessage()
func (*MessagePayloadBLessHeap) ProtoSize ¶
func (m *MessagePayloadBLessHeap) ProtoSize() (n int)
func (*MessagePayloadBLessHeap) Reset ¶
func (m *MessagePayloadBLessHeap) Reset()
func (*MessagePayloadBLessHeap) String ¶
func (m *MessagePayloadBLessHeap) String() string
func (*MessagePayloadBLessHeap) Unmarshal ¶
func (m *MessagePayloadBLessHeap) Unmarshal(dAtA []byte) error
func (*MessagePayloadBLessHeap) XXX_DiscardUnknown ¶
func (m *MessagePayloadBLessHeap) XXX_DiscardUnknown()
func (*MessagePayloadBLessHeap) XXX_Marshal ¶
func (m *MessagePayloadBLessHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadBLessHeap) XXX_Merge ¶
func (m *MessagePayloadBLessHeap) XXX_Merge(src proto.Message)
func (*MessagePayloadBLessHeap) XXX_Size ¶
func (m *MessagePayloadBLessHeap) XXX_Size() int
func (*MessagePayloadBLessHeap) XXX_Unmarshal ¶
func (m *MessagePayloadBLessHeap) XXX_Unmarshal(b []byte) error
type MessagePayloadBSplit ¶
type MessagePayloadBSplit struct { Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"` Datas []Buffer `protobuf:"bytes,2,rep,name=datas,proto3" json:"datas"` }
func (*MessagePayloadBSplit) Descriptor ¶
func (*MessagePayloadBSplit) Descriptor() ([]byte, []int)
func (*MessagePayloadBSplit) GetDatas ¶
func (m *MessagePayloadBSplit) GetDatas() []Buffer
func (*MessagePayloadBSplit) GetIds ¶
func (m *MessagePayloadBSplit) GetIds() []int64
func (*MessagePayloadBSplit) Marshal ¶
func (m *MessagePayloadBSplit) Marshal() (dAtA []byte, err error)
func (*MessagePayloadBSplit) MarshalTo ¶
func (m *MessagePayloadBSplit) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadBSplit) MarshalToSizedBuffer ¶
func (m *MessagePayloadBSplit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadBSplit) ProtoMessage ¶
func (*MessagePayloadBSplit) ProtoMessage()
func (*MessagePayloadBSplit) ProtoSize ¶
func (m *MessagePayloadBSplit) ProtoSize() (n int)
func (*MessagePayloadBSplit) Reset ¶
func (m *MessagePayloadBSplit) Reset()
func (*MessagePayloadBSplit) String ¶
func (m *MessagePayloadBSplit) String() string
func (*MessagePayloadBSplit) Unmarshal ¶
func (m *MessagePayloadBSplit) Unmarshal(dAtA []byte) error
func (*MessagePayloadBSplit) XXX_DiscardUnknown ¶
func (m *MessagePayloadBSplit) XXX_DiscardUnknown()
func (*MessagePayloadBSplit) XXX_Marshal ¶
func (m *MessagePayloadBSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadBSplit) XXX_Merge ¶
func (m *MessagePayloadBSplit) XXX_Merge(src proto.Message)
func (*MessagePayloadBSplit) XXX_Size ¶
func (m *MessagePayloadBSplit) XXX_Size() int
func (*MessagePayloadBSplit) XXX_Unmarshal ¶
func (m *MessagePayloadBSplit) XXX_Unmarshal(b []byte) error
type MessagePayloadCHeap ¶
type MessagePayloadCHeap struct {
Payloads []*PayloadC `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
}
func (*MessagePayloadCHeap) Descriptor ¶
func (*MessagePayloadCHeap) Descriptor() ([]byte, []int)
func (*MessagePayloadCHeap) GetPayloads ¶
func (m *MessagePayloadCHeap) GetPayloads() []*PayloadC
func (*MessagePayloadCHeap) Marshal ¶
func (m *MessagePayloadCHeap) Marshal() (dAtA []byte, err error)
func (*MessagePayloadCHeap) MarshalTo ¶
func (m *MessagePayloadCHeap) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadCHeap) MarshalToSizedBuffer ¶
func (m *MessagePayloadCHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadCHeap) ProtoMessage ¶
func (*MessagePayloadCHeap) ProtoMessage()
func (*MessagePayloadCHeap) ProtoSize ¶
func (m *MessagePayloadCHeap) ProtoSize() (n int)
func (*MessagePayloadCHeap) Reset ¶
func (m *MessagePayloadCHeap) Reset()
func (*MessagePayloadCHeap) String ¶
func (m *MessagePayloadCHeap) String() string
func (*MessagePayloadCHeap) Unmarshal ¶
func (m *MessagePayloadCHeap) Unmarshal(dAtA []byte) error
func (*MessagePayloadCHeap) XXX_DiscardUnknown ¶
func (m *MessagePayloadCHeap) XXX_DiscardUnknown()
func (*MessagePayloadCHeap) XXX_Marshal ¶
func (m *MessagePayloadCHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadCHeap) XXX_Merge ¶
func (m *MessagePayloadCHeap) XXX_Merge(src proto.Message)
func (*MessagePayloadCHeap) XXX_Size ¶
func (m *MessagePayloadCHeap) XXX_Size() int
func (*MessagePayloadCHeap) XXX_Unmarshal ¶
func (m *MessagePayloadCHeap) XXX_Unmarshal(b []byte) error
type MessagePayloadCLessHeap ¶
type MessagePayloadCLessHeap struct {
Payloads []PayloadC `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads"`
}
func (*MessagePayloadCLessHeap) Descriptor ¶
func (*MessagePayloadCLessHeap) Descriptor() ([]byte, []int)
func (*MessagePayloadCLessHeap) GetPayloads ¶
func (m *MessagePayloadCLessHeap) GetPayloads() []PayloadC
func (*MessagePayloadCLessHeap) Marshal ¶
func (m *MessagePayloadCLessHeap) Marshal() (dAtA []byte, err error)
func (*MessagePayloadCLessHeap) MarshalTo ¶
func (m *MessagePayloadCLessHeap) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadCLessHeap) MarshalToSizedBuffer ¶
func (m *MessagePayloadCLessHeap) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadCLessHeap) ProtoMessage ¶
func (*MessagePayloadCLessHeap) ProtoMessage()
func (*MessagePayloadCLessHeap) ProtoSize ¶
func (m *MessagePayloadCLessHeap) ProtoSize() (n int)
func (*MessagePayloadCLessHeap) Reset ¶
func (m *MessagePayloadCLessHeap) Reset()
func (*MessagePayloadCLessHeap) String ¶
func (m *MessagePayloadCLessHeap) String() string
func (*MessagePayloadCLessHeap) Unmarshal ¶
func (m *MessagePayloadCLessHeap) Unmarshal(dAtA []byte) error
func (*MessagePayloadCLessHeap) XXX_DiscardUnknown ¶
func (m *MessagePayloadCLessHeap) XXX_DiscardUnknown()
func (*MessagePayloadCLessHeap) XXX_Marshal ¶
func (m *MessagePayloadCLessHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadCLessHeap) XXX_Merge ¶
func (m *MessagePayloadCLessHeap) XXX_Merge(src proto.Message)
func (*MessagePayloadCLessHeap) XXX_Size ¶
func (m *MessagePayloadCLessHeap) XXX_Size() int
func (*MessagePayloadCLessHeap) XXX_Unmarshal ¶
func (m *MessagePayloadCLessHeap) XXX_Unmarshal(b []byte) error
type MessagePayloadCSplit ¶
type MessagePayloadCSplit struct { Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"` Datas []*Buffer `protobuf:"bytes,2,rep,name=datas,proto3" json:"datas,omitempty"` }
func (*MessagePayloadCSplit) Descriptor ¶
func (*MessagePayloadCSplit) Descriptor() ([]byte, []int)
func (*MessagePayloadCSplit) GetDatas ¶
func (m *MessagePayloadCSplit) GetDatas() []*Buffer
func (*MessagePayloadCSplit) GetIds ¶
func (m *MessagePayloadCSplit) GetIds() []int64
func (*MessagePayloadCSplit) Marshal ¶
func (m *MessagePayloadCSplit) Marshal() (dAtA []byte, err error)
func (*MessagePayloadCSplit) MarshalTo ¶
func (m *MessagePayloadCSplit) MarshalTo(dAtA []byte) (int, error)
func (*MessagePayloadCSplit) MarshalToSizedBuffer ¶
func (m *MessagePayloadCSplit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessagePayloadCSplit) ProtoMessage ¶
func (*MessagePayloadCSplit) ProtoMessage()
func (*MessagePayloadCSplit) ProtoSize ¶
func (m *MessagePayloadCSplit) ProtoSize() (n int)
func (*MessagePayloadCSplit) Reset ¶
func (m *MessagePayloadCSplit) Reset()
func (*MessagePayloadCSplit) String ¶
func (m *MessagePayloadCSplit) String() string
func (*MessagePayloadCSplit) Unmarshal ¶
func (m *MessagePayloadCSplit) Unmarshal(dAtA []byte) error
func (*MessagePayloadCSplit) XXX_DiscardUnknown ¶
func (m *MessagePayloadCSplit) XXX_DiscardUnknown()
func (*MessagePayloadCSplit) XXX_Marshal ¶
func (m *MessagePayloadCSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessagePayloadCSplit) XXX_Merge ¶
func (m *MessagePayloadCSplit) XXX_Merge(src proto.Message)
func (*MessagePayloadCSplit) XXX_Size ¶
func (m *MessagePayloadCSplit) XXX_Size() int
func (*MessagePayloadCSplit) XXX_Unmarshal ¶
func (m *MessagePayloadCSplit) XXX_Unmarshal(b []byte) error
type PayloadA ¶
type PayloadA struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
func (*PayloadA) Descriptor ¶
func (*PayloadA) MarshalToSizedBuffer ¶
func (*PayloadA) ProtoMessage ¶
func (*PayloadA) ProtoMessage()
func (*PayloadA) XXX_DiscardUnknown ¶
func (m *PayloadA) XXX_DiscardUnknown()
func (*PayloadA) XXX_Marshal ¶
func (*PayloadA) XXX_Unmarshal ¶
type PayloadB ¶
type PayloadB struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Data Buffer `protobuf:"bytes,2,opt,name=data,proto3" json:"data"` }
func (*PayloadB) Descriptor ¶
func (*PayloadB) MarshalToSizedBuffer ¶
func (*PayloadB) ProtoMessage ¶
func (*PayloadB) ProtoMessage()
func (*PayloadB) XXX_DiscardUnknown ¶
func (m *PayloadB) XXX_DiscardUnknown()
func (*PayloadB) XXX_Marshal ¶
func (*PayloadB) XXX_Unmarshal ¶
type PayloadC ¶
type PayloadC struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Data *Buffer `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
func (*PayloadC) Descriptor ¶
func (*PayloadC) MarshalToSizedBuffer ¶
func (*PayloadC) ProtoMessage ¶
func (*PayloadC) ProtoMessage()
func (*PayloadC) XXX_DiscardUnknown ¶
func (m *PayloadC) XXX_DiscardUnknown()
func (*PayloadC) XXX_Marshal ¶
func (*PayloadC) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.