operatorservice

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2022 License: MIT Imports: 20 Imported by: 26

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterOperatorServiceServer 

func RegisterOperatorServiceServer(s *grpc.Server, srv OperatorServiceServer)

Types

type AddOrUpdateRemoteClusterRequest added in v1.9.0 

type AddOrUpdateRemoteClusterRequest struct {
	FrontendAddress               string `protobuf:"bytes,1,opt,name=frontend_address,json=frontendAddress,proto3" json:"frontend_address,omitempty"`
	EnableRemoteClusterConnection bool   `` /* 153-byte string literal not displayed */
}

func (*AddOrUpdateRemoteClusterRequest) Descriptor added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) Equal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

func (*AddOrUpdateRemoteClusterRequest) GetFrontendAddress added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

func (*AddOrUpdateRemoteClusterRequest) GoString added in v1.9.0 

func (this *AddOrUpdateRemoteClusterRequest) GoString() string

func (*AddOrUpdateRemoteClusterRequest) Marshal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) MarshalTo added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) MarshalToSizedBuffer added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage added in v1.9.0 

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

func (*AddOrUpdateRemoteClusterRequest) Reset added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) Reset()

func (*AddOrUpdateRemoteClusterRequest) Size added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) String added in v1.9.0 

func (this *AddOrUpdateRemoteClusterRequest) String() string

func (*AddOrUpdateRemoteClusterRequest) Unmarshal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown()

func (*AddOrUpdateRemoteClusterRequest) XXX_Marshal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) XXX_Merge added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterRequest) XXX_Size added in v1.9.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_Size() int

func (*AddOrUpdateRemoteClusterRequest) XXX_Unmarshal added in v1.9.0 

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

type AddOrUpdateRemoteClusterResponse added in v1.9.0 

type AddOrUpdateRemoteClusterResponse struct {
}

func (*AddOrUpdateRemoteClusterResponse) Descriptor added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) Equal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) GoString added in v1.9.0 

func (this *AddOrUpdateRemoteClusterResponse) GoString() string

func (*AddOrUpdateRemoteClusterResponse) Marshal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) MarshalTo added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) MarshalToSizedBuffer added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage added in v1.9.0 

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

func (*AddOrUpdateRemoteClusterResponse) Reset added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) Reset()

func (*AddOrUpdateRemoteClusterResponse) Size added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) String added in v1.9.0 

func (this *AddOrUpdateRemoteClusterResponse) String() string

func (*AddOrUpdateRemoteClusterResponse) Unmarshal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown()

func (*AddOrUpdateRemoteClusterResponse) XXX_Marshal added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) XXX_Merge added in v1.9.0 

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

func (*AddOrUpdateRemoteClusterResponse) XXX_Size added in v1.9.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_Size() int

func (*AddOrUpdateRemoteClusterResponse) XXX_Unmarshal added in v1.9.0 

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

type AddSearchAttributesRequest 

type AddSearchAttributesRequest struct {
	// Mapping between search attribute name and its IndexedValueType.
	SearchAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
}

func (*AddSearchAttributesRequest) Descriptor 

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

func (*AddSearchAttributesRequest) Equal 

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

func (*AddSearchAttributesRequest) GetSearchAttributes 

func (m *AddSearchAttributesRequest) GetSearchAttributes() map[string]v1.IndexedValueType

func (*AddSearchAttributesRequest) GoString 

func (this *AddSearchAttributesRequest) GoString() string

func (*AddSearchAttributesRequest) Marshal 

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

func (*AddSearchAttributesRequest) MarshalTo 

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

func (*AddSearchAttributesRequest) MarshalToSizedBuffer 

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

func (*AddSearchAttributesRequest) ProtoMessage 

func (*AddSearchAttributesRequest) ProtoMessage()

func (*AddSearchAttributesRequest) Reset 

func (m *AddSearchAttributesRequest) Reset()

func (*AddSearchAttributesRequest) Size 

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

func (*AddSearchAttributesRequest) String 

func (this *AddSearchAttributesRequest) String() string

func (*AddSearchAttributesRequest) Unmarshal 

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

func (*AddSearchAttributesRequest) XXX_DiscardUnknown 

func (m *AddSearchAttributesRequest) XXX_DiscardUnknown()

func (*AddSearchAttributesRequest) XXX_Marshal 

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

func (*AddSearchAttributesRequest) XXX_Merge 

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

func (*AddSearchAttributesRequest) XXX_Size 

func (m *AddSearchAttributesRequest) XXX_Size() int

func (*AddSearchAttributesRequest) XXX_Unmarshal 

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

type AddSearchAttributesResponse 

type AddSearchAttributesResponse struct {
}

func (*AddSearchAttributesResponse) Descriptor 

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

func (*AddSearchAttributesResponse) Equal 

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

func (*AddSearchAttributesResponse) GoString 

func (this *AddSearchAttributesResponse) GoString() string

func (*AddSearchAttributesResponse) Marshal 

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

func (*AddSearchAttributesResponse) MarshalTo 

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

func (*AddSearchAttributesResponse) MarshalToSizedBuffer 

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

func (*AddSearchAttributesResponse) ProtoMessage 

func (*AddSearchAttributesResponse) ProtoMessage()

func (*AddSearchAttributesResponse) Reset 

func (m *AddSearchAttributesResponse) Reset()

func (*AddSearchAttributesResponse) Size 

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

func (*AddSearchAttributesResponse) String 

func (this *AddSearchAttributesResponse) String() string

func (*AddSearchAttributesResponse) Unmarshal 

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

func (*AddSearchAttributesResponse) XXX_DiscardUnknown 

func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()

func (*AddSearchAttributesResponse) XXX_Marshal 

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

