datahubProtos

package
v0.0.0-...-8e683c8 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

func (*FieldData) GetValue 

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

func (*FieldData) ProtoMessage 

func (*FieldData) ProtoMessage()

func (*FieldData) Reset 

func (m *FieldData) Reset()

func (*FieldData) String 

func (m *FieldData) String() string

func (*FieldData) XXX_DiscardUnknown 

func (m *FieldData) XXX_DiscardUnknown()

func (*FieldData) XXX_Marshal 

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

func (*FieldData) XXX_Merge 

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

func (*FieldData) XXX_Size 

func (m *FieldData) XXX_Size() int

func (*FieldData) XXX_Unmarshal 

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

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

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.