Documentation ¶
Index ¶
- Constants
- type FailedRecord
- func (*FailedRecord) Descriptor() ([]byte, []int)
- func (m *FailedRecord) GetErrorCode() string
- func (m *FailedRecord) GetErrorMessage() string
- func (m *FailedRecord) GetIndex() int32
- func (*FailedRecord) ProtoMessage()
- func (m *FailedRecord) Reset()
- func (m *FailedRecord) String() string
- func (m *FailedRecord) XXX_DiscardUnknown()
- func (m *FailedRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FailedRecord) XXX_Merge(src proto.Message)
- func (m *FailedRecord) XXX_Size() int
- func (m *FailedRecord) XXX_Unmarshal(b []byte) error
- type FieldData
- func (*FieldData) Descriptor() ([]byte, []int)
- func (m *FieldData) GetValue() []byte
- func (*FieldData) ProtoMessage()
- func (m *FieldData) Reset()
- func (m *FieldData) String() string
- func (m *FieldData) XXX_DiscardUnknown()
- func (m *FieldData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FieldData) XXX_Merge(src proto.Message)
- func (m *FieldData) XXX_Size() int
- func (m *FieldData) XXX_Unmarshal(b []byte) error
- type GetRecordsRequest
- func (*GetRecordsRequest) Descriptor() ([]byte, []int)
- func (m *GetRecordsRequest) GetCursor() string
- func (m *GetRecordsRequest) GetLimit() int32
- func (*GetRecordsRequest) ProtoMessage()
- func (m *GetRecordsRequest) Reset()
- func (m *GetRecordsRequest) String() string
- func (m *GetRecordsRequest) XXX_DiscardUnknown()
- func (m *GetRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRecordsRequest) XXX_Merge(src proto.Message)
- func (m *GetRecordsRequest) XXX_Size() int
- func (m *GetRecordsRequest) XXX_Unmarshal(b []byte) error
- type GetRecordsResponse
- func (*GetRecordsResponse) Descriptor() ([]byte, []int)
- func (m *GetRecordsResponse) GetNextCursor() string
- func (m *GetRecordsResponse) GetRecordCount() int32
- func (m *GetRecordsResponse) GetRecords() []*RecordEntry
- func (m *GetRecordsResponse) GetStartSequence() int64
- func (*GetRecordsResponse) ProtoMessage()
- func (m *GetRecordsResponse) Reset()
- func (m *GetRecordsResponse) String() string
- func (m *GetRecordsResponse) XXX_DiscardUnknown()
- func (m *GetRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRecordsResponse) XXX_Merge(src proto.Message)
- func (m *GetRecordsResponse) XXX_Size() int
- func (m *GetRecordsResponse) XXX_Unmarshal(b []byte) error
- type PutRecordsRequest
- func (*PutRecordsRequest) Descriptor() ([]byte, []int)
- func (m *PutRecordsRequest) GetRecords() []*RecordEntry
- func (*PutRecordsRequest) ProtoMessage()
- func (m *PutRecordsRequest) Reset()
- func (m *PutRecordsRequest) String() string
- func (m *PutRecordsRequest) XXX_DiscardUnknown()
- func (m *PutRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutRecordsRequest) XXX_Merge(src proto.Message)
- func (m *PutRecordsRequest) XXX_Size() int
- func (m *PutRecordsRequest) XXX_Unmarshal(b []byte) error
- type PutRecordsResponse
- func (*PutRecordsResponse) Descriptor() ([]byte, []int)
- func (m *PutRecordsResponse) GetFailedCount() int32
- func (m *PutRecordsResponse) GetFailedRecords() []*FailedRecord
- func (*PutRecordsResponse) ProtoMessage()
- func (m *PutRecordsResponse) Reset()
- func (m *PutRecordsResponse) String() string
- func (m *PutRecordsResponse) XXX_DiscardUnknown()
- func (m *PutRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutRecordsResponse) XXX_Merge(src proto.Message)
- func (m *PutRecordsResponse) XXX_Size() int
- func (m *PutRecordsResponse) XXX_Unmarshal(b []byte) error
- type RecordAttributes
- func (*RecordAttributes) Descriptor() ([]byte, []int)
- func (m *RecordAttributes) GetAttributes() []*StringPair
- func (*RecordAttributes) ProtoMessage()
- func (m *RecordAttributes) Reset()
- func (m *RecordAttributes) String() string
- func (m *RecordAttributes) XXX_DiscardUnknown()
- func (m *RecordAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordAttributes) XXX_Merge(src proto.Message)
- func (m *RecordAttributes) XXX_Size() int
- func (m *RecordAttributes) XXX_Unmarshal(b []byte) error
- type RecordData
- func (*RecordData) Descriptor() ([]byte, []int)
- func (m *RecordData) GetData() []*FieldData
- func (*RecordData) ProtoMessage()
- func (m *RecordData) Reset()
- func (m *RecordData) String() string
- func (m *RecordData) XXX_DiscardUnknown()
- func (m *RecordData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordData) XXX_Merge(src proto.Message)
- func (m *RecordData) XXX_Size() int
- func (m *RecordData) XXX_Unmarshal(b []byte) error
- type RecordEntry
- func (*RecordEntry) Descriptor() ([]byte, []int)
- func (m *RecordEntry) GetAttributes() *RecordAttributes
- func (m *RecordEntry) GetCursor() string
- func (m *RecordEntry) GetData() *RecordData
- func (m *RecordEntry) GetHashKey() string
- func (m *RecordEntry) GetNextCursor() string
- func (m *RecordEntry) GetPartitionKey() string
- func (m *RecordEntry) GetSequence() int64
- func (m *RecordEntry) GetShardId() string
- func (m *RecordEntry) GetSystemTime() int64
- func (*RecordEntry) ProtoMessage()
- func (m *RecordEntry) Reset()
- func (m *RecordEntry) String() string
- func (m *RecordEntry) XXX_DiscardUnknown()
- func (m *RecordEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordEntry) XXX_Merge(src proto.Message)
- func (m *RecordEntry) XXX_Size() int
- func (m *RecordEntry) XXX_Unmarshal(b []byte) error
- type StringPair
- func (*StringPair) Descriptor() ([]byte, []int)
- func (m *StringPair) GetKey() string
- func (m *StringPair) GetValue() string
- func (*StringPair) ProtoMessage()
- func (m *StringPair) Reset()
- func (m *StringPair) String() string
- func (m *StringPair) XXX_DiscardUnknown()
- func (m *StringPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StringPair) XXX_Merge(src proto.Message)
- func (m *StringPair) XXX_Size() int
- func (m *StringPair) XXX_Unmarshal(b []byte) error
Constants ¶
View Source
const Default_GetRecordsRequest_Limit int32 = 1
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FailedRecord ¶
type FailedRecord struct { Index *int32 `protobuf:"varint,1,req,name=index" json:"index,omitempty"` ErrorCode *string `protobuf:"bytes,2,opt,name=error_code,json=errorCode" json:"error_code,omitempty"` ErrorMessage *string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage" json:"error_message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FailedRecord) Descriptor ¶
func (*FailedRecord) Descriptor() ([]byte, []int)
func (*FailedRecord) GetErrorCode ¶
func (m *FailedRecord) GetErrorCode() string
func (*FailedRecord) GetErrorMessage ¶
func (m *FailedRecord) GetErrorMessage() string
func (*FailedRecord) GetIndex ¶
func (m *FailedRecord) GetIndex() int32
func (*FailedRecord) ProtoMessage ¶
func (*FailedRecord) ProtoMessage()
func (*FailedRecord) Reset ¶
func (m *FailedRecord) Reset()
func (*FailedRecord) String ¶
func (m *FailedRecord) String() string
func (*FailedRecord) XXX_DiscardUnknown ¶
func (m *FailedRecord) XXX_DiscardUnknown()
func (*FailedRecord) XXX_Marshal ¶
func (m *FailedRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FailedRecord) XXX_Merge ¶
func (m *FailedRecord) XXX_Merge(src proto.Message)
func (*FailedRecord) XXX_Size ¶
func (m *FailedRecord) XXX_Size() int
func (*FailedRecord) XXX_Unmarshal ¶
func (m *FailedRecord) XXX_Unmarshal(b []byte) error
type FieldData ¶
type FieldData struct { Value []byte `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FieldData) Descriptor ¶
func (*FieldData) ProtoMessage ¶
func (*FieldData) ProtoMessage()
func (*FieldData) XXX_DiscardUnknown ¶
func (m *FieldData) XXX_DiscardUnknown()
func (*FieldData) XXX_Marshal ¶
func (*FieldData) XXX_Unmarshal ¶
type GetRecordsRequest ¶
type GetRecordsRequest struct { Cursor *string `protobuf:"bytes,1,req,name=cursor" json:"cursor,omitempty"` Limit *int32 `protobuf:"varint,2,opt,name=limit,def=1" json:"limit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRecordsRequest) Descriptor ¶
func (*GetRecordsRequest) Descriptor() ([]byte, []int)
func (*GetRecordsRequest) GetCursor ¶
func (m *GetRecordsRequest) GetCursor() string
func (*GetRecordsRequest) GetLimit ¶
func (m *GetRecordsRequest) GetLimit() int32
func (*GetRecordsRequest) ProtoMessage ¶
func (*GetRecordsRequest) ProtoMessage()
func (*GetRecordsRequest) Reset ¶
func (m *GetRecordsRequest) Reset()
func (*GetRecordsRequest) String ¶
func (m *GetRecordsRequest) String() string
func (*GetRecordsRequest) XXX_DiscardUnknown ¶
func (m *GetRecordsRequest) XXX_DiscardUnknown()
func (*GetRecordsRequest) XXX_Marshal ¶
func (m *GetRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRecordsRequest) XXX_Merge ¶
func (m *GetRecordsRequest) XXX_Merge(src proto.Message)
func (*GetRecordsRequest) XXX_Size ¶
func (m *GetRecordsRequest) XXX_Size() int
func (*GetRecordsRequest) XXX_Unmarshal ¶
func (m *GetRecordsRequest) XXX_Unmarshal(b []byte) error
type GetRecordsResponse ¶
type GetRecordsResponse struct { NextCursor *string `protobuf:"bytes,1,req,name=next_cursor,json=nextCursor" json:"next_cursor,omitempty"` RecordCount *int32 `protobuf:"varint,2,req,name=record_count,json=recordCount" json:"record_count,omitempty"` StartSequence *int64 `protobuf:"varint,3,opt,name=start_sequence,json=startSequence" json:"start_sequence,omitempty"` Records []*RecordEntry `protobuf:"bytes,4,rep,name=records" json:"records,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRecordsResponse) Descriptor ¶
func (*GetRecordsResponse) Descriptor() ([]byte, []int)
func (*GetRecordsResponse) GetNextCursor ¶
func (m *GetRecordsResponse) GetNextCursor() string
func (*GetRecordsResponse) GetRecordCount ¶
func (m *GetRecordsResponse) GetRecordCount() int32
func (*GetRecordsResponse) GetRecords ¶
func (m *GetRecordsResponse) GetRecords() []*RecordEntry
func (*GetRecordsResponse) GetStartSequence ¶
func (m *GetRecordsResponse) GetStartSequence() int64
func (*GetRecordsResponse) ProtoMessage ¶
func (*GetRecordsResponse) ProtoMessage()
func (*GetRecordsResponse) Reset ¶
func (m *GetRecordsResponse) Reset()
func (*GetRecordsResponse) String ¶
func (m *GetRecordsResponse) String() string
func (*GetRecordsResponse) XXX_DiscardUnknown ¶
func (m *GetRecordsResponse) XXX_DiscardUnknown()
func (*GetRecordsResponse) XXX_Marshal ¶
func (m *GetRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRecordsResponse) XXX_Merge ¶
func (m *GetRecordsResponse) XXX_Merge(src proto.Message)
func (*GetRecordsResponse) XXX_Size ¶
func (m *GetRecordsResponse) XXX_Size() int
func (*GetRecordsResponse) XXX_Unmarshal ¶
func (m *GetRecordsResponse) XXX_Unmarshal(b []byte) error
type PutRecordsRequest ¶
type PutRecordsRequest struct { Records []*RecordEntry `protobuf:"bytes,1,rep,name=records" json:"records,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutRecordsRequest) Descriptor ¶
func (*PutRecordsRequest) Descriptor() ([]byte, []int)
func (*PutRecordsRequest) GetRecords ¶
func (m *PutRecordsRequest) GetRecords() []*RecordEntry
func (*PutRecordsRequest) ProtoMessage ¶
func (*PutRecordsRequest) ProtoMessage()
func (*PutRecordsRequest) Reset ¶
func (m *PutRecordsRequest) Reset()
func (*PutRecordsRequest) String ¶
func (m *PutRecordsRequest) String() string
func (*PutRecordsRequest) XXX_DiscardUnknown ¶
func (m *PutRecordsRequest) XXX_DiscardUnknown()
func (*PutRecordsRequest) XXX_Marshal ¶
func (m *PutRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutRecordsRequest) XXX_Merge ¶
func (m *PutRecordsRequest) XXX_Merge(src proto.Message)
func (*PutRecordsRequest) XXX_Size ¶
func (m *PutRecordsRequest) XXX_Size() int
func (*PutRecordsRequest) XXX_Unmarshal ¶
func (m *PutRecordsRequest) XXX_Unmarshal(b []byte) error
type PutRecordsResponse ¶
type PutRecordsResponse struct { FailedCount *int32 `protobuf:"varint,1,opt,name=failed_count,json=failedCount" json:"failed_count,omitempty"` FailedRecords []*FailedRecord `protobuf:"bytes,2,rep,name=failed_records,json=failedRecords" json:"failed_records,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutRecordsResponse) Descriptor ¶
func (*PutRecordsResponse) Descriptor() ([]byte, []int)
func (*PutRecordsResponse) GetFailedCount ¶
func (m *PutRecordsResponse) GetFailedCount() int32
func (*PutRecordsResponse) GetFailedRecords ¶
func (m *PutRecordsResponse) GetFailedRecords() []*FailedRecord
func (*PutRecordsResponse) ProtoMessage ¶
func (*PutRecordsResponse) ProtoMessage()
func (*PutRecordsResponse) Reset ¶
func (m *PutRecordsResponse) Reset()
func (*PutRecordsResponse) String ¶
func (m *PutRecordsResponse) String() string
func (*PutRecordsResponse) XXX_DiscardUnknown ¶
func (m *PutRecordsResponse) XXX_DiscardUnknown()
func (*PutRecordsResponse) XXX_Marshal ¶
func (m *PutRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutRecordsResponse) XXX_Merge ¶
func (m *PutRecordsResponse) XXX_Merge(src proto.Message)
func (*PutRecordsResponse) XXX_Size ¶
func (m *PutRecordsResponse) XXX_Size() int
func (*PutRecordsResponse) XXX_Unmarshal ¶
func (m *PutRecordsResponse) XXX_Unmarshal(b []byte) error
type RecordAttributes ¶
type RecordAttributes struct { Attributes []*StringPair `protobuf:"bytes,1,rep,name=attributes" json:"attributes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RecordAttributes) Descriptor ¶
func (*RecordAttributes) Descriptor() ([]byte, []int)
func (*RecordAttributes) GetAttributes ¶
func (m *RecordAttributes) GetAttributes() []*StringPair
func (*RecordAttributes) ProtoMessage ¶
func (*RecordAttributes) ProtoMessage()
func (*RecordAttributes) Reset ¶
func (m *RecordAttributes) Reset()
func (*RecordAttributes) String ¶
func (m *RecordAttributes) String() string
func (*RecordAttributes) XXX_DiscardUnknown ¶
func (m *RecordAttributes) XXX_DiscardUnknown()
func (*RecordAttributes) XXX_Marshal ¶
func (m *RecordAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordAttributes) XXX_Merge ¶
func (m *RecordAttributes) XXX_Merge(src proto.Message)
func (*RecordAttributes) XXX_Size ¶
func (m *RecordAttributes) XXX_Size() int
func (*RecordAttributes) XXX_Unmarshal ¶
func (m *RecordAttributes) XXX_Unmarshal(b []byte) error
type RecordData ¶
type RecordData struct { Data []*FieldData `protobuf:"bytes,1,rep,name=data" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RecordData) Descriptor ¶
func (*RecordData) Descriptor() ([]byte, []int)
func (*RecordData) GetData ¶
func (m *RecordData) GetData() []*FieldData
func (*RecordData) ProtoMessage ¶
func (*RecordData) ProtoMessage()
func (*RecordData) Reset ¶
func (m *RecordData) Reset()
func (*RecordData) String ¶
func (m *RecordData) String() string
func (*RecordData) XXX_DiscardUnknown ¶
func (m *RecordData) XXX_DiscardUnknown()
func (*RecordData) XXX_Marshal ¶
func (m *RecordData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordData) XXX_Merge ¶
func (m *RecordData) XXX_Merge(src proto.Message)
func (*RecordData) XXX_Size ¶
func (m *RecordData) XXX_Size() int
func (*RecordData) XXX_Unmarshal ¶
func (m *RecordData) XXX_Unmarshal(b []byte) error
type RecordEntry ¶
type RecordEntry struct { ShardId *string `protobuf:"bytes,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"` HashKey *string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey" json:"hash_key,omitempty"` PartitionKey *string `protobuf:"bytes,3,opt,name=partition_key,json=partitionKey" json:"partition_key,omitempty"` Cursor *string `protobuf:"bytes,4,opt,name=cursor" json:"cursor,omitempty"` NextCursor *string `protobuf:"bytes,5,opt,name=next_cursor,json=nextCursor" json:"next_cursor,omitempty"` Sequence *int64 `protobuf:"varint,6,opt,name=sequence" json:"sequence,omitempty"` SystemTime *int64 `protobuf:"varint,7,opt,name=system_time,json=systemTime" json:"system_time,omitempty"` Attributes *RecordAttributes `protobuf:"bytes,8,opt,name=attributes" json:"attributes,omitempty"` Data *RecordData `protobuf:"bytes,9,req,name=data" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RecordEntry) Descriptor ¶
func (*RecordEntry) Descriptor() ([]byte, []int)
func (*RecordEntry) GetAttributes ¶
func (m *RecordEntry) GetAttributes() *RecordAttributes
func (*RecordEntry) GetCursor ¶
func (m *RecordEntry) GetCursor() string
func (*RecordEntry) GetData ¶
func (m *RecordEntry) GetData() *RecordData
func (*RecordEntry) GetHashKey ¶
func (m *RecordEntry) GetHashKey() string
func (*RecordEntry) GetNextCursor ¶
func (m *RecordEntry) GetNextCursor() string
func (*RecordEntry) GetPartitionKey ¶
func (m *RecordEntry) GetPartitionKey() string
func (*RecordEntry) GetSequence ¶
func (m *RecordEntry) GetSequence() int64
func (*RecordEntry) GetShardId ¶
func (m *RecordEntry) GetShardId() string
func (*RecordEntry) GetSystemTime ¶
func (m *RecordEntry) GetSystemTime() int64
func (*RecordEntry) ProtoMessage ¶
func (*RecordEntry) ProtoMessage()
func (*RecordEntry) Reset ¶
func (m *RecordEntry) Reset()
func (*RecordEntry) String ¶
func (m *RecordEntry) String() string
func (*RecordEntry) XXX_DiscardUnknown ¶
func (m *RecordEntry) XXX_DiscardUnknown()
func (*RecordEntry) XXX_Marshal ¶
func (m *RecordEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordEntry) XXX_Merge ¶
func (m *RecordEntry) XXX_Merge(src proto.Message)
func (*RecordEntry) XXX_Size ¶
func (m *RecordEntry) XXX_Size() int
func (*RecordEntry) XXX_Unmarshal ¶
func (m *RecordEntry) XXX_Unmarshal(b []byte) error
type StringPair ¶
type StringPair struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Value *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StringPair) Descriptor ¶
func (*StringPair) Descriptor() ([]byte, []int)
func (*StringPair) GetKey ¶
func (m *StringPair) GetKey() string
func (*StringPair) GetValue ¶
func (m *StringPair) GetValue() string
func (*StringPair) ProtoMessage ¶
func (*StringPair) ProtoMessage()
func (*StringPair) Reset ¶
func (m *StringPair) Reset()
func (*StringPair) String ¶
func (m *StringPair) String() string
func (*StringPair) XXX_DiscardUnknown ¶
func (m *StringPair) XXX_DiscardUnknown()
func (*StringPair) XXX_Marshal ¶
func (m *StringPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StringPair) XXX_Merge ¶
func (m *StringPair) XXX_Merge(src proto.Message)
func (*StringPair) XXX_Size ¶
func (m *StringPair) XXX_Size() int
func (*StringPair) XXX_Unmarshal ¶
func (m *StringPair) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.