func (*AddSearchAttributesResponse) XXX_Merge 

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

func (*AddSearchAttributesResponse) XXX_Size 

func (m *AddSearchAttributesResponse) XXX_Size() int

func (*AddSearchAttributesResponse) XXX_Unmarshal 

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

type DeleteNamespaceRequest 

type DeleteNamespaceRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

(-- api-linter: core::0135::request-unknown-fields=disabled 

aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)

(-- api-linter: core::0135::request-name-required=disabled 

aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)

func (*DeleteNamespaceRequest) Descriptor 

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

func (*DeleteNamespaceRequest) Equal 

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

func (*DeleteNamespaceRequest) GetNamespace 

func (m *DeleteNamespaceRequest) GetNamespace() string

func (*DeleteNamespaceRequest) GoString 

func (this *DeleteNamespaceRequest) GoString() string

func (*DeleteNamespaceRequest) Marshal 

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

func (*DeleteNamespaceRequest) MarshalTo 

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

func (*DeleteNamespaceRequest) MarshalToSizedBuffer 

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

func (*DeleteNamespaceRequest) ProtoMessage 

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) Reset 

func (m *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) Size 

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

func (*DeleteNamespaceRequest) String 

func (this *DeleteNamespaceRequest) String() string

func (*DeleteNamespaceRequest) Unmarshal 

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

func (*DeleteNamespaceRequest) XXX_DiscardUnknown 

func (m *DeleteNamespaceRequest) XXX_DiscardUnknown()

func (*DeleteNamespaceRequest) XXX_Marshal 

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

func (*DeleteNamespaceRequest) XXX_Merge 

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

func (*DeleteNamespaceRequest) XXX_Size 

func (m *DeleteNamespaceRequest) XXX_Size() int

func (*DeleteNamespaceRequest) XXX_Unmarshal 

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

type DeleteNamespaceResponse 

type DeleteNamespaceResponse struct {
	// Temporary namespace name that is used during reclaim resources step.
	DeletedNamespace string `protobuf:"bytes,1,opt,name=deleted_namespace,json=deletedNamespace,proto3" json:"deleted_namespace,omitempty"`
}

func (*DeleteNamespaceResponse) Descriptor 

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

func (*DeleteNamespaceResponse) Equal 

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

func (*DeleteNamespaceResponse) GetDeletedNamespace 

func (m *DeleteNamespaceResponse) GetDeletedNamespace() string

func (*DeleteNamespaceResponse) GoString 

func (this *DeleteNamespaceResponse) GoString() string

func (*DeleteNamespaceResponse) Marshal 

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

func (*DeleteNamespaceResponse) MarshalTo 

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

func (*DeleteNamespaceResponse) MarshalToSizedBuffer 

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

func (*DeleteNamespaceResponse) ProtoMessage 

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) Reset 

func (m *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) Size 

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

func (*DeleteNamespaceResponse) String 

func (this *DeleteNamespaceResponse) String() string

func (*DeleteNamespaceResponse) Unmarshal 

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

func (*DeleteNamespaceResponse) XXX_DiscardUnknown 

func (m *DeleteNamespaceResponse) XXX_DiscardUnknown()

func (*DeleteNamespaceResponse) XXX_Marshal 

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

func (*DeleteNamespaceResponse) XXX_Merge 

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

func (*DeleteNamespaceResponse) XXX_Size 

func (m *DeleteNamespaceResponse) XXX_Size() int

func (*DeleteNamespaceResponse) XXX_Unmarshal 

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

type DeleteWorkflowExecutionRequest 

type DeleteWorkflowExecutionRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Workflow executions to delete. If run_id is not specified, last one is used.
	WorkflowExecution *v11.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
}

This message is EXPERIMENTAL and may be changed or removed in a later release. (-- api-linter: core::0135::request-unknown-fields=disabled 

aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)

(-- api-linter: core::0135::request-name-required=disabled 

aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)

func (*DeleteWorkflowExecutionRequest) Descriptor 

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

func (*DeleteWorkflowExecutionRequest) Equal 

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

func (*DeleteWorkflowExecutionRequest) GetNamespace 

func (m *DeleteWorkflowExecutionRequest) GetNamespace() string

func (*DeleteWorkflowExecutionRequest) GetWorkflowExecution 

func (m *DeleteWorkflowExecutionRequest) GetWorkflowExecution() *v11.WorkflowExecution

func (*DeleteWorkflowExecutionRequest) GoString 

func (this *DeleteWorkflowExecutionRequest) GoString() string

func (*DeleteWorkflowExecutionRequest) Marshal 

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

func (*DeleteWorkflowExecutionRequest) MarshalTo 

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

func (*DeleteWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*DeleteWorkflowExecutionRequest) ProtoMessage 

func (*DeleteWorkflowExecutionRequest) ProtoMessage()

func (*DeleteWorkflowExecutionRequest) Reset 

func (m *DeleteWorkflowExecutionRequest) Reset()

func (*DeleteWorkflowExecutionRequest) Size 

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

func (*DeleteWorkflowExecutionRequest) String 

func (this *DeleteWorkflowExecutionRequest) String() string

func (*DeleteWorkflowExecutionRequest) Unmarshal 

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

func (*DeleteWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *DeleteWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*DeleteWorkflowExecutionRequest) XXX_Marshal 

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

func (*DeleteWorkflowExecutionRequest) XXX_Merge 

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

func (*DeleteWorkflowExecutionRequest) XXX_Size 

func (m *DeleteWorkflowExecutionRequest) XXX_Size() int

func (*DeleteWorkflowExecutionRequest) XXX_Unmarshal 

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

type DeleteWorkflowExecutionResponse 

