pbmodel

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2025 License: Apache-2.0 Imports: 5 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	Default_GetRecordsResponse_LatestSequence = int64(-1)
	Default_GetRecordsResponse_LatestTime     = int64(-1)
)

Default values for GetRecordsResponse fields.

View Source 
const (
	Default_GetBinaryRecordsResponse_LatestSequence = int64(-1)
	Default_GetBinaryRecordsResponse_LatestTime     = int64(-1)
)

Default values for GetBinaryRecordsResponse fields.

View Source 
const (
	Default_BinaryRecordEntry_Serial = uint32(0)
)

Default values for BinaryRecordEntry fields.

View Source 
const (
	Default_GetRecordsRequest_Limit = int32(1)
)

Default values for GetRecordsRequest fields.

Variables

View Source 
var File_datahub_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BinaryRecordEntry added in v0.1.5 

type BinaryRecordEntry struct {
	Cursor     *string `protobuf:"bytes,1,opt,name=cursor" json:"cursor,omitempty"`
	NextCursor *string `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor" json:"next_cursor,omitempty"`
	Sequence   *int64  `protobuf:"varint,3,opt,name=sequence" json:"sequence,omitempty"`
	SystemTime *int64  `protobuf:"varint,4,opt,name=system_time,json=systemTime" json:"system_time,omitempty"`
	Serial     *uint32 `protobuf:"varint,5,opt,name=serial,def=0" json:"serial,omitempty"`
	Data       []byte  `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BinaryRecordEntry) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use BinaryRecordEntry.ProtoReflect.Descriptor instead.

func (*BinaryRecordEntry) GetCursor added in v0.1.5 

func (x *BinaryRecordEntry) GetCursor() string

func (*BinaryRecordEntry) GetData added in v0.1.5 

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

func (*BinaryRecordEntry) GetNextCursor added in v0.1.5 

func (x *BinaryRecordEntry) GetNextCursor() string

func (*BinaryRecordEntry) GetSequence added in v0.1.5 

func (x *BinaryRecordEntry) GetSequence() int64

func (*BinaryRecordEntry) GetSerial added in v0.1.5 

func (x *BinaryRecordEntry) GetSerial() uint32

func (*BinaryRecordEntry) GetSystemTime added in v0.1.5 

func (x *BinaryRecordEntry) GetSystemTime() int64

func (*BinaryRecordEntry) ProtoMessage added in v0.1.5 

func (*BinaryRecordEntry) ProtoMessage()

func (*BinaryRecordEntry) ProtoReflect added in v0.1.5 

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

func (*BinaryRecordEntry) Reset added in v0.1.5 

func (x *BinaryRecordEntry) Reset()

func (*BinaryRecordEntry) String added in v0.1.5 

func (x *BinaryRecordEntry) String() string

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"`
	// contains filtered or unexported fields
}

func (*FailedRecord) Descriptor deprecated 

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

Deprecated: Use FailedRecord.ProtoReflect.Descriptor instead.

func (*FailedRecord) GetErrorCode 

func (x *FailedRecord) GetErrorCode() string

func (*FailedRecord) GetErrorMessage 

func (x *FailedRecord) GetErrorMessage() string

func (*FailedRecord) GetIndex 

func (x *FailedRecord) GetIndex() int32

func (*FailedRecord) ProtoMessage 

func (*FailedRecord) ProtoMessage()

func (*FailedRecord) ProtoReflect added in v0.1.3 

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

func (*FailedRecord) Reset 

func (x *FailedRecord) Reset()

func (*FailedRecord) String 

func (x *FailedRecord) String() string

type FieldData 

