clock

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

• Variables
• type HybridLogicalClock
  • func (*HybridLogicalClock) Descriptor() ([]byte, []int)
  • func (this *HybridLogicalClock) Equal(that interface{}) bool
  • func (x *HybridLogicalClock) GetClusterId() int64
  • func (x *HybridLogicalClock) GetVersion() int32
  • func (x *HybridLogicalClock) GetWallClock() int64
  • func (val *HybridLogicalClock) Marshal() ([]byte, error)
  • func (*HybridLogicalClock) ProtoMessage()
  • func (x *HybridLogicalClock) ProtoReflect() protoreflect.Message
  • func (x *HybridLogicalClock) Reset()
  • func (val *HybridLogicalClock) Size() int
  • func (x *HybridLogicalClock) String() string
  • func (val *HybridLogicalClock) Unmarshal(buf []byte) error
• type VectorClock
  • func (*VectorClock) Descriptor() ([]byte, []int)
  • func (this *VectorClock) Equal(that interface{}) bool
  • func (x *VectorClock) GetClock() int64
  • func (x *VectorClock) GetClusterId() int64
  • func (x *VectorClock) GetShardId() int32
  • func (val *VectorClock) Marshal() ([]byte, error)
  • func (*VectorClock) ProtoMessage()
  • func (x *VectorClock) ProtoReflect() protoreflect.Message
  • func (x *VectorClock) Reset()
  • func (val *VectorClock) Size() int
  • func (x *VectorClock) String() string
  • func (val *VectorClock) Unmarshal(buf []byte) error

Variables

var File_temporal_server_api_clock_v1_message_proto protoreflect.FileDescriptor

Types

type HybridLogicalClock

type HybridLogicalClock struct {

	// Wall clock - A single time source MUST guarantee that 2 consecutive timestamps are monotonically non-decreasing.
	// e.g. by storing the last wall clock and returning max(gettimeofday(), lastWallClock).
	WallClock int64 `protobuf:"varint,1,opt,name=wall_clock,json=wallClock,proto3" json:"wall_clock,omitempty"`
	// Incremental sequence that is reset every time the system's wallclock moves forward.
	// Ensures the clock generates monotonically increasing timestamps.
	Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// The cluster version ID as described in the XDC docs - used as a tie breaker.
	// See: https://github.com/uber/cadence/blob/master/docs/design/2290-cadence-ndc.md
	ClusterId int64 `protobuf:"varint,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

A Hybrid Logical Clock timestamp. Guarantees strict total ordering for conflict resolution purposes.

func (*HybridLogicalClock) Descriptor

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

Deprecated: Use HybridLogicalClock.ProtoReflect.Descriptor instead.

func (*HybridLogicalClock) Equal

func (this *HybridLogicalClock) Equal(that interface{}) bool

Equal returns whether two HybridLogicalClock values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*HybridLogicalClock) GetClusterId

func (x *HybridLogicalClock) GetClusterId() int64

func (*HybridLogicalClock) GetVersion

func (x *HybridLogicalClock) GetVersion() int32

func (*HybridLogicalClock) GetWallClock

func (x *HybridLogicalClock) GetWallClock() int64

func (*HybridLogicalClock) Marshal

func (val *HybridLogicalClock) Marshal() ([]byte, error)

Marshal an object of type HybridLogicalClock to the protobuf v3 wire format

func (*HybridLogicalClock) ProtoMessage

func (*HybridLogicalClock) ProtoMessage()

func (*HybridLogicalClock) ProtoReflect

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

func (*HybridLogicalClock) Reset

func (x *HybridLogicalClock) Reset()

func (*HybridLogicalClock) Size

func (val *HybridLogicalClock) Size() int

Size returns the size of the object, in bytes, once serialized

func (*HybridLogicalClock) String

func (x *HybridLogicalClock) String() string

func (*HybridLogicalClock) Unmarshal

func (val *HybridLogicalClock) Unmarshal(buf []byte) error

Unmarshal an object of type HybridLogicalClock from the protobuf v3 wire format

type VectorClock

type VectorClock struct {
	ShardId   int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Clock     int64 `protobuf:"varint,2,opt,name=clock,proto3" json:"clock,omitempty"`
	ClusterId int64 `protobuf:"varint,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VectorClock) Descriptor

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

Deprecated: Use VectorClock.ProtoReflect.Descriptor instead.

func (*VectorClock) Equal

func (this *VectorClock) Equal(that interface{}) bool

Equal returns whether two VectorClock values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*VectorClock) GetClock

func (x *VectorClock) GetClock() int64

func (*VectorClock) GetClusterId

func (x *VectorClock) GetClusterId() int64

func (*VectorClock) GetShardId

func (x *VectorClock) GetShardId() int32

func (*VectorClock) Marshal

func (val *VectorClock) Marshal() ([]byte, error)

Marshal an object of type VectorClock to the protobuf v3 wire format

func (*VectorClock) ProtoMessage

func (*VectorClock) ProtoMessage()

func (*VectorClock) ProtoReflect

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

func (*VectorClock) Reset

func (x *VectorClock) Reset()

func (*VectorClock) Size

func (val *VectorClock) Size() int

Size returns the size of the object, in bytes, once serialized

func (*VectorClock) String

func (x *VectorClock) String() string

func (*VectorClock) Unmarshal

func (val *VectorClock) Unmarshal(buf []byte) error

Unmarshal an object of type VectorClock from the protobuf v3 wire format