type DeleteWorkflowExecutionResponse struct {
}

This message is EXPERIMENTAL and may be changed or removed in a later release.

func (*DeleteWorkflowExecutionResponse) Descriptor 

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

func (*DeleteWorkflowExecutionResponse) Equal 

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

func (*DeleteWorkflowExecutionResponse) GoString 

func (this *DeleteWorkflowExecutionResponse) GoString() string

func (*DeleteWorkflowExecutionResponse) Marshal 

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

func (*DeleteWorkflowExecutionResponse) MarshalTo 

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

func (*DeleteWorkflowExecutionResponse) MarshalToSizedBuffer 

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

func (*DeleteWorkflowExecutionResponse) ProtoMessage 

func (*DeleteWorkflowExecutionResponse) ProtoMessage()

func (*DeleteWorkflowExecutionResponse) Reset 

func (m *DeleteWorkflowExecutionResponse) Reset()

func (*DeleteWorkflowExecutionResponse) Size 

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

func (*DeleteWorkflowExecutionResponse) String 

func (this *DeleteWorkflowExecutionResponse) String() string

func (*DeleteWorkflowExecutionResponse) Unmarshal 

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

func (*DeleteWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *DeleteWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*DeleteWorkflowExecutionResponse) XXX_Marshal 

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

func (*DeleteWorkflowExecutionResponse) XXX_Merge 

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

func (*DeleteWorkflowExecutionResponse) XXX_Size 

func (m *DeleteWorkflowExecutionResponse) XXX_Size() int

func (*DeleteWorkflowExecutionResponse) XXX_Unmarshal 

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

type DescribeClusterRequest added in v1.9.0 

type DescribeClusterRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
}

func (*DescribeClusterRequest) Descriptor added in v1.9.0 

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

func (*DescribeClusterRequest) Equal added in v1.9.0 

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

func (*DescribeClusterRequest) GetClusterName added in v1.9.0 

func (m *DescribeClusterRequest) GetClusterName() string

func (*DescribeClusterRequest) GoString added in v1.9.0 

func (this *DescribeClusterRequest) GoString() string

func (*DescribeClusterRequest) Marshal added in v1.9.0 

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

func (*DescribeClusterRequest) MarshalTo added in v1.9.0 

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

func (*DescribeClusterRequest) MarshalToSizedBuffer added in v1.9.0 

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

func (*DescribeClusterRequest) ProtoMessage added in v1.9.0 

func (*DescribeClusterRequest) ProtoMessage()

func (*DescribeClusterRequest) Reset added in v1.9.0 

func (m *DescribeClusterRequest) Reset()

func (*DescribeClusterRequest) Size added in v1.9.0 

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

func (*DescribeClusterRequest) String added in v1.9.0 

func (this *DescribeClusterRequest) String() string

func (*DescribeClusterRequest) Unmarshal added in v1.9.0 

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

func (*DescribeClusterRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *DescribeClusterRequest) XXX_DiscardUnknown()

func (*DescribeClusterRequest) XXX_Marshal added in v1.9.0 

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

func (*DescribeClusterRequest) XXX_Merge added in v1.9.0 

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

func (*DescribeClusterRequest) XXX_Size added in v1.9.0 

func (m *DescribeClusterRequest) XXX_Size() int

func (*DescribeClusterRequest) XXX_Unmarshal added in v1.9.0 

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

type DescribeClusterResponse added in v1.9.0 

