pbmodel

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

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

func (*GetRecordsResponse) Descriptor deprecated 

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

Deprecated: Use GetRecordsResponse.ProtoReflect.Descriptor instead.

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 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.