type FieldData struct {
	Value []byte `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldData) Descriptor deprecated 

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

Deprecated: Use FieldData.ProtoReflect.Descriptor instead.

func (*FieldData) GetValue 

func (x *FieldData) GetValue() []byte

func (*FieldData) ProtoMessage 

func (*FieldData) ProtoMessage()

func (*FieldData) ProtoReflect added in v0.1.3 

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

func (*FieldData) Reset 

func (x *FieldData) Reset()

func (*FieldData) String 

func (x *FieldData) String() string

type GetBinaryRecordsResponse added in v0.1.5 

type GetBinaryRecordsResponse 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        []*BinaryRecordEntry `protobuf:"bytes,4,rep,name=records" json:"records,omitempty"`
	LatestSequence *int64               `protobuf:"varint,5,opt,name=latest_sequence,json=latestSequence,def=-1" json:"latest_sequence,omitempty"`
	LatestTime     *int64               `protobuf:"varint,6,opt,name=latest_time,json=latestTime,def=-1" json:"latest_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBinaryRecordsResponse) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use GetBinaryRecordsResponse.ProtoReflect.Descriptor instead.

func (*GetBinaryRecordsResponse) GetLatestSequence added in v0.1.5 

func (x *GetBinaryRecordsResponse) GetLatestSequence() int64

func (*GetBinaryRecordsResponse) GetLatestTime added in v0.1.5 

func (x *GetBinaryRecordsResponse) GetLatestTime() int64

func (*GetBinaryRecordsResponse) GetNextCursor added in v0.1.5 

func (x *GetBinaryRecordsResponse) GetNextCursor() string

func (*GetBinaryRecordsResponse) GetRecordCount added in v0.1.5 

func (x *GetBinaryRecordsResponse) GetRecordCount() int32

func (*GetBinaryRecordsResponse) GetRecords added in v0.1.5 

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

func (*GetBinaryRecordsResponse) GetStartSequence added in v0.1.5 

func (x *GetBinaryRecordsResponse) GetStartSequence() int64

func (*GetBinaryRecordsResponse) ProtoMessage added in v0.1.5 

func (*GetBinaryRecordsResponse) ProtoMessage()

func (*GetBinaryRecordsResponse) ProtoReflect added in v0.1.5 

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

func (*GetBinaryRecordsResponse) Reset added in v0.1.5 

func (x *GetBinaryRecordsResponse) Reset()

func (*GetBinaryRecordsResponse) String added in v0.1.5 

func (x *GetBinaryRecordsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetRecordsRequest) Descriptor deprecated 

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

Deprecated: Use GetRecordsRequest.ProtoReflect.Descriptor instead.

func (*GetRecordsRequest) GetCursor 

func (x *GetRecordsRequest) GetCursor() string

func (*GetRecordsRequest) GetLimit 

func (x *GetRecordsRequest) GetLimit() int32

func (*GetRecordsRequest) ProtoMessage 

func (*GetRecordsRequest) ProtoMessage()

func (*GetRecordsRequest) ProtoReflect added in v0.1.3 

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

func (*GetRecordsRequest) Reset 

func (x *GetRecordsRequest) Reset()

func (*GetRecordsRequest) String 

func (x *GetRecordsRequest) String() string

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"`
	LatestSequence *int64         `protobuf:"varint,5,opt,name=latest_sequence,json=latestSequence,def=-1" json:"latest_sequence,omitempty"`
	LatestTime     *int64         `protobuf:"varint,6,opt,name=latest_time,json=latestTime,def=-1" json:"latest_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecordsResponse) Descriptor deprecated 

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

Deprecated: Use GetRecordsResponse.ProtoReflect.Descriptor instead.

func (*GetRecordsResponse) GetLatestSequence added in v0.1.5 

func (x *GetRecordsResponse) GetLatestSequence() int64

func (*GetRecordsResponse) GetLatestTime added in v0.1.5 

func (x *GetRecordsResponse) GetLatestTime() int64

func (*GetRecordsResponse) GetNextCursor 

func (x *GetRecordsResponse) GetNextCursor() string

func (*GetRecordsResponse) GetRecordCount 

func (x *GetRecordsResponse) GetRecordCount() int32

func (*GetRecordsResponse) GetRecords 

func (x *GetRecordsResponse) GetRecords() []*RecordEntry

func (*GetRecordsResponse) GetStartSequence 

func (x *GetRecordsResponse) GetStartSequence() int64

func (*GetRecordsResponse) ProtoMessage 

func (*GetRecordsResponse) ProtoMessage()

func (*GetRecordsResponse) ProtoReflect added in v0.1.3 

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

func (*GetRecordsResponse) Reset 

func (x *GetRecordsResponse) Reset()

func (*GetRecordsResponse) String 

func (x *GetRecordsResponse) String() string

type PutBinaryRecordsRequest added in v0.1.5 

type PutBinaryRecordsRequest struct {
	Records []*BinaryRecordEntry `protobuf:"bytes,1,rep,name=records" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*PutBinaryRecordsRequest) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use PutBinaryRecordsRequest.ProtoReflect.Descriptor instead.

func (*PutBinaryRecordsRequest) GetRecords added in v0.1.5 

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

func (*PutBinaryRecordsRequest) ProtoMessage added in v0.1.5 

func (*PutBinaryRecordsRequest) ProtoMessage()

func (*PutBinaryRecordsRequest) ProtoReflect added in v0.1.5 

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

func (*PutBinaryRecordsRequest) Reset added in v0.1.5 

func (x *PutBinaryRecordsRequest) Reset()

func (*PutBinaryRecordsRequest) String added in v0.1.5 

func (x *PutBinaryRecordsRequest) String() string

type PutRecordsRequest 