type DescribeClusterResponse struct {
	SupportedClients         map[string]string   `` /* 197-byte string literal not displayed */
	ServerVersion            string              `protobuf:"bytes,2,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	MembershipInfo           *v12.MembershipInfo `protobuf:"bytes,3,opt,name=membership_info,json=membershipInfo,proto3" json:"membership_info,omitempty"`
	ClusterId                string              `protobuf:"bytes,4,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ClusterName              string              `protobuf:"bytes,5,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HistoryShardCount        int32               `protobuf:"varint,6,opt,name=history_shard_count,json=historyShardCount,proto3" json:"history_shard_count,omitempty"`
	PersistenceStore         string              `protobuf:"bytes,7,opt,name=persistence_store,json=persistenceStore,proto3" json:"persistence_store,omitempty"`
	VisibilityStore          string              `protobuf:"bytes,8,opt,name=visibility_store,json=visibilityStore,proto3" json:"visibility_store,omitempty"`
	VersionInfo              *v13.VersionInfo    `protobuf:"bytes,9,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	FailoverVersionIncrement int64               `` /* 137-byte string literal not displayed */
	InitialFailoverVersion   int64               `` /* 131-byte string literal not displayed */
	IsGlobalNamespaceEnabled bool                `` /* 139-byte string literal not displayed */
}

func (*DescribeClusterResponse) Descriptor added in v1.9.0 

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

func (*DescribeClusterResponse) Equal added in v1.9.0 

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

func (*DescribeClusterResponse) GetClusterId added in v1.9.0 

func (m *DescribeClusterResponse) GetClusterId() string

func (*DescribeClusterResponse) GetClusterName added in v1.9.0 

func (m *DescribeClusterResponse) GetClusterName() string

func (*DescribeClusterResponse) GetFailoverVersionIncrement added in v1.9.0 

func (m *DescribeClusterResponse) GetFailoverVersionIncrement() int64

func (*DescribeClusterResponse) GetHistoryShardCount added in v1.9.0 

func (m *DescribeClusterResponse) GetHistoryShardCount() int32

func (*DescribeClusterResponse) GetInitialFailoverVersion added in v1.9.0 

func (m *DescribeClusterResponse) GetInitialFailoverVersion() int64

func (*DescribeClusterResponse) GetIsGlobalNamespaceEnabled added in v1.9.0 

func (m *DescribeClusterResponse) GetIsGlobalNamespaceEnabled() bool

func (*DescribeClusterResponse) GetMembershipInfo added in v1.9.0 

func (m *DescribeClusterResponse) GetMembershipInfo() *v12.MembershipInfo

func (*DescribeClusterResponse) GetPersistenceStore added in v1.9.0 

func (m *DescribeClusterResponse) GetPersistenceStore() string

func (*DescribeClusterResponse) GetServerVersion added in v1.9.0 

func (m *DescribeClusterResponse) GetServerVersion() string

func (*DescribeClusterResponse) GetSupportedClients added in v1.9.0 

func (m *DescribeClusterResponse) GetSupportedClients() map[string]string

func (*DescribeClusterResponse) GetVersionInfo added in v1.9.0 

func (m *DescribeClusterResponse) GetVersionInfo() *v13.VersionInfo

func (*DescribeClusterResponse) GetVisibilityStore added in v1.9.0 

func (m *DescribeClusterResponse) GetVisibilityStore() string

func (*DescribeClusterResponse) GoString added in v1.9.0 

func (this *DescribeClusterResponse) GoString() string

func (*DescribeClusterResponse) Marshal added in v1.9.0 

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

func (*DescribeClusterResponse) MarshalTo added in v1.9.0 

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

func (*DescribeClusterResponse) MarshalToSizedBuffer added in v1.9.0 

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

func (*DescribeClusterResponse) ProtoMessage added in v1.9.0 

func (*DescribeClusterResponse) ProtoMessage()

func (*DescribeClusterResponse) Reset added in v1.9.0 

func (m *DescribeClusterResponse) Reset()

func (*DescribeClusterResponse) Size added in v1.9.0 

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

func (*DescribeClusterResponse) String added in v1.9.0 

func (this *DescribeClusterResponse) String() string

func (*DescribeClusterResponse) Unmarshal added in v1.9.0 

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

func (*DescribeClusterResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *DescribeClusterResponse) XXX_DiscardUnknown()

func (*DescribeClusterResponse) XXX_Marshal added in v1.9.0 

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

func (*DescribeClusterResponse) XXX_Merge added in v1.9.0 

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

func (*DescribeClusterResponse) XXX_Size added in v1.9.0 

func (m *DescribeClusterResponse) XXX_Size() int

func (*DescribeClusterResponse) XXX_Unmarshal added in v1.9.0 

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

type ListClusterMembersRequest added in v1.9.0 

type ListClusterMembersRequest struct {
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "within" is used to indicate a time range. --)
	LastHeartbeatWithin *time.Duration       `` /* 132-byte string literal not displayed */
	RpcAddress          string               `protobuf:"bytes,2,opt,name=rpc_address,json=rpcAddress,proto3" json:"rpc_address,omitempty"`
	HostId              string               `protobuf:"bytes,3,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Role                v1.ClusterMemberRole `protobuf:"varint,4,opt,name=role,proto3,enum=temporal.api.enums.v1.ClusterMemberRole" json:"role,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "after" is used to indicate a time range. --)
	SessionStartedAfterTime *time.Time `` /* 142-byte string literal not displayed */
	PageSize                int32      `protobuf:"varint,6,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken           []byte     `protobuf:"bytes,7,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClusterMembersRequest) Descriptor added in v1.9.0 

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

func (*ListClusterMembersRequest) Equal added in v1.9.0 

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

func (*ListClusterMembersRequest) GetHostId added in v1.9.0 

func (m *ListClusterMembersRequest) GetHostId() string

func (*ListClusterMembersRequest) GetLastHeartbeatWithin added in v1.9.0 

func (m *ListClusterMembersRequest) GetLastHeartbeatWithin() *time.Duration

func (*ListClusterMembersRequest) GetNextPageToken added in v1.9.0 

func (m *ListClusterMembersRequest) GetNextPageToken() []byte

func (*ListClusterMembersRequest) GetPageSize added in v1.9.0 

func (m *ListClusterMembersRequest) GetPageSize() int32

func (*ListClusterMembersRequest) GetRole added in v1.9.0 

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

func (*ListClusterMembersRequest) GetRpcAddress added in v1.9.0 

func (m *ListClusterMembersRequest) GetRpcAddress() string

func (*ListClusterMembersRequest) GetSessionStartedAfterTime added in v1.9.0 

func (m *ListClusterMembersRequest) GetSessionStartedAfterTime() *time.Time

func (*ListClusterMembersRequest) GoString added in v1.9.0 

func (this *ListClusterMembersRequest) GoString() string

func (*ListClusterMembersRequest) Marshal added in v1.9.0 

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

func (*ListClusterMembersRequest) MarshalTo added in v1.9.0 

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

func (*ListClusterMembersRequest) MarshalToSizedBuffer added in v1.9.0 

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

func (*ListClusterMembersRequest) ProtoMessage added in v1.9.0 

func (*ListClusterMembersRequest) ProtoMessage()

func (*ListClusterMembersRequest) Reset added in v1.9.0 

func (m *ListClusterMembersRequest) Reset()

func (*ListClusterMembersRequest) Size added in v1.9.0 

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

func (*ListClusterMembersRequest) String added in v1.9.0 

func (this *ListClusterMembersRequest) String() string

func (*ListClusterMembersRequest) Unmarshal added in v1.9.0 

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

func (*ListClusterMembersRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *ListClusterMembersRequest) XXX_DiscardUnknown()

func (*ListClusterMembersRequest) XXX_Marshal added in v1.9.0 

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

func (*ListClusterMembersRequest) XXX_Merge added in v1.9.0 

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

