Documentation ¶
Index ¶
- Variables
- type KVPair
- func (*KVPair) Descriptor() ([]byte, []int)
- func (m *KVPair) Marshal() (dAtA []byte, err error)
- func (m *KVPair) MarshalTo(dAtA []byte) (int, error)
- func (m *KVPair) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KVPair) ProtoMessage()
- func (m *KVPair) Reset()
- func (m *KVPair) Size() (n int)
- func (m *KVPair) String() string
- func (m *KVPair) Unmarshal(dAtA []byte) error
- func (m *KVPair) XXX_DiscardUnknown()
- func (m *KVPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KVPair) XXX_Merge(src proto.Message)
- func (m *KVPair) XXX_Size() int
- func (m *KVPair) XXX_Unmarshal(b []byte) error
- type SnapshotChunk
- func (*SnapshotChunk) Descriptor() ([]byte, []int)
- func (m *SnapshotChunk) Marshal() (dAtA []byte, err error)
- func (m *SnapshotChunk) MarshalTo(dAtA []byte) (int, error)
- func (m *SnapshotChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SnapshotChunk) ProtoMessage()
- func (m *SnapshotChunk) Reset()
- func (m *SnapshotChunk) Size() (n int)
- func (m *SnapshotChunk) String() string
- func (m *SnapshotChunk) Unmarshal(dAtA []byte) error
- func (m *SnapshotChunk) XXX_DiscardUnknown()
- func (m *SnapshotChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SnapshotChunk) XXX_Merge(src proto.Message)
- func (m *SnapshotChunk) XXX_Size() int
- func (m *SnapshotChunk) XXX_Unmarshal(b []byte) error
- type SnapshotHeader
- func (*SnapshotHeader) Descriptor() ([]byte, []int)
- func (m *SnapshotHeader) Marshal() (dAtA []byte, err error)
- func (m *SnapshotHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *SnapshotHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SnapshotHeader) ProtoMessage()
- func (m *SnapshotHeader) Reset()
- func (m *SnapshotHeader) Size() (n int)
- func (m *SnapshotHeader) String() string
- func (m *SnapshotHeader) Unmarshal(dAtA []byte) error
- func (m *SnapshotHeader) XXX_DiscardUnknown()
- func (m *SnapshotHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SnapshotHeader) XXX_Merge(src proto.Message)
- func (m *SnapshotHeader) XXX_Size() int
- func (m *SnapshotHeader) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type KVPair ¶
type KVPair struct { Key []byte `protobuf:"bytes,1,opt,name=key" json:"key"` Value []byte `protobuf:"bytes,3,opt,name=value" json:"value"` }
func (*KVPair) Descriptor ¶
func (*KVPair) MarshalToSizedBuffer ¶
func (*KVPair) ProtoMessage ¶
func (*KVPair) ProtoMessage()
func (*KVPair) XXX_DiscardUnknown ¶
func (m *KVPair) XXX_DiscardUnknown()
func (*KVPair) XXX_Marshal ¶
func (*KVPair) XXX_Unmarshal ¶
type SnapshotChunk ¶
type SnapshotChunk struct { // Payload for this chunk Content []byte `protobuf:"bytes,1,opt,name=content" json:"content"` // Checksum of stream up to this point. At the end of the stream // the checksums should match Checksum []byte `protobuf:"bytes,2,opt,name=checksum" json:"checksum"` }
This is an envelope for sending raw bytes io.Reader -> Chunk Stream Chunk Stream -> io.Reader
func (*SnapshotChunk) Descriptor ¶
func (*SnapshotChunk) Descriptor() ([]byte, []int)
func (*SnapshotChunk) Marshal ¶
func (m *SnapshotChunk) Marshal() (dAtA []byte, err error)
func (*SnapshotChunk) MarshalToSizedBuffer ¶
func (m *SnapshotChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SnapshotChunk) ProtoMessage ¶
func (*SnapshotChunk) ProtoMessage()
func (*SnapshotChunk) Reset ¶
func (m *SnapshotChunk) Reset()
func (*SnapshotChunk) Size ¶
func (m *SnapshotChunk) Size() (n int)
func (*SnapshotChunk) String ¶
func (m *SnapshotChunk) String() string
func (*SnapshotChunk) Unmarshal ¶
func (m *SnapshotChunk) Unmarshal(dAtA []byte) error
func (*SnapshotChunk) XXX_DiscardUnknown ¶
func (m *SnapshotChunk) XXX_DiscardUnknown()
func (*SnapshotChunk) XXX_Marshal ¶
func (m *SnapshotChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SnapshotChunk) XXX_Merge ¶
func (m *SnapshotChunk) XXX_Merge(src proto.Message)
func (*SnapshotChunk) XXX_Size ¶
func (m *SnapshotChunk) XXX_Size() int
func (*SnapshotChunk) XXX_Unmarshal ¶
func (m *SnapshotChunk) XXX_Unmarshal(b []byte) error
type SnapshotHeader ¶
type SnapshotHeader struct { // Useful for checking format // and version compatibility Metadata map[string][]byte `` /* 136-byte string literal not displayed */ }
func (*SnapshotHeader) Descriptor ¶
func (*SnapshotHeader) Descriptor() ([]byte, []int)
func (*SnapshotHeader) Marshal ¶
func (m *SnapshotHeader) Marshal() (dAtA []byte, err error)
func (*SnapshotHeader) MarshalToSizedBuffer ¶
func (m *SnapshotHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SnapshotHeader) ProtoMessage ¶
func (*SnapshotHeader) ProtoMessage()
func (*SnapshotHeader) Reset ¶
func (m *SnapshotHeader) Reset()
func (*SnapshotHeader) Size ¶
func (m *SnapshotHeader) Size() (n int)
func (*SnapshotHeader) String ¶
func (m *SnapshotHeader) String() string
func (*SnapshotHeader) Unmarshal ¶
func (m *SnapshotHeader) Unmarshal(dAtA []byte) error
func (*SnapshotHeader) XXX_DiscardUnknown ¶
func (m *SnapshotHeader) XXX_DiscardUnknown()
func (*SnapshotHeader) XXX_Marshal ¶
func (m *SnapshotHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SnapshotHeader) XXX_Merge ¶
func (m *SnapshotHeader) XXX_Merge(src proto.Message)
func (*SnapshotHeader) XXX_Size ¶
func (m *SnapshotHeader) XXX_Size() int
func (*SnapshotHeader) XXX_Unmarshal ¶
func (m *SnapshotHeader) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.