type PutRecordsRequest struct {
	Records []*RecordEntry `protobuf:"bytes,1,rep,name=records" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRecordsRequest) Descriptor deprecated 

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

Deprecated: Use PutRecordsRequest.ProtoReflect.Descriptor instead.

func (*PutRecordsRequest) GetRecords 

func (x *PutRecordsRequest) GetRecords() []*RecordEntry

func (*PutRecordsRequest) ProtoMessage 

func (*PutRecordsRequest) ProtoMessage()

func (*PutRecordsRequest) ProtoReflect added in v0.1.3 

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

func (*PutRecordsRequest) Reset 

func (x *PutRecordsRequest) Reset()

func (*PutRecordsRequest) String 

func (x *PutRecordsRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*PutRecordsResponse) Descriptor deprecated 

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

Deprecated: Use PutRecordsResponse.ProtoReflect.Descriptor instead.

func (*PutRecordsResponse) GetFailedCount 

func (x *PutRecordsResponse) GetFailedCount() int32

func (*PutRecordsResponse) GetFailedRecords 

func (x *PutRecordsResponse) GetFailedRecords() []*FailedRecord

func (*PutRecordsResponse) ProtoMessage 

func (*PutRecordsResponse) ProtoMessage()

func (*PutRecordsResponse) ProtoReflect added in v0.1.3 

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

func (*PutRecordsResponse) Reset 

func (x *PutRecordsResponse) Reset()

func (*PutRecordsResponse) String 

func (x *PutRecordsResponse) String() string

type RecordAttributes 

type RecordAttributes struct {
	Attributes []*StringPair `protobuf:"bytes,1,rep,name=attributes" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordAttributes) Descriptor deprecated 

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

Deprecated: Use RecordAttributes.ProtoReflect.Descriptor instead.

func (*RecordAttributes) GetAttributes 

func (x *RecordAttributes) GetAttributes() []*StringPair

func (*RecordAttributes) ProtoMessage 

func (*RecordAttributes) ProtoMessage()

func (*RecordAttributes) ProtoReflect added in v0.1.3 

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

func (*RecordAttributes) Reset 

func (x *RecordAttributes) Reset()

func (*RecordAttributes) String 

func (x *RecordAttributes) String() string

type RecordData 

type RecordData struct {
	Data []*FieldData `protobuf:"bytes,1,rep,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordData) Descriptor deprecated 

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

Deprecated: Use RecordData.ProtoReflect.Descriptor instead.

func (*RecordData) GetData 

func (x *RecordData) GetData() []*FieldData

func (*RecordData) ProtoMessage 

func (*RecordData) ProtoMessage()

func (*RecordData) ProtoReflect added in v0.1.3 

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

func (*RecordData) Reset 

func (x *RecordData) Reset()

func (*RecordData) String 

func (x *RecordData) String() string

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"`
	// contains filtered or unexported fields
}

func (*RecordEntry) Descriptor deprecated 

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

Deprecated: Use RecordEntry.ProtoReflect.Descriptor instead.

func (*RecordEntry) GetAttributes 

func (x *RecordEntry) GetAttributes() *RecordAttributes

func (*RecordEntry) GetCursor 

func (x *RecordEntry) GetCursor() string

func (*RecordEntry) GetData 

func (x *RecordEntry) GetData() *RecordData

func (*RecordEntry) GetHashKey 

func (x *RecordEntry) GetHashKey() string

func (*RecordEntry) GetNextCursor 

func (x *RecordEntry) GetNextCursor() string

func (*RecordEntry) GetPartitionKey 

func (x *RecordEntry) GetPartitionKey() string

func (*RecordEntry) GetSequence 

func (x *RecordEntry) GetSequence() int64

func (*RecordEntry) GetShardId 

func (x *RecordEntry) GetShardId() string

func (*RecordEntry) GetSystemTime 

func (x *RecordEntry) GetSystemTime() int64

func (*RecordEntry) ProtoMessage 

func (*RecordEntry) ProtoMessage()

func (*RecordEntry) ProtoReflect added in v0.1.3 

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

func (*RecordEntry) Reset 

func (x *RecordEntry) Reset()

func (*RecordEntry) String 

func (x *RecordEntry) String() string

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"`
	// contains filtered or unexported fields
}

func (*StringPair) Descriptor deprecated 

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

Deprecated: Use StringPair.ProtoReflect.Descriptor instead.

func (*StringPair) GetKey 

func (x *StringPair) GetKey() string

func (*StringPair) GetValue 

func (x *StringPair) GetValue() string

func (*StringPair) ProtoMessage 

func (*StringPair) ProtoMessage()

func (*StringPair) ProtoReflect added in v0.1.3 

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

func (*StringPair) Reset 

func (x *StringPair) Reset()

func (*StringPair) String 

func (x *StringPair) 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.