func (*ListClusterMembersRequest) XXX_Size added in v1.9.0 

func (m *ListClusterMembersRequest) XXX_Size() int

func (*ListClusterMembersRequest) XXX_Unmarshal added in v1.9.0 

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

type ListClusterMembersResponse added in v1.9.0 

type ListClusterMembersResponse struct {
	ActiveMembers []*v12.ClusterMember `protobuf:"bytes,1,rep,name=active_members,json=activeMembers,proto3" json:"active_members,omitempty"`
	NextPageToken []byte               `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClusterMembersResponse) Descriptor added in v1.9.0 

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

func (*ListClusterMembersResponse) Equal added in v1.9.0 

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

func (*ListClusterMembersResponse) GetActiveMembers added in v1.9.0 

func (m *ListClusterMembersResponse) GetActiveMembers() []*v12.ClusterMember

func (*ListClusterMembersResponse) GetNextPageToken added in v1.9.0 

func (m *ListClusterMembersResponse) GetNextPageToken() []byte

func (*ListClusterMembersResponse) GoString added in v1.9.0 

func (this *ListClusterMembersResponse) GoString() string

func (*ListClusterMembersResponse) Marshal added in v1.9.0 

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

func (*ListClusterMembersResponse) MarshalTo added in v1.9.0 

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

func (*ListClusterMembersResponse) MarshalToSizedBuffer added in v1.9.0 

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

func (*ListClusterMembersResponse) ProtoMessage added in v1.9.0 

func (*ListClusterMembersResponse) ProtoMessage()

func (*ListClusterMembersResponse) Reset added in v1.9.0 

func (m *ListClusterMembersResponse) Reset()

func (*ListClusterMembersResponse) Size added in v1.9.0 

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

func (*ListClusterMembersResponse) String added in v1.9.0 

func (this *ListClusterMembersResponse) String() string

func (*ListClusterMembersResponse) Unmarshal added in v1.9.0 

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

func (*ListClusterMembersResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *ListClusterMembersResponse) XXX_DiscardUnknown()

func (*ListClusterMembersResponse) XXX_Marshal added in v1.9.0 

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

func (*ListClusterMembersResponse) XXX_Merge added in v1.9.0 

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

func (*ListClusterMembersResponse) XXX_Size added in v1.9.0 

func (m *ListClusterMembersResponse) XXX_Size() int

func (*ListClusterMembersResponse) XXX_Unmarshal added in v1.9.0 

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

type ListClustersRequest added in v1.9.0 

type ListClustersRequest struct {
	PageSize      int32  `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClustersRequest) Descriptor added in v1.9.0 

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

func (*ListClustersRequest) Equal added in v1.9.0 

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

func (*ListClustersRequest) GetNextPageToken added in v1.9.0 

func (m *ListClustersRequest) GetNextPageToken() []byte

func (*ListClustersRequest) GetPageSize added in v1.9.0 

func (m *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GoString added in v1.9.0 

func (this *ListClustersRequest) GoString() string

func (*ListClustersRequest) Marshal added in v1.9.0 

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

func (*ListClustersRequest) MarshalTo added in v1.9.0 

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

func (*ListClustersRequest) MarshalToSizedBuffer added in v1.9.0 

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

func (*ListClustersRequest) ProtoMessage added in v1.9.0 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) Reset added in v1.9.0 

func (m *ListClustersRequest) Reset()

func (*ListClustersRequest) Size added in v1.9.0 

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

func (*ListClustersRequest) String added in v1.9.0 

func (this *ListClustersRequest) String() string

func (*ListClustersRequest) Unmarshal added in v1.9.0 

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

func (*ListClustersRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *ListClustersRequest) XXX_DiscardUnknown()

func (*ListClustersRequest) XXX_Marshal added in v1.9.0 

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

func (*ListClustersRequest) XXX_Merge added in v1.9.0 

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

func (*ListClustersRequest) XXX_Size added in v1.9.0 

func (m *ListClustersRequest) XXX_Size() int

func (*ListClustersRequest) XXX_Unmarshal added in v1.9.0 

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

type ListClustersResponse added in v1.9.0 

type ListClustersResponse struct {
	Clusters      []*v12.ClusterMetadata `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	NextPageToken []byte                 `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClustersResponse) Descriptor added in v1.9.0 

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

func (*ListClustersResponse) Equal added in v1.9.0 

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

func (*ListClustersResponse) GetClusters added in v1.9.0 

func (m *ListClustersResponse) GetClusters() []*v12.ClusterMetadata

func (*ListClustersResponse) GetNextPageToken added in v1.9.0 

func (m *ListClustersResponse) GetNextPageToken() []byte

func (*ListClustersResponse) GoString added in v1.9.0 

func (this *ListClustersResponse) GoString() string

func (*ListClustersResponse) Marshal added in v1.9.0 

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

func (*ListClustersResponse) MarshalTo added in v1.9.0 

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

func (*ListClustersResponse) MarshalToSizedBuffer added in v1.9.0 

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

func (*ListClustersResponse) ProtoMessage added in v1.9.0 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) Reset added in v1.9.0 

func (m *ListClustersResponse) Reset()

func (*ListClustersResponse) Size added in v1.9.0 

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

func (*ListClustersResponse) String added in v1.9.0 

func (this *ListClustersResponse) String() string

func (*ListClustersResponse) Unmarshal added in v1.9.0 

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

func (*ListClustersResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *ListClustersResponse) XXX_DiscardUnknown()

func (*ListClustersResponse) XXX_Marshal added in v1.9.0 

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

func (*ListClustersResponse) XXX_Merge added in v1.9.0 

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

