pb

package
v1.6.2 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2020 License: Apache-2.0 Imports: 5 Imported by: 17

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ManifestChange_Operation_name = map[int32]string{
	0: "CREATE",
	1: "DELETE",
}
View Source 
var ManifestChange_Operation_value = map[string]int32{
	"CREATE": 0,
	"DELETE": 1,
}

Functions

This section is empty.

Types

type KV 

type KV struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	UserMeta  []byte `protobuf:"bytes,3,opt,name=user_meta,json=userMeta,proto3" json:"user_meta,omitempty"`
	Version   uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	ExpiresAt uint64 `protobuf:"varint,5,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	Meta      []byte `protobuf:"bytes,6,opt,name=meta,proto3" json:"meta,omitempty"`
	// Stream id is used to identify which stream the KV came from.
	StreamId uint32 `protobuf:"varint,10,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Stream done is used to indicate end of stream.
	StreamDone           bool     `protobuf:"varint,11,opt,name=stream_done,json=streamDone,proto3" json:"stream_done,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KV) Descriptor 

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

func (*KV) GetExpiresAt 

func (m *KV) GetExpiresAt() uint64

func (*KV) GetKey 

func (m *KV) GetKey() []byte

func (*KV) GetMeta 

func (m *KV) GetMeta() []byte

func (*KV) GetStreamDone added in v1.6.1 

func (m *KV) GetStreamDone() bool

func (*KV) GetStreamId 

func (m *KV) GetStreamId() uint32

func (*KV) GetUserMeta 

func (m *KV) GetUserMeta() []byte

func (*KV) GetValue 

func (m *KV) GetValue() []byte

func (*KV) GetVersion 

func (m *KV) GetVersion() uint64

func (*KV) Marshal 

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

func (*KV) MarshalTo 

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

func (*KV) MarshalToSizedBuffer added in v1.6.1 

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

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) Size 

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

func (*KV) String 

func (m *KV) String() string

func (*KV) Unmarshal 

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

func (*KV) XXX_DiscardUnknown 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal 

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

func (*KV) XXX_Merge 

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

func (*KV) XXX_Size 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal 

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

type KVList 

type KVList struct {
	Kv                   []*KV    `protobuf:"bytes,1,rep,name=kv,proto3" json:"kv,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KVList) Descriptor 

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

func (*KVList) GetKv 

func (m *KVList) GetKv() []*KV

func (*KVList) Marshal 

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

func (*KVList) MarshalTo 

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

func (*KVList) MarshalToSizedBuffer added in v1.6.1 

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

func (*KVList) ProtoMessage 

func (*KVList) ProtoMessage()

func (*KVList) Reset 

func (m *KVList) Reset()

func (*KVList) Size 

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

func (*KVList) String 

func (m *KVList) String() string

func (*KVList) Unmarshal 

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

func (*KVList) XXX_DiscardUnknown 

func (m *KVList) XXX_DiscardUnknown()

func (*KVList) XXX_Marshal 

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

func (*KVList) XXX_Merge 

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

func (*KVList) XXX_Size 

func (m *KVList) XXX_Size() int

func (*KVList) XXX_Unmarshal 

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

type ManifestChange 

type ManifestChange struct {
	Id                   uint64                   `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Op                   ManifestChange_Operation `protobuf:"varint,2,opt,name=Op,proto3,enum=pb.ManifestChange_Operation" json:"Op,omitempty"`
	Level                uint32                   `protobuf:"varint,3,opt,name=Level,proto3" json:"Level,omitempty"`
	Checksum             []byte                   `protobuf:"bytes,4,opt,name=Checksum,proto3" json:"Checksum,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ManifestChange) Descriptor 

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

func (*ManifestChange) GetChecksum 

func (m *ManifestChange) GetChecksum() []byte

func (*ManifestChange) GetId 

func (m *ManifestChange) GetId() uint64

func (*ManifestChange) GetLevel 

func (m *ManifestChange) GetLevel() uint32

func (*ManifestChange) GetOp 

func (m *ManifestChange) GetOp() ManifestChange_Operation

func (*ManifestChange) Marshal 

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

func (*ManifestChange) MarshalTo 

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

func (*ManifestChange) MarshalToSizedBuffer added in v1.6.1 

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

func (*ManifestChange) ProtoMessage 

func (*ManifestChange) ProtoMessage()

func (*ManifestChange) Reset 

func (m *ManifestChange) Reset()

func (*ManifestChange) Size 

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

func (*ManifestChange) String 

func (m *ManifestChange) String() string

func (*ManifestChange) Unmarshal 

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

func (*ManifestChange) XXX_DiscardUnknown 

func (m *ManifestChange) XXX_DiscardUnknown()

func (*ManifestChange) XXX_Marshal 

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

func (*ManifestChange) XXX_Merge 

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

func (*ManifestChange) XXX_Size 

func (m *ManifestChange) XXX_Size() int

func (*ManifestChange) XXX_Unmarshal 

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

type ManifestChangeSet 

type ManifestChangeSet struct {
	// A set of changes that are applied atomically.
	Changes              []*ManifestChange `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ManifestChangeSet) Descriptor 

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

func (*ManifestChangeSet) GetChanges 

func (m *ManifestChangeSet) GetChanges() []*ManifestChange

func (*ManifestChangeSet) Marshal 

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

func (*ManifestChangeSet) MarshalTo 

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

func (*ManifestChangeSet) MarshalToSizedBuffer added in v1.6.1 

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

func (*ManifestChangeSet) ProtoMessage 

func (*ManifestChangeSet) ProtoMessage()

func (*ManifestChangeSet) Reset 

func (m *ManifestChangeSet) Reset()

func (*ManifestChangeSet) Size 

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

func (*ManifestChangeSet) String 

func (m *ManifestChangeSet) String() string

func (*ManifestChangeSet) Unmarshal 

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

func (*ManifestChangeSet) XXX_DiscardUnknown 

func (m *ManifestChangeSet) XXX_DiscardUnknown()

func (*ManifestChangeSet) XXX_Marshal 

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

func (*ManifestChangeSet) XXX_Merge 

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

func (*ManifestChangeSet) XXX_Size 

func (m *ManifestChangeSet) XXX_Size() int

func (*ManifestChangeSet) XXX_Unmarshal 

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

type ManifestChange_Operation 

type ManifestChange_Operation int32
const (
	ManifestChange_CREATE ManifestChange_Operation = 0
	ManifestChange_DELETE ManifestChange_Operation = 1
)

func (ManifestChange_Operation) EnumDescriptor 

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

func (ManifestChange_Operation) String 

func (x ManifestChange_Operation) String() string

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.