records

Documentation

Index

• type AggregatedRecord
  • func (*AggregatedRecord) Descriptor() ([]byte, []int)
  • func (m *AggregatedRecord) GetExplicitHashKeyTable() []string
  • func (m *AggregatedRecord) GetPartitionKeyTable() []string
  • func (m *AggregatedRecord) GetRecords() []*Record
  • func (*AggregatedRecord) ProtoMessage()
  • func (m *AggregatedRecord) Reset()
  • func (m *AggregatedRecord) String() string
  • func (m *AggregatedRecord) XXX_DiscardUnknown()
  • func (m *AggregatedRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AggregatedRecord) XXX_Merge(src proto.Message)
  • func (m *AggregatedRecord) XXX_Size() int
  • func (m *AggregatedRecord) XXX_Unmarshal(b []byte) error
• type Record
  • func (*Record) Descriptor() ([]byte, []int)
  • func (m *Record) GetData() []byte
  • func (m *Record) GetExplicitHashKeyIndex() uint64
  • func (m *Record) GetPartitionKeyIndex() uint64
  • func (m *Record) GetTags() []*Tag
  • func (*Record) ProtoMessage()
  • func (m *Record) Reset()
  • func (m *Record) String() string
  • func (m *Record) XXX_DiscardUnknown()
  • func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Record) XXX_Merge(src proto.Message)
  • func (m *Record) XXX_Size() int
  • func (m *Record) XXX_Unmarshal(b []byte) error
• type Tag
  • func (*Tag) Descriptor() ([]byte, []int)
  • func (m *Tag) GetKey() string
  • func (m *Tag) GetValue() string
  • func (*Tag) ProtoMessage()
  • func (m *Tag) Reset()
  • func (m *Tag) String() string
  • func (m *Tag) XXX_DiscardUnknown()
  • func (m *Tag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Tag) XXX_Merge(src proto.Message)
  • func (m *Tag) XXX_Size() int
  • func (m *Tag) XXX_Unmarshal(b []byte) error

Types

type AggregatedRecord

type AggregatedRecord struct {
	PartitionKeyTable    []string  `protobuf:"bytes,1,rep,name=partition_key_table,json=partitionKeyTable" json:"partition_key_table,omitempty"`
	ExplicitHashKeyTable []string  `protobuf:"bytes,2,rep,name=explicit_hash_key_table,json=explicitHashKeyTable" json:"explicit_hash_key_table,omitempty"`
	Records              []*Record `protobuf:"bytes,3,rep,name=records" json:"records,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AggregatedRecord) Descriptor

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

func (*AggregatedRecord) GetExplicitHashKeyTable

func (m *AggregatedRecord) GetExplicitHashKeyTable() []string

func (*AggregatedRecord) GetPartitionKeyTable

func (m *AggregatedRecord) GetPartitionKeyTable() []string

func (*AggregatedRecord) GetRecords

func (m *AggregatedRecord) GetRecords() []*Record

func (*AggregatedRecord) ProtoMessage

func (*AggregatedRecord) ProtoMessage()

func (*AggregatedRecord) Reset

func (m *AggregatedRecord) Reset()

func (*AggregatedRecord) String

func (m *AggregatedRecord) String() string

func (*AggregatedRecord) XXX_DiscardUnknown

func (m *AggregatedRecord) XXX_DiscardUnknown()

func (*AggregatedRecord) XXX_Marshal

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

func (*AggregatedRecord) XXX_Merge

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

func (*AggregatedRecord) XXX_Size

func (m *AggregatedRecord) XXX_Size() int

func (*AggregatedRecord) XXX_Unmarshal

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

type Record

type Record struct {
	PartitionKeyIndex    *uint64  `protobuf:"varint,1,req,name=partition_key_index,json=partitionKeyIndex" json:"partition_key_index,omitempty"`
	ExplicitHashKeyIndex *uint64  `protobuf:"varint,2,opt,name=explicit_hash_key_index,json=explicitHashKeyIndex" json:"explicit_hash_key_index,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
	Tags                 []*Tag   `protobuf:"bytes,4,rep,name=tags" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Record) Descriptor

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

func (*Record) GetData

func (m *Record) GetData() []byte

func (*Record) GetExplicitHashKeyIndex

func (m *Record) GetExplicitHashKeyIndex() uint64

func (*Record) GetPartitionKeyIndex

func (m *Record) GetPartitionKeyIndex() uint64

func (*Record) GetTags

func (m *Record) GetTags() []*Tag

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) Reset

func (m *Record) Reset()

func (*Record) String

func (m *Record) String() string

func (*Record) XXX_DiscardUnknown

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal

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

func (*Record) XXX_Merge

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

func (*Record) XXX_Size

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal

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

type Tag

type Tag struct {
	Key                  *string  `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value                *string  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Tag) Descriptor

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

func (*Tag) GetKey

func (m *Tag) GetKey() string

func (*Tag) GetValue

func (m *Tag) GetValue() string

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) Reset

func (m *Tag) Reset()

func (*Tag) String

func (m *Tag) String() string

func (*Tag) XXX_DiscardUnknown

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal

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

func (*Tag) XXX_Merge

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

func (*Tag) XXX_Size

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal

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