func (*ListClustersResponse) XXX_Size added in v1.9.0 

func (m *ListClustersResponse) XXX_Size() int

func (*ListClustersResponse) XXX_Unmarshal added in v1.9.0 

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

type ListSearchAttributesRequest 

type ListSearchAttributesRequest struct {
}

func (*ListSearchAttributesRequest) Descriptor 

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

func (*ListSearchAttributesRequest) Equal 

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

func (*ListSearchAttributesRequest) GoString 

func (this *ListSearchAttributesRequest) GoString() string

func (*ListSearchAttributesRequest) Marshal 

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

func (*ListSearchAttributesRequest) MarshalTo 

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

func (*ListSearchAttributesRequest) MarshalToSizedBuffer 

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

func (*ListSearchAttributesRequest) ProtoMessage 

func (*ListSearchAttributesRequest) ProtoMessage()

func (*ListSearchAttributesRequest) Reset 

func (m *ListSearchAttributesRequest) Reset()

func (*ListSearchAttributesRequest) Size 

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

func (*ListSearchAttributesRequest) String 

func (this *ListSearchAttributesRequest) String() string

func (*ListSearchAttributesRequest) Unmarshal 

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

func (*ListSearchAttributesRequest) XXX_DiscardUnknown 

func (m *ListSearchAttributesRequest) XXX_DiscardUnknown()

func (*ListSearchAttributesRequest) XXX_Marshal 

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

func (*ListSearchAttributesRequest) XXX_Merge 

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

func (*ListSearchAttributesRequest) XXX_Size 

func (m *ListSearchAttributesRequest) XXX_Size() int

func (*ListSearchAttributesRequest) XXX_Unmarshal 

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

type ListSearchAttributesResponse 

type ListSearchAttributesResponse struct {
	// Mapping between custom (user-registered) search attribute name to its IndexedValueType.
	CustomAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
	// Mapping between system (predefined) search attribute name to its IndexedValueType.
	SystemAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
	// Mapping from the attribute name to the visibility storage native type.
	StorageSchema map[string]string `` /* 188-byte string literal not displayed */
}

func (*ListSearchAttributesResponse) Descriptor 

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

func (*ListSearchAttributesResponse) Equal 

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

func (*ListSearchAttributesResponse) GetCustomAttributes 

func (m *ListSearchAttributesResponse) GetCustomAttributes() map[string]v1.IndexedValueType

func (*ListSearchAttributesResponse) GetStorageSchema 

func (m *ListSearchAttributesResponse) GetStorageSchema() map[string]string

func (*ListSearchAttributesResponse) GetSystemAttributes 

func (m *ListSearchAttributesResponse) GetSystemAttributes() map[string]v1.IndexedValueType

func (*ListSearchAttributesResponse) GoString 

func (this *ListSearchAttributesResponse) GoString() string

func (*ListSearchAttributesResponse) Marshal 

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

func (*ListSearchAttributesResponse) MarshalTo 

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

func (*ListSearchAttributesResponse) MarshalToSizedBuffer 

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

func (*ListSearchAttributesResponse) ProtoMessage 

func (*ListSearchAttributesResponse) ProtoMessage()

func (*ListSearchAttributesResponse) Reset 

func (m *ListSearchAttributesResponse) Reset()

func (*ListSearchAttributesResponse) Size 

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

func (*ListSearchAttributesResponse) String 

func (this *ListSearchAttributesResponse) String() string

func (*ListSearchAttributesResponse) Unmarshal 

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

func (*ListSearchAttributesResponse) XXX_DiscardUnknown 

func (m *ListSearchAttributesResponse) XXX_DiscardUnknown()

func (*ListSearchAttributesResponse) XXX_Marshal 

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

func (*ListSearchAttributesResponse) XXX_Merge 

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

func (*ListSearchAttributesResponse) XXX_Size 

func (m *ListSearchAttributesResponse) XXX_Size() int

func (*ListSearchAttributesResponse) XXX_Unmarshal 

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

type OperatorServiceClient 

type OperatorServiceClient interface {
	// AddSearchAttributes add custom search attributes.
	//
	// Returns ALREADY_EXISTS status code if a Search Attribute with any of the specified names already exists
	// Returns INTERNAL status code with temporal.api.errordetails.v1.SystemWorkflowFailure in Error Details if registration process fails,
	AddSearchAttributes(ctx context.Context, in *AddSearchAttributesRequest, opts ...grpc.CallOption) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes.
	//
	// Returns NOT_FOUND status code if a Search Attribute with any of the specified names is not registered
	RemoveSearchAttributes(ctx context.Context, in *RemoveSearchAttributesRequest, opts ...grpc.CallOption) (*RemoveSearchAttributesResponse, error)
	// ListSearchAttributes returns comprehensive information about search attributes.
	ListSearchAttributes(ctx context.Context, in *ListSearchAttributesRequest, opts ...grpc.CallOption) (*ListSearchAttributesResponse, error)
	// DeleteNamespace synchronously deletes a namespace and asynchronously reclaims all namespace resources.
	// (-- api-linter: core::0135::method-signature=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0135::response-message-name=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error)
	// DeleteWorkflowExecution deletes a closed workflow execution asynchronously (workflow must be completed or terminated before).
	// This method is EXPERIMENTAL and may be changed or removed in a later release.
	// (-- api-linter: core::0135::method-signature=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0135::response-message-name=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	DeleteWorkflowExecution(ctx context.Context, in *DeleteWorkflowExecutionRequest, opts ...grpc.CallOption) (*DeleteWorkflowExecutionResponse, error)
	// AddOrUpdateRemoteCluster adds or updates remote cluster.
	AddOrUpdateRemoteCluster(ctx context.Context, in *AddOrUpdateRemoteClusterRequest, opts ...grpc.CallOption) (*AddOrUpdateRemoteClusterResponse, error)
	// RemoveRemoteCluster removes remote cluster.
	RemoveRemoteCluster(ctx context.Context, in *RemoveRemoteClusterRequest, opts ...grpc.CallOption) (*RemoveRemoteClusterResponse, error)
	// DescribeCluster returns information about Temporal cluster.
	DescribeCluster(ctx context.Context, in *DescribeClusterRequest, opts ...grpc.CallOption) (*DescribeClusterResponse, error)
	// ListClusters returns information about Temporal clusters.
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// ListClusterMembers returns information about Temporal cluster members.
	ListClusterMembers(ctx context.Context, in *ListClusterMembersRequest, opts ...grpc.CallOption) (*ListClusterMembersResponse, error)
}

