Documentation ¶
Index ¶
- Variables
- type CompositeTimestamp
- func (*CompositeTimestamp) Descriptor() ([]byte, []int)
- func (m *CompositeTimestamp) GetTimestamps() []Timestamp
- func (m *CompositeTimestamp) Marshal() (dAtA []byte, err error)
- func (m *CompositeTimestamp) MarshalTo(dAtA []byte) (int, error)
- func (m *CompositeTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CompositeTimestamp) ProtoMessage()
- func (m *CompositeTimestamp) Reset()
- func (m *CompositeTimestamp) Size() (n int)
- func (m *CompositeTimestamp) String() string
- func (m *CompositeTimestamp) Unmarshal(dAtA []byte) error
- func (m *CompositeTimestamp) XXX_DiscardUnknown()
- func (m *CompositeTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CompositeTimestamp) XXX_Merge(src proto.Message)
- func (m *CompositeTimestamp) XXX_Size() int
- func (m *CompositeTimestamp) XXX_Unmarshal(b []byte) error
- type Epoch
- func (*Epoch) Descriptor() ([]byte, []int)
- func (m *Epoch) GetNum() EpochNum
- func (m *Epoch) Marshal() (dAtA []byte, err error)
- func (m *Epoch) MarshalTo(dAtA []byte) (int, error)
- func (m *Epoch) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Epoch) ProtoMessage()
- func (m *Epoch) Reset()
- func (m *Epoch) Size() (n int)
- func (m *Epoch) String() string
- func (m *Epoch) Unmarshal(dAtA []byte) error
- func (m *Epoch) XXX_DiscardUnknown()
- func (m *Epoch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Epoch) XXX_Merge(src proto.Message)
- func (m *Epoch) XXX_Size() int
- func (m *Epoch) XXX_Unmarshal(b []byte) error
- type EpochNum
- type EpochTimestamp
- func (*EpochTimestamp) Descriptor() ([]byte, []int)
- func (m *EpochTimestamp) GetEpoch() Epoch
- func (m *EpochTimestamp) GetSequence() Sequence
- func (m *EpochTimestamp) Marshal() (dAtA []byte, err error)
- func (m *EpochTimestamp) MarshalTo(dAtA []byte) (int, error)
- func (m *EpochTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EpochTimestamp) ProtoMessage()
- func (m *EpochTimestamp) Reset()
- func (m *EpochTimestamp) Size() (n int)
- func (m *EpochTimestamp) String() string
- func (m *EpochTimestamp) Unmarshal(dAtA []byte) error
- func (m *EpochTimestamp) XXX_DiscardUnknown()
- func (m *EpochTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EpochTimestamp) XXX_Merge(src proto.Message)
- func (m *EpochTimestamp) XXX_Size() int
- func (m *EpochTimestamp) XXX_Unmarshal(b []byte) error
- type LogicalTime
- type LogicalTimestamp
- func (*LogicalTimestamp) Descriptor() ([]byte, []int)
- func (m *LogicalTimestamp) GetTime() LogicalTime
- func (m *LogicalTimestamp) Marshal() (dAtA []byte, err error)
- func (m *LogicalTimestamp) MarshalTo(dAtA []byte) (int, error)
- func (m *LogicalTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogicalTimestamp) ProtoMessage()
- func (m *LogicalTimestamp) Reset()
- func (m *LogicalTimestamp) Size() (n int)
- func (m *LogicalTimestamp) String() string
- func (m *LogicalTimestamp) Unmarshal(dAtA []byte) error
- func (m *LogicalTimestamp) XXX_DiscardUnknown()
- func (m *LogicalTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogicalTimestamp) XXX_Merge(src proto.Message)
- func (m *LogicalTimestamp) XXX_Size() int
- func (m *LogicalTimestamp) XXX_Unmarshal(b []byte) error
- type ObjectMeta
- func (*ObjectMeta) Descriptor() ([]byte, []int)
- func (m *ObjectMeta) GetRevision() *Revision
- func (m *ObjectMeta) GetTimestamp() *Timestamp
- func (m *ObjectMeta) GetType() ObjectMeta_Type
- func (m *ObjectMeta) Marshal() (dAtA []byte, err error)
- func (m *ObjectMeta) MarshalTo(dAtA []byte) (int, error)
- func (m *ObjectMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ObjectMeta) ProtoMessage()
- func (m *ObjectMeta) Reset()
- func (m *ObjectMeta) Size() (n int)
- func (m *ObjectMeta) String() string
- func (m *ObjectMeta) Unmarshal(dAtA []byte) error
- func (m *ObjectMeta) XXX_DiscardUnknown()
- func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectMeta) XXX_Merge(src proto.Message)
- func (m *ObjectMeta) XXX_Size() int
- func (m *ObjectMeta) XXX_Unmarshal(b []byte) error
- type ObjectMeta_Type
- type PhysicalTime
- type PhysicalTimestamp
- func (*PhysicalTimestamp) Descriptor() ([]byte, []int)
- func (m *PhysicalTimestamp) GetTime() PhysicalTime
- func (m *PhysicalTimestamp) Marshal() (dAtA []byte, err error)
- func (m *PhysicalTimestamp) MarshalTo(dAtA []byte) (int, error)
- func (m *PhysicalTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PhysicalTimestamp) ProtoMessage()
- func (m *PhysicalTimestamp) Reset()
- func (m *PhysicalTimestamp) Size() (n int)
- func (m *PhysicalTimestamp) String() string
- func (m *PhysicalTimestamp) Unmarshal(dAtA []byte) error
- func (m *PhysicalTimestamp) XXX_DiscardUnknown()
- func (m *PhysicalTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PhysicalTimestamp) XXX_Merge(src proto.Message)
- func (m *PhysicalTimestamp) XXX_Size() int
- func (m *PhysicalTimestamp) XXX_Unmarshal(b []byte) error
- type Revision
- func (*Revision) Descriptor() ([]byte, []int)
- func (m *Revision) GetNum() RevisionNum
- func (m *Revision) Marshal() (dAtA []byte, err error)
- func (m *Revision) MarshalTo(dAtA []byte) (int, error)
- func (m *Revision) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Revision) ProtoMessage()
- func (m *Revision) Reset()
- func (m *Revision) Size() (n int)
- func (m *Revision) String() string
- func (m *Revision) Unmarshal(dAtA []byte) error
- func (m *Revision) XXX_DiscardUnknown()
- func (m *Revision) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Revision) XXX_Merge(src proto.Message)
- func (m *Revision) XXX_Size() int
- func (m *Revision) XXX_Unmarshal(b []byte) error
- type RevisionNum
- type Sequence
- func (*Sequence) Descriptor() ([]byte, []int)
- func (m *Sequence) GetNum() SequenceNum
- func (m *Sequence) Marshal() (dAtA []byte, err error)
- func (m *Sequence) MarshalTo(dAtA []byte) (int, error)
- func (m *Sequence) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Sequence) ProtoMessage()
- func (m *Sequence) Reset()
- func (m *Sequence) Size() (n int)
- func (m *Sequence) String() string
- func (m *Sequence) Unmarshal(dAtA []byte) error
- func (m *Sequence) XXX_DiscardUnknown()
- func (m *Sequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sequence) XXX_Merge(src proto.Message)
- func (m *Sequence) XXX_Size() int
- func (m *Sequence) XXX_Unmarshal(b []byte) error
- type SequenceNum
- type Timestamp
- func (*Timestamp) Descriptor() ([]byte, []int)
- func (m *Timestamp) GetCompositeTimestamp() *CompositeTimestamp
- func (m *Timestamp) GetEpochTimestamp() *EpochTimestamp
- func (m *Timestamp) GetLogicalTimestamp() *LogicalTimestamp
- func (m *Timestamp) GetPhysicalTimestamp() *PhysicalTimestamp
- func (m *Timestamp) GetTimestamp() isTimestamp_Timestamp
- func (m *Timestamp) GetVectorTimestamp() *VectorTimestamp
- func (m *Timestamp) Marshal() (dAtA []byte, err error)
- func (m *Timestamp) MarshalTo(dAtA []byte) (int, error)
- func (m *Timestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Timestamp) ProtoMessage()
- func (m *Timestamp) Reset()
- func (m *Timestamp) Size() (n int)
- func (m *Timestamp) String() string
- func (m *Timestamp) Unmarshal(dAtA []byte) error
- func (m *Timestamp) XXX_DiscardUnknown()
- func (m *Timestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Timestamp) XXX_Merge(src proto.Message)
- func (*Timestamp) XXX_OneofWrappers() []interface{}
- func (m *Timestamp) XXX_Size() int
- func (m *Timestamp) XXX_Unmarshal(b []byte) error
- type Timestamp_CompositeTimestamp
- type Timestamp_EpochTimestamp
- type Timestamp_LogicalTimestamp
- type Timestamp_PhysicalTimestamp
- type Timestamp_VectorTimestamp
- type VectorTimestamp
- func (*VectorTimestamp) Descriptor() ([]byte, []int)
- func (m *VectorTimestamp) GetTime() []LogicalTime
- func (m *VectorTimestamp) Marshal() (dAtA []byte, err error)
- func (m *VectorTimestamp) MarshalTo(dAtA []byte) (int, error)
- func (m *VectorTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VectorTimestamp) ProtoMessage()
- func (m *VectorTimestamp) Reset()
- func (m *VectorTimestamp) Size() (n int)
- func (m *VectorTimestamp) String() string
- func (m *VectorTimestamp) Unmarshal(dAtA []byte) error
- func (m *VectorTimestamp) XXX_DiscardUnknown()
- func (m *VectorTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VectorTimestamp) XXX_Merge(src proto.Message)
- func (m *VectorTimestamp) XXX_Size() int
- func (m *VectorTimestamp) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthObject = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowObject = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupObject = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthTimestamp = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTimestamp = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTimestamp = fmt.Errorf("proto: unexpected end of group") )
View Source
var ObjectMeta_Type_name = map[int32]string{
0: "OBJECT",
1: "TOMBSTONE",
}
View Source
var ObjectMeta_Type_value = map[string]int32{
"OBJECT": 0,
"TOMBSTONE": 1,
}
Functions ¶
This section is empty.
Types ¶
type CompositeTimestamp ¶
type CompositeTimestamp struct {
Timestamps []Timestamp `protobuf:"bytes,1,rep,name=timestamps,proto3" json:"timestamps"`
}
func (*CompositeTimestamp) Descriptor ¶
func (*CompositeTimestamp) Descriptor() ([]byte, []int)
func (*CompositeTimestamp) GetTimestamps ¶
func (m *CompositeTimestamp) GetTimestamps() []Timestamp
func (*CompositeTimestamp) Marshal ¶
func (m *CompositeTimestamp) Marshal() (dAtA []byte, err error)
func (*CompositeTimestamp) MarshalTo ¶
func (m *CompositeTimestamp) MarshalTo(dAtA []byte) (int, error)
func (*CompositeTimestamp) MarshalToSizedBuffer ¶
func (m *CompositeTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CompositeTimestamp) ProtoMessage ¶
func (*CompositeTimestamp) ProtoMessage()
func (*CompositeTimestamp) Reset ¶
func (m *CompositeTimestamp) Reset()
func (*CompositeTimestamp) Size ¶
func (m *CompositeTimestamp) Size() (n int)
func (*CompositeTimestamp) String ¶
func (m *CompositeTimestamp) String() string
func (*CompositeTimestamp) Unmarshal ¶
func (m *CompositeTimestamp) Unmarshal(dAtA []byte) error
func (*CompositeTimestamp) XXX_DiscardUnknown ¶
func (m *CompositeTimestamp) XXX_DiscardUnknown()
func (*CompositeTimestamp) XXX_Marshal ¶
func (m *CompositeTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CompositeTimestamp) XXX_Merge ¶
func (m *CompositeTimestamp) XXX_Merge(src proto.Message)
func (*CompositeTimestamp) XXX_Size ¶
func (m *CompositeTimestamp) XXX_Size() int
func (*CompositeTimestamp) XXX_Unmarshal ¶
func (m *CompositeTimestamp) XXX_Unmarshal(b []byte) error
type Epoch ¶
type Epoch struct {
Num EpochNum `protobuf:"varint,1,opt,name=num,proto3,casttype=EpochNum" json:"num,omitempty"`
}
func (*Epoch) Descriptor ¶
func (*Epoch) ProtoMessage ¶
func (*Epoch) ProtoMessage()
func (*Epoch) XXX_DiscardUnknown ¶
func (m *Epoch) XXX_DiscardUnknown()
func (*Epoch) XXX_Marshal ¶
func (*Epoch) XXX_Unmarshal ¶
type EpochTimestamp ¶
type EpochTimestamp struct { Epoch Epoch `protobuf:"bytes,1,opt,name=epoch,proto3" json:"epoch"` Sequence Sequence `protobuf:"bytes,2,opt,name=sequence,proto3" json:"sequence"` }
func (*EpochTimestamp) Descriptor ¶
func (*EpochTimestamp) Descriptor() ([]byte, []int)
func (*EpochTimestamp) GetEpoch ¶
func (m *EpochTimestamp) GetEpoch() Epoch
func (*EpochTimestamp) GetSequence ¶
func (m *EpochTimestamp) GetSequence() Sequence
func (*EpochTimestamp) Marshal ¶
func (m *EpochTimestamp) Marshal() (dAtA []byte, err error)
func (*EpochTimestamp) MarshalToSizedBuffer ¶
func (m *EpochTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EpochTimestamp) ProtoMessage ¶
func (*EpochTimestamp) ProtoMessage()
func (*EpochTimestamp) Reset ¶
func (m *EpochTimestamp) Reset()
func (*EpochTimestamp) Size ¶
func (m *EpochTimestamp) Size() (n int)
func (*EpochTimestamp) String ¶
func (m *EpochTimestamp) String() string
func (*EpochTimestamp) Unmarshal ¶
func (m *EpochTimestamp) Unmarshal(dAtA []byte) error
func (*EpochTimestamp) XXX_DiscardUnknown ¶
func (m *EpochTimestamp) XXX_DiscardUnknown()
func (*EpochTimestamp) XXX_Marshal ¶
func (m *EpochTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EpochTimestamp) XXX_Merge ¶
func (m *EpochTimestamp) XXX_Merge(src proto.Message)
func (*EpochTimestamp) XXX_Size ¶
func (m *EpochTimestamp) XXX_Size() int
func (*EpochTimestamp) XXX_Unmarshal ¶
func (m *EpochTimestamp) XXX_Unmarshal(b []byte) error
type LogicalTime ¶
type LogicalTime uint64
type LogicalTimestamp ¶
type LogicalTimestamp struct {
Time LogicalTime `protobuf:"varint,1,opt,name=time,proto3,casttype=LogicalTime" json:"time,omitempty"`
}
func (*LogicalTimestamp) Descriptor ¶
func (*LogicalTimestamp) Descriptor() ([]byte, []int)
func (*LogicalTimestamp) GetTime ¶
func (m *LogicalTimestamp) GetTime() LogicalTime
func (*LogicalTimestamp) Marshal ¶
func (m *LogicalTimestamp) Marshal() (dAtA []byte, err error)
func (*LogicalTimestamp) MarshalToSizedBuffer ¶
func (m *LogicalTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogicalTimestamp) ProtoMessage ¶
func (*LogicalTimestamp) ProtoMessage()
func (*LogicalTimestamp) Reset ¶
func (m *LogicalTimestamp) Reset()
func (*LogicalTimestamp) Size ¶
func (m *LogicalTimestamp) Size() (n int)
func (*LogicalTimestamp) String ¶
func (m *LogicalTimestamp) String() string
func (*LogicalTimestamp) Unmarshal ¶
func (m *LogicalTimestamp) Unmarshal(dAtA []byte) error
func (*LogicalTimestamp) XXX_DiscardUnknown ¶
func (m *LogicalTimestamp) XXX_DiscardUnknown()
func (*LogicalTimestamp) XXX_Marshal ¶
func (m *LogicalTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogicalTimestamp) XXX_Merge ¶
func (m *LogicalTimestamp) XXX_Merge(src proto.Message)
func (*LogicalTimestamp) XXX_Size ¶
func (m *LogicalTimestamp) XXX_Size() int
func (*LogicalTimestamp) XXX_Unmarshal ¶
func (m *LogicalTimestamp) XXX_Unmarshal(b []byte) error
type ObjectMeta ¶
type ObjectMeta struct { Revision *Revision `protobuf:"bytes,1,opt,name=revision,proto3" json:"revision,omitempty"` Timestamp *Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Type ObjectMeta_Type `protobuf:"varint,3,opt,name=type,proto3,enum=atomix.primitive.meta.v1.ObjectMeta_Type" json:"type,omitempty"` }
func (*ObjectMeta) Descriptor ¶
func (*ObjectMeta) Descriptor() ([]byte, []int)
func (*ObjectMeta) GetRevision ¶
func (m *ObjectMeta) GetRevision() *Revision
func (*ObjectMeta) GetTimestamp ¶
func (m *ObjectMeta) GetTimestamp() *Timestamp
func (*ObjectMeta) GetType ¶
func (m *ObjectMeta) GetType() ObjectMeta_Type
func (*ObjectMeta) Marshal ¶
func (m *ObjectMeta) Marshal() (dAtA []byte, err error)
func (*ObjectMeta) MarshalToSizedBuffer ¶
func (m *ObjectMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ObjectMeta) ProtoMessage ¶
func (*ObjectMeta) ProtoMessage()
func (*ObjectMeta) Reset ¶
func (m *ObjectMeta) Reset()
func (*ObjectMeta) Size ¶
func (m *ObjectMeta) Size() (n int)
func (*ObjectMeta) String ¶
func (m *ObjectMeta) String() string
func (*ObjectMeta) Unmarshal ¶
func (m *ObjectMeta) Unmarshal(dAtA []byte) error
func (*ObjectMeta) XXX_DiscardUnknown ¶
func (m *ObjectMeta) XXX_DiscardUnknown()
func (*ObjectMeta) XXX_Marshal ¶
func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectMeta) XXX_Merge ¶
func (m *ObjectMeta) XXX_Merge(src proto.Message)
func (*ObjectMeta) XXX_Size ¶
func (m *ObjectMeta) XXX_Size() int
func (*ObjectMeta) XXX_Unmarshal ¶
func (m *ObjectMeta) XXX_Unmarshal(b []byte) error
type ObjectMeta_Type ¶
type ObjectMeta_Type int32
const ( ObjectMeta_OBJECT ObjectMeta_Type = 0 ObjectMeta_TOMBSTONE ObjectMeta_Type = 1 )
func (ObjectMeta_Type) EnumDescriptor ¶
func (ObjectMeta_Type) EnumDescriptor() ([]byte, []int)
func (ObjectMeta_Type) String ¶
func (x ObjectMeta_Type) String() string
type PhysicalTime ¶
type PhysicalTimestamp ¶
type PhysicalTimestamp struct {
Time PhysicalTime `protobuf:"bytes,1,opt,name=time,proto3,casttype=PhysicalTime,stdtime" json:"time"`
}
func (*PhysicalTimestamp) Descriptor ¶
func (*PhysicalTimestamp) Descriptor() ([]byte, []int)
func (*PhysicalTimestamp) GetTime ¶
func (m *PhysicalTimestamp) GetTime() PhysicalTime
func (*PhysicalTimestamp) Marshal ¶
func (m *PhysicalTimestamp) Marshal() (dAtA []byte, err error)
func (*PhysicalTimestamp) MarshalTo ¶
func (m *PhysicalTimestamp) MarshalTo(dAtA []byte) (int, error)
func (*PhysicalTimestamp) MarshalToSizedBuffer ¶
func (m *PhysicalTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PhysicalTimestamp) ProtoMessage ¶
func (*PhysicalTimestamp) ProtoMessage()
func (*PhysicalTimestamp) Reset ¶
func (m *PhysicalTimestamp) Reset()
func (*PhysicalTimestamp) Size ¶
func (m *PhysicalTimestamp) Size() (n int)
func (*PhysicalTimestamp) String ¶
func (m *PhysicalTimestamp) String() string
func (*PhysicalTimestamp) Unmarshal ¶
func (m *PhysicalTimestamp) Unmarshal(dAtA []byte) error
func (*PhysicalTimestamp) XXX_DiscardUnknown ¶
func (m *PhysicalTimestamp) XXX_DiscardUnknown()
func (*PhysicalTimestamp) XXX_Marshal ¶
func (m *PhysicalTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PhysicalTimestamp) XXX_Merge ¶
func (m *PhysicalTimestamp) XXX_Merge(src proto.Message)
func (*PhysicalTimestamp) XXX_Size ¶
func (m *PhysicalTimestamp) XXX_Size() int
func (*PhysicalTimestamp) XXX_Unmarshal ¶
func (m *PhysicalTimestamp) XXX_Unmarshal(b []byte) error
type Revision ¶
type Revision struct {
Num RevisionNum `protobuf:"varint,1,opt,name=num,proto3,casttype=RevisionNum" json:"num,omitempty"`
}
func (*Revision) Descriptor ¶
func (*Revision) GetNum ¶
func (m *Revision) GetNum() RevisionNum
func (*Revision) MarshalToSizedBuffer ¶
func (*Revision) ProtoMessage ¶
func (*Revision) ProtoMessage()
func (*Revision) XXX_DiscardUnknown ¶
func (m *Revision) XXX_DiscardUnknown()
func (*Revision) XXX_Marshal ¶
func (*Revision) XXX_Unmarshal ¶
type RevisionNum ¶
type RevisionNum uint64
type Sequence ¶
type Sequence struct {
Num SequenceNum `protobuf:"varint,1,opt,name=num,proto3,casttype=SequenceNum" json:"num,omitempty"`
}
func (*Sequence) Descriptor ¶
func (*Sequence) GetNum ¶
func (m *Sequence) GetNum() SequenceNum
func (*Sequence) MarshalToSizedBuffer ¶
func (*Sequence) ProtoMessage ¶
func (*Sequence) ProtoMessage()
func (*Sequence) XXX_DiscardUnknown ¶
func (m *Sequence) XXX_DiscardUnknown()
func (*Sequence) XXX_Marshal ¶
func (*Sequence) XXX_Unmarshal ¶
type SequenceNum ¶
type SequenceNum uint64
type Timestamp ¶
type Timestamp struct { // Types that are valid to be assigned to Timestamp: // *Timestamp_PhysicalTimestamp // *Timestamp_LogicalTimestamp // *Timestamp_VectorTimestamp // *Timestamp_EpochTimestamp // *Timestamp_CompositeTimestamp Timestamp isTimestamp_Timestamp `protobuf_oneof:"timestamp"` }
func (*Timestamp) Descriptor ¶
func (*Timestamp) GetCompositeTimestamp ¶
func (m *Timestamp) GetCompositeTimestamp() *CompositeTimestamp
func (*Timestamp) GetEpochTimestamp ¶
func (m *Timestamp) GetEpochTimestamp() *EpochTimestamp
func (*Timestamp) GetLogicalTimestamp ¶
func (m *Timestamp) GetLogicalTimestamp() *LogicalTimestamp
func (*Timestamp) GetPhysicalTimestamp ¶
func (m *Timestamp) GetPhysicalTimestamp() *PhysicalTimestamp
func (*Timestamp) GetTimestamp ¶
func (m *Timestamp) GetTimestamp() isTimestamp_Timestamp
func (*Timestamp) GetVectorTimestamp ¶
func (m *Timestamp) GetVectorTimestamp() *VectorTimestamp
func (*Timestamp) MarshalToSizedBuffer ¶
func (*Timestamp) ProtoMessage ¶
func (*Timestamp) ProtoMessage()
func (*Timestamp) XXX_DiscardUnknown ¶
func (m *Timestamp) XXX_DiscardUnknown()
func (*Timestamp) XXX_Marshal ¶
func (*Timestamp) XXX_OneofWrappers ¶
func (*Timestamp) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Timestamp) XXX_Unmarshal ¶
type Timestamp_CompositeTimestamp ¶
type Timestamp_CompositeTimestamp struct {
CompositeTimestamp *CompositeTimestamp `protobuf:"bytes,5,opt,name=composite_timestamp,json=compositeTimestamp,proto3,oneof" json:"composite_timestamp,omitempty"`
}
func (*Timestamp_CompositeTimestamp) MarshalTo ¶
func (m *Timestamp_CompositeTimestamp) MarshalTo(dAtA []byte) (int, error)
func (*Timestamp_CompositeTimestamp) MarshalToSizedBuffer ¶
func (m *Timestamp_CompositeTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Timestamp_CompositeTimestamp) Size ¶
func (m *Timestamp_CompositeTimestamp) Size() (n int)
type Timestamp_EpochTimestamp ¶
type Timestamp_EpochTimestamp struct {
EpochTimestamp *EpochTimestamp `protobuf:"bytes,4,opt,name=epoch_timestamp,json=epochTimestamp,proto3,oneof" json:"epoch_timestamp,omitempty"`
}
func (*Timestamp_EpochTimestamp) MarshalTo ¶
func (m *Timestamp_EpochTimestamp) MarshalTo(dAtA []byte) (int, error)
func (*Timestamp_EpochTimestamp) MarshalToSizedBuffer ¶
func (m *Timestamp_EpochTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Timestamp_EpochTimestamp) Size ¶
func (m *Timestamp_EpochTimestamp) Size() (n int)
type Timestamp_LogicalTimestamp ¶
type Timestamp_LogicalTimestamp struct {
LogicalTimestamp *LogicalTimestamp `protobuf:"bytes,2,opt,name=logical_timestamp,json=logicalTimestamp,proto3,oneof" json:"logical_timestamp,omitempty"`
}
func (*Timestamp_LogicalTimestamp) MarshalTo ¶
func (m *Timestamp_LogicalTimestamp) MarshalTo(dAtA []byte) (int, error)
func (*Timestamp_LogicalTimestamp) MarshalToSizedBuffer ¶
func (m *Timestamp_LogicalTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Timestamp_LogicalTimestamp) Size ¶
func (m *Timestamp_LogicalTimestamp) Size() (n int)
type Timestamp_PhysicalTimestamp ¶
type Timestamp_PhysicalTimestamp struct {
PhysicalTimestamp *PhysicalTimestamp `protobuf:"bytes,1,opt,name=physical_timestamp,json=physicalTimestamp,proto3,oneof" json:"physical_timestamp,omitempty"`
}
func (*Timestamp_PhysicalTimestamp) MarshalTo ¶
func (m *Timestamp_PhysicalTimestamp) MarshalTo(dAtA []byte) (int, error)
func (*Timestamp_PhysicalTimestamp) MarshalToSizedBuffer ¶
func (m *Timestamp_PhysicalTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Timestamp_PhysicalTimestamp) Size ¶
func (m *Timestamp_PhysicalTimestamp) Size() (n int)
type Timestamp_VectorTimestamp ¶
type Timestamp_VectorTimestamp struct {
VectorTimestamp *VectorTimestamp `protobuf:"bytes,3,opt,name=vector_timestamp,json=vectorTimestamp,proto3,oneof" json:"vector_timestamp,omitempty"`
}
func (*Timestamp_VectorTimestamp) MarshalTo ¶
func (m *Timestamp_VectorTimestamp) MarshalTo(dAtA []byte) (int, error)
func (*Timestamp_VectorTimestamp) MarshalToSizedBuffer ¶
func (m *Timestamp_VectorTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Timestamp_VectorTimestamp) Size ¶
func (m *Timestamp_VectorTimestamp) Size() (n int)
type VectorTimestamp ¶
type VectorTimestamp struct {
Time []LogicalTime `protobuf:"varint,1,rep,packed,name=time,proto3,casttype=LogicalTime" json:"time,omitempty"`
}
func (*VectorTimestamp) Descriptor ¶
func (*VectorTimestamp) Descriptor() ([]byte, []int)
func (*VectorTimestamp) GetTime ¶
func (m *VectorTimestamp) GetTime() []LogicalTime
func (*VectorTimestamp) Marshal ¶
func (m *VectorTimestamp) Marshal() (dAtA []byte, err error)
func (*VectorTimestamp) MarshalToSizedBuffer ¶
func (m *VectorTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VectorTimestamp) ProtoMessage ¶
func (*VectorTimestamp) ProtoMessage()
func (*VectorTimestamp) Reset ¶
func (m *VectorTimestamp) Reset()
func (*VectorTimestamp) Size ¶
func (m *VectorTimestamp) Size() (n int)
func (*VectorTimestamp) String ¶
func (m *VectorTimestamp) String() string
func (*VectorTimestamp) Unmarshal ¶
func (m *VectorTimestamp) Unmarshal(dAtA []byte) error
func (*VectorTimestamp) XXX_DiscardUnknown ¶
func (m *VectorTimestamp) XXX_DiscardUnknown()
func (*VectorTimestamp) XXX_Marshal ¶
func (m *VectorTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VectorTimestamp) XXX_Merge ¶
func (m *VectorTimestamp) XXX_Merge(src proto.Message)
func (*VectorTimestamp) XXX_Size ¶
func (m *VectorTimestamp) XXX_Size() int
func (*VectorTimestamp) XXX_Unmarshal ¶
func (m *VectorTimestamp) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.