cluster

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ClusterMember 

type ClusterMember struct {
	Role             v11.ClusterMemberRole `protobuf:"varint,1,opt,name=role,proto3,enum=temporal.api.enums.v1.ClusterMemberRole" json:"role,omitempty"`
	HostId           string                `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	RpcAddress       string                `protobuf:"bytes,3,opt,name=rpc_address,json=rpcAddress,proto3" json:"rpc_address,omitempty"`
	RpcPort          int32                 `protobuf:"varint,4,opt,name=rpc_port,json=rpcPort,proto3" json:"rpc_port,omitempty"`
	SessionStartTime *time.Time            `protobuf:"bytes,5,opt,name=session_start_time,json=sessionStartTime,proto3,stdtime" json:"session_start_time,omitempty"`
	LastHeartbitTime *time.Time            `protobuf:"bytes,6,opt,name=last_heartbit_time,json=lastHeartbitTime,proto3,stdtime" json:"last_heartbit_time,omitempty"`
	RecordExpiryTime *time.Time            `protobuf:"bytes,7,opt,name=record_expiry_time,json=recordExpiryTime,proto3,stdtime" json:"record_expiry_time,omitempty"`
}

func (*ClusterMember) Descriptor 

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

func (*ClusterMember) Equal 

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

func (*ClusterMember) GetHostId 

func (m *ClusterMember) GetHostId() string

func (*ClusterMember) GetLastHeartbitTime 

func (m *ClusterMember) GetLastHeartbitTime() *time.Time

func (*ClusterMember) GetRecordExpiryTime 

func (m *ClusterMember) GetRecordExpiryTime() *time.Time

func (*ClusterMember) GetRole 

func (m *ClusterMember) GetRole() v11.ClusterMemberRole

func (*ClusterMember) GetRpcAddress 

func (m *ClusterMember) GetRpcAddress() string

func (*ClusterMember) GetRpcPort 

func (m *ClusterMember) GetRpcPort() int32

func (*ClusterMember) GetSessionStartTime 

func (m *ClusterMember) GetSessionStartTime() *time.Time

func (*ClusterMember) GoString 

func (this *ClusterMember) GoString() string

func (*ClusterMember) Marshal 

func (m *ClusterMember) Marshal() (dAtA []byte, err error)

func (*ClusterMember) MarshalTo 

func (m *ClusterMember) MarshalTo(dAtA []byte) (int, error)

func (*ClusterMember) MarshalToSizedBuffer 

func (m *ClusterMember) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterMember) ProtoMessage 

func (*ClusterMember) ProtoMessage()

func (*ClusterMember) Reset 

func (m *ClusterMember) Reset()

func (*ClusterMember) Size 

func (m *ClusterMember) Size() (n int)

func (*ClusterMember) String 

func (this *ClusterMember) String() string

func (*ClusterMember) Unmarshal 

func (m *ClusterMember) Unmarshal(dAtA []byte) error

func (*ClusterMember) XXX_DiscardUnknown 

func (m *ClusterMember) XXX_DiscardUnknown()

func (*ClusterMember) XXX_Marshal 

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

func (*ClusterMember) XXX_Merge 

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

func (*ClusterMember) XXX_Size 

func (m *ClusterMember) XXX_Size() int

func (*ClusterMember) XXX_Unmarshal 

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

type ClusterMetadata 

type ClusterMetadata struct {
	Cluster                  string                            `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	HistoryShardCount        int32                             `protobuf:"varint,2,opt,name=history_shard_count,json=historyShardCount,proto3" json:"history_shard_count,omitempty"`
	ClusterId                string                            `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	VersionInfo              *v1.VersionInfo                   `protobuf:"bytes,4,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	IndexSearchAttributes    map[string]*IndexSearchAttributes `` /* 214-byte string literal not displayed */
	ClusterAddress           string                            `protobuf:"bytes,6,opt,name=cluster_address,json=clusterAddress,proto3" json:"cluster_address,omitempty"`
	FailoverVersionIncrement int64                             `` /* 136-byte string literal not displayed */
	InitialFailoverVersion   int64                             `` /* 130-byte string literal not displayed */
	IsGlobalNamespaceEnabled bool                              `` /* 138-byte string literal not displayed */
	IsConnectionEnabled      bool                              `protobuf:"varint,10,opt,name=is_connection_enabled,json=isConnectionEnabled,proto3" json:"is_connection_enabled,omitempty"`
}

data column

func (*ClusterMetadata) Descriptor 

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

func (*ClusterMetadata) Equal 

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

func (*ClusterMetadata) GetCluster 

func (m *ClusterMetadata) GetCluster() string

func (*ClusterMetadata) GetClusterAddress 

func (m *ClusterMetadata) GetClusterAddress() string

func (*ClusterMetadata) GetClusterId 

func (m *ClusterMetadata) GetClusterId() string