OperatorServiceClient is the client API for OperatorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewOperatorServiceClient 

func NewOperatorServiceClient(cc *grpc.ClientConn) OperatorServiceClient

type OperatorServiceServer 

type OperatorServiceServer interface {
	// AddSearchAttributes add custom search attributes.
	//
	// Returns ALREADY_EXISTS status code if a Search Attribute with any of the specified names already exists
	// Returns INTERNAL status code with temporal.api.errordetails.v1.SystemWorkflowFailure in Error Details if registration process fails,
	AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes.
	//
	// Returns NOT_FOUND status code if a Search Attribute with any of the specified names is not registered
	RemoveSearchAttributes(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)
	// ListSearchAttributes returns comprehensive information about search attributes.
	ListSearchAttributes(context.Context, *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)
	// DeleteNamespace synchronously deletes a namespace and asynchronously reclaims all namespace resources.
	// (-- api-linter: core::0135::method-signature=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0135::response-message-name=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
	// DeleteWorkflowExecution deletes a closed workflow execution asynchronously (workflow must be completed or terminated before).
	// This method is EXPERIMENTAL and may be changed or removed in a later release.
	// (-- api-linter: core::0135::method-signature=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0135::response-message-name=disabled
	//     aip.dev/not-precedent: DeleteNamespace RPC doesn't follow Google API format. --)
	DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)
	// AddOrUpdateRemoteCluster adds or updates remote cluster.
	AddOrUpdateRemoteCluster(context.Context, *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)
	// RemoveRemoteCluster removes remote cluster.
	RemoveRemoteCluster(context.Context, *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)
	// DescribeCluster returns information about Temporal cluster.
	DescribeCluster(context.Context, *DescribeClusterRequest) (*DescribeClusterResponse, error)
	// ListClusters returns information about Temporal clusters.
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// ListClusterMembers returns information about Temporal cluster members.
	ListClusterMembers(context.Context, *ListClusterMembersRequest) (*ListClusterMembersResponse, error)
}

OperatorServiceServer is the server API for OperatorService service.

type RemoveRemoteClusterRequest added in v1.9.0 

type RemoveRemoteClusterRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
}

func (*RemoveRemoteClusterRequest) Descriptor added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) Equal added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) GetClusterName added in v1.9.0 

func (m *RemoveRemoteClusterRequest) GetClusterName() string

func (*RemoveRemoteClusterRequest) GoString added in v1.9.0 

func (this *RemoveRemoteClusterRequest) GoString() string

func (*RemoveRemoteClusterRequest) Marshal added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) MarshalTo added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) MarshalToSizedBuffer added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) ProtoMessage added in v1.9.0 

func (*RemoveRemoteClusterRequest) ProtoMessage()

func (*RemoveRemoteClusterRequest) Reset added in v1.9.0 

func (m *RemoveRemoteClusterRequest) Reset()

func (*RemoveRemoteClusterRequest) Size added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) String added in v1.9.0 

func (this *RemoveRemoteClusterRequest) String() string

func (*RemoveRemoteClusterRequest) Unmarshal added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *RemoveRemoteClusterRequest) XXX_DiscardUnknown()

func (*RemoveRemoteClusterRequest) XXX_Marshal added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) XXX_Merge added in v1.9.0 

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

func (*RemoveRemoteClusterRequest) XXX_Size added in v1.9.0 

func (m *RemoveRemoteClusterRequest) XXX_Size() int

func (*RemoveRemoteClusterRequest) XXX_Unmarshal added in v1.9.0 

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

type RemoveRemoteClusterResponse added in v1.9.0 

type RemoveRemoteClusterResponse struct {
}

func (*RemoveRemoteClusterResponse) Descriptor added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) Equal added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) GoString added in v1.9.0 

func (this *RemoveRemoteClusterResponse) GoString() string

func (*RemoveRemoteClusterResponse) Marshal added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) MarshalTo added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) MarshalToSizedBuffer added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) ProtoMessage added in v1.9.0 

func (*RemoveRemoteClusterResponse) ProtoMessage()

func (*RemoveRemoteClusterResponse) Reset added in v1.9.0 

func (m *RemoveRemoteClusterResponse) Reset()

func (*RemoveRemoteClusterResponse) Size added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) String added in v1.9.0 

func (this *RemoveRemoteClusterResponse) String() string

func (*RemoveRemoteClusterResponse) Unmarshal added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *RemoveRemoteClusterResponse) XXX_DiscardUnknown()

func (*RemoveRemoteClusterResponse) XXX_Marshal added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) XXX_Merge added in v1.9.0 

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

func (*RemoveRemoteClusterResponse) XXX_Size added in v1.9.0 

func (m *RemoveRemoteClusterResponse) XXX_Size() int

func (*RemoveRemoteClusterResponse) XXX_Unmarshal added in v1.9.0 

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

