cluster

package
v1.22.1 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2023 License: MIT Imports: 11 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 added in v1.14.0 

type ClusterMember struct {
	Role             v1.ClusterMemberRole `protobuf:"varint,1,opt,name=role,proto3,enum=temporal.server.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 added in v1.14.0 

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

func (*ClusterMember) Equal added in v1.14.0 

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

func (*ClusterMember) GetHostId added in v1.14.0 

func (m *ClusterMember) GetHostId() string

func (*ClusterMember) GetLastHeartbitTime added in v1.14.0 

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

func (*ClusterMember) GetRecordExpiryTime added in v1.14.0 

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

func (*ClusterMember) GetRole added in v1.14.0 

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

func (*ClusterMember) GetRpcAddress added in v1.14.0 

func (m *ClusterMember) GetRpcAddress() string

func (*ClusterMember) GetRpcPort added in v1.14.0 

func (m *ClusterMember) GetRpcPort() int32

func (*ClusterMember) GetSessionStartTime added in v1.14.0 

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

func (*ClusterMember) GoString added in v1.14.0 

func (this *ClusterMember) GoString() string

func (*ClusterMember) Marshal added in v1.14.0 

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

func (*ClusterMember) MarshalTo added in v1.14.0 

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

func (*ClusterMember) MarshalToSizedBuffer added in v1.14.0 

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

func (*ClusterMember) ProtoMessage added in v1.14.0 

func (*ClusterMember) ProtoMessage()

func (*ClusterMember) Reset added in v1.14.0 

func (m *ClusterMember) Reset()

func (*ClusterMember) Size added in v1.14.0 

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

func (*ClusterMember) String added in v1.14.0 

func (this *ClusterMember) String() string

func (*ClusterMember) Unmarshal added in v1.14.0 

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

func (*ClusterMember) XXX_DiscardUnknown added in v1.14.0 

func (m *ClusterMember) XXX_DiscardUnknown()

func (*ClusterMember) XXX_Marshal added in v1.14.0 

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

func (*ClusterMember) XXX_Merge added in v1.14.0 

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

func (*ClusterMember) XXX_Size added in v1.14.0 

func (m *ClusterMember) XXX_Size() int

func (*ClusterMember) XXX_Unmarshal added in v1.14.0 

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