pbmodel

package

Go to main page

Versions in this module

v0

v0.2.1

Feb 16, 2025

v0.2.0

Dec 19, 2024

v0.1.10

Dec 19, 2024

v0.1.9

Dec 17, 2024

v0.1.8

Oct 31, 2024

v0.1.6

Jun 20, 2022

v0.1.5

May 6, 2021

Changes in this version

+ const Default_BinaryRecordEntry_Serial

+ const Default_GetBinaryRecordsResponse_LatestSequence

+ const Default_GetBinaryRecordsResponse_LatestTime

+ const Default_GetRecordsResponse_LatestSequence

+ const Default_GetRecordsResponse_LatestTime

+ type BinaryRecordEntry struct

+ Cursor *string

+ Data []byte

+ NextCursor *string

+ Sequence *int64

+ Serial *uint32

+ SystemTime *int64

+ func (*BinaryRecordEntry) Descriptor() ([]byte, []int)

+ func (*BinaryRecordEntry) ProtoMessage()

+ func (x *BinaryRecordEntry) GetCursor() string

+ func (x *BinaryRecordEntry) GetData() []byte

+ func (x *BinaryRecordEntry) GetNextCursor() string

+ func (x *BinaryRecordEntry) GetSequence() int64

+ func (x *BinaryRecordEntry) GetSerial() uint32

+ func (x *BinaryRecordEntry) GetSystemTime() int64

+ func (x *BinaryRecordEntry) ProtoReflect() protoreflect.Message

+ func (x *BinaryRecordEntry) Reset()

+ func (x *BinaryRecordEntry) String() string

+ type GetBinaryRecordsResponse struct

+ LatestSequence *int64

+ LatestTime *int64

+ NextCursor *string

+ RecordCount *int32

+ Records []*BinaryRecordEntry

+ StartSequence *int64

+ func (*GetBinaryRecordsResponse) Descriptor() ([]byte, []int)

+ func (*GetBinaryRecordsResponse) ProtoMessage()

+ func (x *GetBinaryRecordsResponse) GetLatestSequence() int64

+ func (x *GetBinaryRecordsResponse) GetLatestTime() int64

+ func (x *GetBinaryRecordsResponse) GetNextCursor() string

+ func (x *GetBinaryRecordsResponse) GetRecordCount() int32

+ func (x *GetBinaryRecordsResponse) GetRecords() []*BinaryRecordEntry

+ func (x *GetBinaryRecordsResponse) GetStartSequence() int64

+ func (x *GetBinaryRecordsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetBinaryRecordsResponse) Reset()

+ func (x *GetBinaryRecordsResponse) String() string

type GetRecordsResponse

+ LatestSequence *int64

+ LatestTime *int64

+ func (x *GetRecordsResponse) GetLatestSequence() int64

+ func (x *GetRecordsResponse) GetLatestTime() int64

+ type PutBinaryRecordsRequest struct

+ Records []*BinaryRecordEntry

+ func (*PutBinaryRecordsRequest) Descriptor() ([]byte, []int)

+ func (*PutBinaryRecordsRequest) ProtoMessage()

+ func (x *PutBinaryRecordsRequest) GetRecords() []*BinaryRecordEntry

+ func (x *PutBinaryRecordsRequest) ProtoReflect() protoreflect.Message

+ func (x *PutBinaryRecordsRequest) Reset()

+ func (x *PutBinaryRecordsRequest) String() string

v0.1.4

Nov 17, 2020

v0.1.3

May 15, 2020

Changes in this version

+ var File_datahub_proto protoreflect.FileDescriptor

type FailedRecord

+ func (x *FailedRecord) ProtoReflect() protoreflect.Message

type FieldData

+ func (x *FieldData) ProtoReflect() protoreflect.Message

type GetRecordsRequest

+ func (x *GetRecordsRequest) ProtoReflect() protoreflect.Message

type GetRecordsResponse