type RemoveSearchAttributesRequest 

type RemoveSearchAttributesRequest struct {
	// Search attribute names to delete.
	SearchAttributes []string `protobuf:"bytes,1,rep,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
}

func (*RemoveSearchAttributesRequest) Descriptor 

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

func (*RemoveSearchAttributesRequest) Equal 

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

func (*RemoveSearchAttributesRequest) GetSearchAttributes 

func (m *RemoveSearchAttributesRequest) GetSearchAttributes() []string

func (*RemoveSearchAttributesRequest) GoString 

func (this *RemoveSearchAttributesRequest) GoString() string

func (*RemoveSearchAttributesRequest) Marshal 

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

func (*RemoveSearchAttributesRequest) MarshalTo 

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

func (*RemoveSearchAttributesRequest) MarshalToSizedBuffer 

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

func (*RemoveSearchAttributesRequest) ProtoMessage 

func (*RemoveSearchAttributesRequest) ProtoMessage()

func (*RemoveSearchAttributesRequest) Reset 

func (m *RemoveSearchAttributesRequest) Reset()

func (*RemoveSearchAttributesRequest) Size 

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

func (*RemoveSearchAttributesRequest) String 

func (this *RemoveSearchAttributesRequest) String() string

func (*RemoveSearchAttributesRequest) Unmarshal 

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

func (*RemoveSearchAttributesRequest) XXX_DiscardUnknown 

func (m *RemoveSearchAttributesRequest) XXX_DiscardUnknown()

func (*RemoveSearchAttributesRequest) XXX_Marshal 

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

func (*RemoveSearchAttributesRequest) XXX_Merge 

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

func (*RemoveSearchAttributesRequest) XXX_Size 

func (m *RemoveSearchAttributesRequest) XXX_Size() int

func (*RemoveSearchAttributesRequest) XXX_Unmarshal 

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

type RemoveSearchAttributesResponse 

type RemoveSearchAttributesResponse struct {
}

func (*RemoveSearchAttributesResponse) Descriptor 

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

func (*RemoveSearchAttributesResponse) Equal 

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

func (*RemoveSearchAttributesResponse) GoString 

func (this *RemoveSearchAttributesResponse) GoString() string

func (*RemoveSearchAttributesResponse) Marshal 

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

func (*RemoveSearchAttributesResponse) MarshalTo 

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

func (*RemoveSearchAttributesResponse) MarshalToSizedBuffer 

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

func (*RemoveSearchAttributesResponse) ProtoMessage 

func (*RemoveSearchAttributesResponse) ProtoMessage()

func (*RemoveSearchAttributesResponse) Reset 

func (m *RemoveSearchAttributesResponse) Reset()

func (*RemoveSearchAttributesResponse) Size 

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

func (*RemoveSearchAttributesResponse) String 

func (this *RemoveSearchAttributesResponse) String() string

func (*RemoveSearchAttributesResponse) Unmarshal 

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

func (*RemoveSearchAttributesResponse) XXX_DiscardUnknown 

func (m *RemoveSearchAttributesResponse) XXX_DiscardUnknown()

func (*RemoveSearchAttributesResponse) XXX_Marshal 

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

func (*RemoveSearchAttributesResponse) XXX_Merge 

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

func (*RemoveSearchAttributesResponse) XXX_Size 

func (m *RemoveSearchAttributesResponse) XXX_Size() int

func (*RemoveSearchAttributesResponse) XXX_Unmarshal 

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

type UnimplementedOperatorServiceServer 

type UnimplementedOperatorServiceServer struct {
}

UnimplementedOperatorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedOperatorServiceServer) AddOrUpdateRemoteCluster added in v1.9.0 

func (*UnimplementedOperatorServiceServer) AddOrUpdateRemoteCluster(ctx context.Context, req *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)

func (*UnimplementedOperatorServiceServer) AddSearchAttributes 

func (*UnimplementedOperatorServiceServer) AddSearchAttributes(ctx context.Context, req *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

func (*UnimplementedOperatorServiceServer) DeleteNamespace 

func (*UnimplementedOperatorServiceServer) DeleteNamespace(ctx context.Context, req *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)

func (*UnimplementedOperatorServiceServer) DeleteWorkflowExecution 

func (*UnimplementedOperatorServiceServer) DeleteWorkflowExecution(ctx context.Context, req *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)

func (*UnimplementedOperatorServiceServer) DescribeCluster added in v1.9.0 

func (*UnimplementedOperatorServiceServer) DescribeCluster(ctx context.Context, req *DescribeClusterRequest) (*DescribeClusterResponse, error)

func (*UnimplementedOperatorServiceServer) ListClusterMembers added in v1.9.0 

func (*UnimplementedOperatorServiceServer) ListClusterMembers(ctx context.Context, req *ListClusterMembersRequest) (*ListClusterMembersResponse, error)

func (*UnimplementedOperatorServiceServer) ListClusters added in v1.9.0 

func (*UnimplementedOperatorServiceServer) ListClusters(ctx context.Context, req *ListClustersRequest) (*ListClustersResponse, error)

func (*UnimplementedOperatorServiceServer) ListSearchAttributes 

func (*UnimplementedOperatorServiceServer) ListSearchAttributes(ctx context.Context, req *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)

func (*UnimplementedOperatorServiceServer) RemoveRemoteCluster added in v1.9.0 

func (*UnimplementedOperatorServiceServer) RemoveRemoteCluster(ctx context.Context, req *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)

func (*UnimplementedOperatorServiceServer) RemoveSearchAttributes 

func (*UnimplementedOperatorServiceServer) RemoveSearchAttributes(ctx context.Context, req *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, 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.