func (*ClusterMetadata) GetFailoverVersionIncrement 

func (m *ClusterMetadata) GetFailoverVersionIncrement() int64

func (*ClusterMetadata) GetHistoryShardCount 

func (m *ClusterMetadata) GetHistoryShardCount() int32

func (*ClusterMetadata) GetIndexSearchAttributes 

func (m *ClusterMetadata) GetIndexSearchAttributes() map[string]*IndexSearchAttributes

func (*ClusterMetadata) GetInitialFailoverVersion 

func (m *ClusterMetadata) GetInitialFailoverVersion() int64

func (*ClusterMetadata) GetIsConnectionEnabled 

func (m *ClusterMetadata) GetIsConnectionEnabled() bool

func (*ClusterMetadata) GetIsGlobalNamespaceEnabled 

func (m *ClusterMetadata) GetIsGlobalNamespaceEnabled() bool

func (*ClusterMetadata) GetVersionInfo 

func (m *ClusterMetadata) GetVersionInfo() *v1.VersionInfo

func (*ClusterMetadata) GoString 

func (this *ClusterMetadata) GoString() string

func (*ClusterMetadata) Marshal 

func (m *ClusterMetadata) Marshal() (dAtA []byte, err error)

func (*ClusterMetadata) MarshalTo 

func (m *ClusterMetadata) MarshalTo(dAtA []byte) (int, error)

func (*ClusterMetadata) MarshalToSizedBuffer 

func (m *ClusterMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterMetadata) ProtoMessage 

func (*ClusterMetadata) ProtoMessage()

func (*ClusterMetadata) Reset 

func (m *ClusterMetadata) Reset()

func (*ClusterMetadata) Size 

func (m *ClusterMetadata) Size() (n int)

func (*ClusterMetadata) String 

func (this *ClusterMetadata) String() string

func (*ClusterMetadata) Unmarshal 

func (m *ClusterMetadata) Unmarshal(dAtA []byte) error

func (*ClusterMetadata) XXX_DiscardUnknown 

func (m *ClusterMetadata) XXX_DiscardUnknown()

func (*ClusterMetadata) XXX_Marshal 

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

func (*ClusterMetadata) XXX_Merge 

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

func (*ClusterMetadata) XXX_Size 

func (m *ClusterMetadata) XXX_Size() int

func (*ClusterMetadata) XXX_Unmarshal 

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

type HostInfo 

type HostInfo struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*HostInfo) Descriptor 

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

func (*HostInfo) Equal 

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

func (*HostInfo) GetIdentity 

func (m *HostInfo) GetIdentity() string

func (*HostInfo) GoString 

func (this *HostInfo) GoString() string

func (*HostInfo) Marshal 

func (m *HostInfo) Marshal() (dAtA []byte, err error)

func (*HostInfo) MarshalTo 

func (m *HostInfo) MarshalTo(dAtA []byte) (int, error)

func (*HostInfo) MarshalToSizedBuffer 

func (m *HostInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HostInfo) ProtoMessage 

func (*HostInfo) ProtoMessage()

func (*HostInfo) Reset 

func (m *HostInfo) Reset()

func (*HostInfo) Size 

func (m *HostInfo) Size() (n int)

func (*HostInfo) String 

func (this *HostInfo) String() string

func (*HostInfo) Unmarshal 

func (m *HostInfo) Unmarshal(dAtA []byte) error

func (*HostInfo) XXX_DiscardUnknown 

func (m *HostInfo) XXX_DiscardUnknown()

func (*HostInfo) XXX_Marshal 

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

func (*HostInfo) XXX_Merge 

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

func (*HostInfo) XXX_Size 

func (m *HostInfo) XXX_Size() int

func (*HostInfo) XXX_Unmarshal 

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

type IndexSearchAttributes 

type IndexSearchAttributes struct {
	CustomSearchAttributes map[string]v11.IndexedValueType `` /* 262-byte string literal not displayed */
}

func (*IndexSearchAttributes) Descriptor 

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

func (*IndexSearchAttributes) Equal 

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

func (*IndexSearchAttributes) GetCustomSearchAttributes 

func (m *IndexSearchAttributes) GetCustomSearchAttributes() map[string]v11.IndexedValueType

func (*IndexSearchAttributes) GoString 

func (this *IndexSearchAttributes) GoString() string

func (*IndexSearchAttributes) Marshal 

func (m *IndexSearchAttributes) Marshal() (dAtA []byte, err error)

func (*IndexSearchAttributes) MarshalTo 

func (m *IndexSearchAttributes) MarshalTo(dAtA []byte) (int, error)

func (*IndexSearchAttributes) MarshalToSizedBuffer 

func (m *IndexSearchAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IndexSearchAttributes) ProtoMessage 

func (*IndexSearchAttributes) ProtoMessage()

func (*IndexSearchAttributes) Reset 

func (m *IndexSearchAttributes) Reset()

func (*IndexSearchAttributes) Size 

func (m *IndexSearchAttributes) Size() (n int)

func (*IndexSearchAttributes) String 

func (this *IndexSearchAttributes) String() string

func (*IndexSearchAttributes) Unmarshal 

func (m *IndexSearchAttributes) Unmarshal(dAtA []byte) error

func (*IndexSearchAttributes) XXX_DiscardUnknown 

func (m *IndexSearchAttributes) XXX_DiscardUnknown()

func (*IndexSearchAttributes) XXX_Marshal 

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

func (*IndexSearchAttributes) XXX_Merge 

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

func (*IndexSearchAttributes) XXX_Size 

func (m *IndexSearchAttributes) XXX_Size() int

func (*IndexSearchAttributes) XXX_Unmarshal 

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

type MembershipInfo 

type MembershipInfo struct {
	CurrentHost      *HostInfo   `protobuf:"bytes,1,opt,name=current_host,json=currentHost,proto3" json:"current_host,omitempty"`
	ReachableMembers []string    `protobuf:"bytes,2,rep,name=reachable_members,json=reachableMembers,proto3" json:"reachable_members,omitempty"`
	Rings            []*RingInfo `protobuf:"bytes,3,rep,name=rings,proto3" json:"rings,omitempty"`
}

func (*MembershipInfo) Descriptor 

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

func (*MembershipInfo) Equal 

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

func (*MembershipInfo) GetCurrentHost 

func (m *MembershipInfo) GetCurrentHost() *HostInfo

func (*MembershipInfo) GetReachableMembers 

func (m *MembershipInfo) GetReachableMembers() []string

func (*MembershipInfo) GetRings 

func (m *MembershipInfo) GetRings() []*RingInfo

func (*MembershipInfo) GoString 

func (this *MembershipInfo) GoString() string

func (*MembershipInfo) Marshal 

func (m *MembershipInfo) Marshal() (dAtA []byte, err error)

func (*MembershipInfo) MarshalTo 

func (m *MembershipInfo) MarshalTo(dAtA []byte) (int, error)

func (*MembershipInfo) MarshalToSizedBuffer 

func (m *MembershipInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MembershipInfo) ProtoMessage 

func (*MembershipInfo) ProtoMessage()

func (*MembershipInfo) Reset 

func (m *MembershipInfo) Reset()

func (*MembershipInfo) Size 

func (m *MembershipInfo) Size() (n int)

func (*MembershipInfo) String 

func (this *MembershipInfo) String() string

func (*MembershipInfo) Unmarshal 

func (m *MembershipInfo) Unmarshal(dAtA []byte) error

func (*MembershipInfo) XXX_DiscardUnknown 

func (m *MembershipInfo) XXX_DiscardUnknown()

func (*MembershipInfo) XXX_Marshal 

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

func (*MembershipInfo) XXX_Merge 

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

func (*MembershipInfo) XXX_Size 

func (m *MembershipInfo) XXX_Size() int

func (*MembershipInfo) XXX_Unmarshal 

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

type RingInfo 

type RingInfo struct {
	Role        string      `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	MemberCount int32       `protobuf:"varint,2,opt,name=member_count,json=memberCount,proto3" json:"member_count,omitempty"`
	Members     []*HostInfo `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
}

func (*RingInfo) Descriptor 

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

func (*RingInfo) Equal 

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

func (*RingInfo) GetMemberCount 

func (m *RingInfo) GetMemberCount() int32

func (*RingInfo) GetMembers 

func (m *RingInfo) GetMembers() []*HostInfo

func (*RingInfo) GetRole 

func (m *RingInfo) GetRole() string

func (*RingInfo) GoString 

func (this *RingInfo) GoString() string

func (*RingInfo) Marshal 

func (m *RingInfo) Marshal() (dAtA []byte, err error)

func (*RingInfo) MarshalTo 

func (m *RingInfo) MarshalTo(dAtA []byte) (int, error)

func (*RingInfo) MarshalToSizedBuffer 

func (m *RingInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RingInfo) ProtoMessage 

func (*RingInfo) ProtoMessage()

func (*RingInfo) Reset 

func (m *RingInfo) Reset()

func (*RingInfo) Size 

func (m *RingInfo) Size() (n int)

func (*RingInfo) String 

func (this *RingInfo) String() string

func (*RingInfo) Unmarshal 

func (m *RingInfo) Unmarshal(dAtA []byte) error

func (*RingInfo) XXX_DiscardUnknown 

func (m *RingInfo) XXX_DiscardUnknown()

func (*RingInfo) XXX_Marshal 

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

func (*RingInfo) XXX_Merge 

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

func (*RingInfo) XXX_Size 

func (m *RingInfo) XXX_Size() int

func (*RingInfo) XXX_Unmarshal 

func (m *RingInfo) 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.