+ func (x *GetRecordsResponse) ProtoReflect() protoreflect.Message

type PutRecordsRequest

+ func (x *PutRecordsRequest) ProtoReflect() protoreflect.Message

type PutRecordsResponse

+ func (x *PutRecordsResponse) ProtoReflect() protoreflect.Message

type RecordAttributes

+ func (x *RecordAttributes) ProtoReflect() protoreflect.Message

type RecordData

+ func (x *RecordData) ProtoReflect() protoreflect.Message

type RecordEntry

+ func (x *RecordEntry) ProtoReflect() protoreflect.Message

type StringPair

+ func (x *StringPair) ProtoReflect() protoreflect.Message

v0.1.2

Apr 7, 2020

Changes in this version

+ const Default_GetRecordsRequest_Limit

+ type FailedRecord struct

+ ErrorCode *string

+ ErrorMessage *string

+ Index *int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FailedRecord) Descriptor() ([]byte, []int)

+ func (*FailedRecord) ProtoMessage()

+ func (m *FailedRecord) GetErrorCode() string

+ func (m *FailedRecord) GetErrorMessage() string

+ func (m *FailedRecord) GetIndex() int32

+ 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 struct

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FieldData) Descriptor() ([]byte, []int)

+ func (*FieldData) ProtoMessage()

+ func (m *FieldData) GetValue() []byte

+ 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 struct

+ Cursor *string

+ Limit *int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetRecordsRequest) Descriptor() ([]byte, []int)

+ func (*GetRecordsRequest) ProtoMessage()

+ func (m *GetRecordsRequest) GetCursor() string

+ func (m *GetRecordsRequest) GetLimit() int32

+ 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 struct

+ NextCursor *string

+ RecordCount *int32

+ Records []*RecordEntry

+ StartSequence *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetRecordsResponse) Descriptor() ([]byte, []int)

+ func (*GetRecordsResponse) ProtoMessage()

+ func (m *GetRecordsResponse) GetNextCursor() string

+ func (m *GetRecordsResponse) GetRecordCount() int32

+ func (m *GetRecordsResponse) GetRecords() []*RecordEntry

+ func (m *GetRecordsResponse) GetStartSequence() int64

+ 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 struct

+ Records []*RecordEntry

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PutRecordsRequest) Descriptor() ([]byte, []int)

+ func (*PutRecordsRequest) ProtoMessage()

+ func (m *PutRecordsRequest) GetRecords() []*RecordEntry

+ 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 struct

+ FailedCount *int32

+ FailedRecords []*FailedRecord

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PutRecordsResponse) Descriptor() ([]byte, []int)

+ func (*PutRecordsResponse) ProtoMessage()

+ func (m *PutRecordsResponse) GetFailedCount() int32

+ func (m *PutRecordsResponse) GetFailedRecords() []*FailedRecord

+ 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 struct

+ Attributes []*StringPair

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RecordAttributes) Descriptor() ([]byte, []int)

+ func (*RecordAttributes) ProtoMessage()

+ func (m *RecordAttributes) GetAttributes() []*StringPair

+ 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 struct

+ Data []*FieldData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RecordData) Descriptor() ([]byte, []int)

+ func (*RecordData) ProtoMessage()

+ func (m *RecordData) GetData() []*FieldData

+ 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 struct

+ Attributes *RecordAttributes

+ Cursor *string

+ Data *RecordData

+ HashKey *string

+ NextCursor *string

+ PartitionKey *string

+ Sequence *int64

+ ShardId *string

+ SystemTime *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RecordEntry) Descriptor() ([]byte, []int)

+ func (*RecordEntry) ProtoMessage()

+ 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 (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 struct

+ Key *string

+ Value *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StringPair) Descriptor() ([]byte, []int)

+ func (*StringPair) ProtoMessage()

+ func (m *StringPair) GetKey() string

+ func (m *StringPair) GetValue() string

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL