operatorservice

May 9, 2024

Changes in this version

+ const OperatorService_CreateNexusEndpoint_FullMethodName

+ const OperatorService_DeleteNexusEndpoint_FullMethodName

+ const OperatorService_GetNexusEndpoint_FullMethodName

+ const OperatorService_ListNexusEndpoints_FullMethodName

+ const OperatorService_UpdateNexusEndpoint_FullMethodName

+ type CreateNexusEndpointRequest struct

+ Spec *v11.EndpointSpec

+ func (*CreateNexusEndpointRequest) Descriptor() ([]byte, []int)

+ func (*CreateNexusEndpointRequest) ProtoMessage()

+ func (this *CreateNexusEndpointRequest) Equal(that interface{}) bool

+ func (val *CreateNexusEndpointRequest) Marshal() ([]byte, error)

+ func (val *CreateNexusEndpointRequest) Size() int

+ func (val *CreateNexusEndpointRequest) Unmarshal(buf []byte) error

+ func (x *CreateNexusEndpointRequest) GetSpec() *v11.EndpointSpec

+ func (x *CreateNexusEndpointRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateNexusEndpointRequest) Reset()

+ func (x *CreateNexusEndpointRequest) String() string

+ type CreateNexusEndpointResponse struct

+ Endpoint *v11.Endpoint

+ func (*CreateNexusEndpointResponse) Descriptor() ([]byte, []int)

+ func (*CreateNexusEndpointResponse) ProtoMessage()

+ func (this *CreateNexusEndpointResponse) Equal(that interface{}) bool

+ func (val *CreateNexusEndpointResponse) Marshal() ([]byte, error)

+ func (val *CreateNexusEndpointResponse) Size() int

+ func (val *CreateNexusEndpointResponse) Unmarshal(buf []byte) error

+ func (x *CreateNexusEndpointResponse) GetEndpoint() *v11.Endpoint

+ func (x *CreateNexusEndpointResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateNexusEndpointResponse) Reset()

+ func (x *CreateNexusEndpointResponse) String() string

+ type DeleteNexusEndpointRequest struct

+ Id string

+ Version int64

+ func (*DeleteNexusEndpointRequest) Descriptor() ([]byte, []int)

+ func (*DeleteNexusEndpointRequest) ProtoMessage()

+ func (this *DeleteNexusEndpointRequest) Equal(that interface{}) bool

+ func (val *DeleteNexusEndpointRequest) Marshal() ([]byte, error)

+ func (val *DeleteNexusEndpointRequest) Size() int

+ func (val *DeleteNexusEndpointRequest) Unmarshal(buf []byte) error

+ func (x *DeleteNexusEndpointRequest) GetId() string

+ func (x *DeleteNexusEndpointRequest) GetVersion() int64

+ func (x *DeleteNexusEndpointRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteNexusEndpointRequest) Reset()

+ func (x *DeleteNexusEndpointRequest) String() string

+ type DeleteNexusEndpointResponse struct

+ func (*DeleteNexusEndpointResponse) Descriptor() ([]byte, []int)

+ func (*DeleteNexusEndpointResponse) ProtoMessage()

+ func (this *DeleteNexusEndpointResponse) Equal(that interface{}) bool

+ func (val *DeleteNexusEndpointResponse) Marshal() ([]byte, error)

+ func (val *DeleteNexusEndpointResponse) Size() int

+ func (val *DeleteNexusEndpointResponse) Unmarshal(buf []byte) error

+ func (x *DeleteNexusEndpointResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteNexusEndpointResponse) Reset()

+ func (x *DeleteNexusEndpointResponse) String() string

+ type GetNexusEndpointRequest struct

+ Id string

+ func (*GetNexusEndpointRequest) Descriptor() ([]byte, []int)

+ func (*GetNexusEndpointRequest) ProtoMessage()

+ func (this *GetNexusEndpointRequest) Equal(that interface{}) bool

+ func (val *GetNexusEndpointRequest) Marshal() ([]byte, error)

+ func (val *GetNexusEndpointRequest) Size() int

+ func (val *GetNexusEndpointRequest) Unmarshal(buf []byte) error

+ func (x *GetNexusEndpointRequest) GetId() string

+ func (x *GetNexusEndpointRequest) ProtoReflect() protoreflect.Message

+ func (x *GetNexusEndpointRequest) Reset()

+ func (x *GetNexusEndpointRequest) String() string

+ type GetNexusEndpointResponse struct

+ Endpoint *v11.Endpoint

+ func (*GetNexusEndpointResponse) Descriptor() ([]byte, []int)

+ func (*GetNexusEndpointResponse) ProtoMessage()

+ func (this *GetNexusEndpointResponse) Equal(that interface{}) bool

+ func (val *GetNexusEndpointResponse) Marshal() ([]byte, error)

+ func (val *GetNexusEndpointResponse) Size() int

+ func (val *GetNexusEndpointResponse) Unmarshal(buf []byte) error

+ func (x *GetNexusEndpointResponse) GetEndpoint() *v11.Endpoint

+ func (x *GetNexusEndpointResponse) ProtoReflect() protoreflect.Message

+ func (x *GetNexusEndpointResponse) Reset()

+ func (x *GetNexusEndpointResponse) String() string

+ type ListNexusEndpointsRequest struct

+ Name string

+ NextPageToken []byte

+ PageSize int32

+ func (*ListNexusEndpointsRequest) Descriptor() ([]byte, []int)

+ func (*ListNexusEndpointsRequest) ProtoMessage()

+ func (this *ListNexusEndpointsRequest) Equal(that interface{}) bool

+ func (val *ListNexusEndpointsRequest) Marshal() ([]byte, error)

+ func (val *ListNexusEndpointsRequest) Size() int

+ func (val *ListNexusEndpointsRequest) Unmarshal(buf []byte) error

+ func (x *ListNexusEndpointsRequest) GetName() string

+ func (x *ListNexusEndpointsRequest) GetNextPageToken() []byte

+ func (x *ListNexusEndpointsRequest) GetPageSize() int32

+ func (x *ListNexusEndpointsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListNexusEndpointsRequest) Reset()

+ func (x *ListNexusEndpointsRequest) String() string

+ type ListNexusEndpointsResponse struct

+ Endpoints []*v11.Endpoint

+ NextPageToken []byte

+ func (*ListNexusEndpointsResponse) Descriptor() ([]byte, []int)

+ func (*ListNexusEndpointsResponse) ProtoMessage()

+ func (this *ListNexusEndpointsResponse) Equal(that interface{}) bool

+ func (val *ListNexusEndpointsResponse) Marshal() ([]byte, error)

+ func (val *ListNexusEndpointsResponse) Size() int

+ func (val *ListNexusEndpointsResponse) Unmarshal(buf []byte) error

+ func (x *ListNexusEndpointsResponse) GetEndpoints() []*v11.Endpoint

+ func (x *ListNexusEndpointsResponse) GetNextPageToken() []byte

+ func (x *ListNexusEndpointsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListNexusEndpointsResponse) Reset()

+ func (x *ListNexusEndpointsResponse) String() string

type OperatorServiceClient

+ CreateNexusEndpoint func(ctx context.Context, in *CreateNexusEndpointRequest, opts ...grpc.CallOption) (*CreateNexusEndpointResponse, error)

+ DeleteNexusEndpoint func(ctx context.Context, in *DeleteNexusEndpointRequest, opts ...grpc.CallOption) (*DeleteNexusEndpointResponse, error)

+ GetNexusEndpoint func(ctx context.Context, in *GetNexusEndpointRequest, opts ...grpc.CallOption) (*GetNexusEndpointResponse, error)

+ ListNexusEndpoints func(ctx context.Context, in *ListNexusEndpointsRequest, opts ...grpc.CallOption) (*ListNexusEndpointsResponse, error)

+ UpdateNexusEndpoint func(ctx context.Context, in *UpdateNexusEndpointRequest, opts ...grpc.CallOption) (*UpdateNexusEndpointResponse, error)

type OperatorServiceServer

+ CreateNexusEndpoint func(context.Context, *CreateNexusEndpointRequest) (*CreateNexusEndpointResponse, error)

+ DeleteNexusEndpoint func(context.Context, *DeleteNexusEndpointRequest) (*DeleteNexusEndpointResponse, error)

+ GetNexusEndpoint func(context.Context, *GetNexusEndpointRequest) (*GetNexusEndpointResponse, error)

+ ListNexusEndpoints func(context.Context, *ListNexusEndpointsRequest) (*ListNexusEndpointsResponse, error)

+ UpdateNexusEndpoint func(context.Context, *UpdateNexusEndpointRequest) (*UpdateNexusEndpointResponse, error)

type UnimplementedOperatorServiceServer

+ func (UnimplementedOperatorServiceServer) CreateNexusEndpoint(context.Context, *CreateNexusEndpointRequest) (*CreateNexusEndpointResponse, error)

+ func (UnimplementedOperatorServiceServer) DeleteNexusEndpoint(context.Context, *DeleteNexusEndpointRequest) (*DeleteNexusEndpointResponse, error)

+ func (UnimplementedOperatorServiceServer) GetNexusEndpoint(context.Context, *GetNexusEndpointRequest) (*GetNexusEndpointResponse, error)

+ func (UnimplementedOperatorServiceServer) ListNexusEndpoints(context.Context, *ListNexusEndpointsRequest) (*ListNexusEndpointsResponse, error)

+ func (UnimplementedOperatorServiceServer) UpdateNexusEndpoint(context.Context, *UpdateNexusEndpointRequest) (*UpdateNexusEndpointResponse, error)

+ type UpdateNexusEndpointRequest struct

+ Id string

+ Spec *v11.EndpointSpec

+ Version int64

+ func (*UpdateNexusEndpointRequest) Descriptor() ([]byte, []int)

+ func (*UpdateNexusEndpointRequest) ProtoMessage()

+ func (this *UpdateNexusEndpointRequest) Equal(that interface{}) bool

+ func (val *UpdateNexusEndpointRequest) Marshal() ([]byte, error)

+ func (val *UpdateNexusEndpointRequest) Size() int

+ func (val *UpdateNexusEndpointRequest) Unmarshal(buf []byte) error

+ func (x *UpdateNexusEndpointRequest) GetId() string

+ func (x *UpdateNexusEndpointRequest) GetSpec() *v11.EndpointSpec

+ func (x *UpdateNexusEndpointRequest) GetVersion() int64

+ func (x *UpdateNexusEndpointRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateNexusEndpointRequest) Reset()

+ func (x *UpdateNexusEndpointRequest) String() string

+ type UpdateNexusEndpointResponse struct

+ Endpoint *v11.Endpoint

+ func (*UpdateNexusEndpointResponse) Descriptor() ([]byte, []int)

+ func (*UpdateNexusEndpointResponse) ProtoMessage()

+ func (this *UpdateNexusEndpointResponse) Equal(that interface{}) bool

+ func (val *UpdateNexusEndpointResponse) Marshal() ([]byte, error)

+ func (val *UpdateNexusEndpointResponse) Size() int

+ func (val *UpdateNexusEndpointResponse) Unmarshal(buf []byte) error

+ func (x *UpdateNexusEndpointResponse) GetEndpoint() *v11.Endpoint

+ func (x *UpdateNexusEndpointResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateNexusEndpointResponse) Reset()

+ func (x *UpdateNexusEndpointResponse) String() string

Apr 6, 2024

Changes in this version

type AddOrUpdateRemoteClusterRequest

+ FrontendHttpAddress string

+ func (x *AddOrUpdateRemoteClusterRequest) GetFrontendHttpAddress() string

type ClusterMetadata

+ HttpAddress string

+ func (x *ClusterMetadata) GetHttpAddress() string

Mar 19, 2024

Changes in this version

+ const OperatorService_CreateNexusIncomingService_FullMethodName

+ const OperatorService_CreateNexusOutgoingService_FullMethodName

+ const OperatorService_DeleteNexusOutgoingService_FullMethodName

+ const OperatorService_GetNexusOutgoingService_FullMethodName

+ const OperatorService_ListNexusOutgoingServices_FullMethodName

+ const OperatorService_UpdateNexusIncomingService_FullMethodName

+ const OperatorService_UpdateNexusOutgoingService_FullMethodName

+ type CreateNexusIncomingServiceRequest struct

+ Spec *v11.IncomingServiceSpec

+ func (*CreateNexusIncomingServiceRequest) Descriptor() ([]byte, []int)

+ func (*CreateNexusIncomingServiceRequest) ProtoMessage()

+ func (this *CreateNexusIncomingServiceRequest) Equal(that interface{}) bool

+ func (val *CreateNexusIncomingServiceRequest) Marshal() ([]byte, error)

+ func (val *CreateNexusIncomingServiceRequest) Size() int

+ func (val *CreateNexusIncomingServiceRequest) Unmarshal(buf []byte) error

+ func (x *CreateNexusIncomingServiceRequest) GetSpec() *v11.IncomingServiceSpec

+ func (x *CreateNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateNexusIncomingServiceRequest) Reset()

+ func (x *CreateNexusIncomingServiceRequest) String() string

+ type CreateNexusIncomingServiceResponse struct

+ Service *v11.IncomingService

+ func (*CreateNexusIncomingServiceResponse) Descriptor() ([]byte, []int)

+ func (*CreateNexusIncomingServiceResponse) ProtoMessage()

+ func (this *CreateNexusIncomingServiceResponse) Equal(that interface{}) bool

+ func (val *CreateNexusIncomingServiceResponse) Marshal() ([]byte, error)

+ func (val *CreateNexusIncomingServiceResponse) Size() int

+ func (val *CreateNexusIncomingServiceResponse) Unmarshal(buf []byte) error

+ func (x *CreateNexusIncomingServiceResponse) GetService() *v11.IncomingService

+ func (x *CreateNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateNexusIncomingServiceResponse) Reset()

+ func (x *CreateNexusIncomingServiceResponse) String() string

+ type CreateNexusOutgoingServiceRequest struct

+ Name string

+ Namespace string

+ Spec *v11.OutgoingServiceSpec

+ func (*CreateNexusOutgoingServiceRequest) Descriptor() ([]byte, []int)

+ func (*CreateNexusOutgoingServiceRequest) ProtoMessage()

+ func (this *CreateNexusOutgoingServiceRequest) Equal(that interface{}) bool

+ func (val *CreateNexusOutgoingServiceRequest) Marshal() ([]byte, error)

+ func (val *CreateNexusOutgoingServiceRequest) Size() int

+ func (val *CreateNexusOutgoingServiceRequest) Unmarshal(buf []byte) error

+ func (x *CreateNexusOutgoingServiceRequest) GetName() string

+ func (x *CreateNexusOutgoingServiceRequest) GetNamespace() string

+ func (x *CreateNexusOutgoingServiceRequest) GetSpec() *v11.OutgoingServiceSpec

+ func (x *CreateNexusOutgoingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateNexusOutgoingServiceRequest) Reset()

+ func (x *CreateNexusOutgoingServiceRequest) String() string

+ type CreateNexusOutgoingServiceResponse struct

+ Service *v11.OutgoingService

+ func (*CreateNexusOutgoingServiceResponse) Descriptor() ([]byte, []int)

+ func (*CreateNexusOutgoingServiceResponse) ProtoMessage()

+ func (this *CreateNexusOutgoingServiceResponse) Equal(that interface{}) bool

+ func (val *CreateNexusOutgoingServiceResponse) Marshal() ([]byte, error)

+ func (val *CreateNexusOutgoingServiceResponse) Size() int

+ func (val *CreateNexusOutgoingServiceResponse) Unmarshal(buf []byte) error

+ func (x *CreateNexusOutgoingServiceResponse) GetService() *v11.OutgoingService

+ func (x *CreateNexusOutgoingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateNexusOutgoingServiceResponse) Reset()

+ func (x *CreateNexusOutgoingServiceResponse) String() string

type DeleteNexusIncomingServiceRequest

+ Id string

+ Version int64

+ func (x *DeleteNexusIncomingServiceRequest) GetId() string

+ func (x *DeleteNexusIncomingServiceRequest) GetVersion() int64

+ type DeleteNexusOutgoingServiceRequest struct

+ Name string

+ Namespace string

+ func (*DeleteNexusOutgoingServiceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteNexusOutgoingServiceRequest) ProtoMessage()

+ func (this *DeleteNexusOutgoingServiceRequest) Equal(that interface{}) bool

+ func (val *DeleteNexusOutgoingServiceRequest) Marshal() ([]byte, error)

+ func (val *DeleteNexusOutgoingServiceRequest) Size() int

+ func (val *DeleteNexusOutgoingServiceRequest) Unmarshal(buf []byte) error

+ func (x *DeleteNexusOutgoingServiceRequest) GetName() string

+ func (x *DeleteNexusOutgoingServiceRequest) GetNamespace() string

+ func (x *DeleteNexusOutgoingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteNexusOutgoingServiceRequest) Reset()

+ func (x *DeleteNexusOutgoingServiceRequest) String() string

+ type DeleteNexusOutgoingServiceResponse struct

+ func (*DeleteNexusOutgoingServiceResponse) Descriptor() ([]byte, []int)

+ func (*DeleteNexusOutgoingServiceResponse) ProtoMessage()

+ func (this *DeleteNexusOutgoingServiceResponse) Equal(that interface{}) bool

+ func (val *DeleteNexusOutgoingServiceResponse) Marshal() ([]byte, error)

+ func (val *DeleteNexusOutgoingServiceResponse) Size() int

+ func (val *DeleteNexusOutgoingServiceResponse) Unmarshal(buf []byte) error

+ func (x *DeleteNexusOutgoingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteNexusOutgoingServiceResponse) Reset()

+ func (x *DeleteNexusOutgoingServiceResponse) String() string

type GetNexusIncomingServiceRequest

+ Id string

+ func (x *GetNexusIncomingServiceRequest) GetId() string

+ type GetNexusOutgoingServiceRequest struct

+ Name string

+ Namespace string

+ func (*GetNexusOutgoingServiceRequest) Descriptor() ([]byte, []int)

+ func (*GetNexusOutgoingServiceRequest) ProtoMessage()

+ func (this *GetNexusOutgoingServiceRequest) Equal(that interface{}) bool

+ func (val *GetNexusOutgoingServiceRequest) Marshal() ([]byte, error)

+ func (val *GetNexusOutgoingServiceRequest) Size() int

+ func (val *GetNexusOutgoingServiceRequest) Unmarshal(buf []byte) error

+ func (x *GetNexusOutgoingServiceRequest) GetName() string

+ func (x *GetNexusOutgoingServiceRequest) GetNamespace() string

+ func (x *GetNexusOutgoingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetNexusOutgoingServiceRequest) Reset()

+ func (x *GetNexusOutgoingServiceRequest) String() string

+ type GetNexusOutgoingServiceResponse struct

+ Service *v11.OutgoingService

+ func (*GetNexusOutgoingServiceResponse) Descriptor() ([]byte, []int)

+ func (*GetNexusOutgoingServiceResponse) ProtoMessage()

+ func (this *GetNexusOutgoingServiceResponse) Equal(that interface{}) bool

+ func (val *GetNexusOutgoingServiceResponse) Marshal() ([]byte, error)

+ func (val *GetNexusOutgoingServiceResponse) Size() int

+ func (val *GetNexusOutgoingServiceResponse) Unmarshal(buf []byte) error

+ func (x *GetNexusOutgoingServiceResponse) GetService() *v11.OutgoingService

+ func (x *GetNexusOutgoingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *GetNexusOutgoingServiceResponse) Reset()

+ func (x *GetNexusOutgoingServiceResponse) String() string

type ListNexusIncomingServicesRequest

+ Name string

+ func (x *ListNexusIncomingServicesRequest) GetName() string

+ type ListNexusOutgoingServicesRequest struct

+ Namespace string

+ PageSize int32

+ PageToken []byte

+ func (*ListNexusOutgoingServicesRequest) Descriptor() ([]byte, []int)

+ func (*ListNexusOutgoingServicesRequest) ProtoMessage()

+ func (this *ListNexusOutgoingServicesRequest) Equal(that interface{}) bool

+ func (val *ListNexusOutgoingServicesRequest) Marshal() ([]byte, error)

+ func (val *ListNexusOutgoingServicesRequest) Size() int

+ func (val *ListNexusOutgoingServicesRequest) Unmarshal(buf []byte) error

+ func (x *ListNexusOutgoingServicesRequest) GetNamespace() string

+ func (x *ListNexusOutgoingServicesRequest) GetPageSize() int32

+ func (x *ListNexusOutgoingServicesRequest) GetPageToken() []byte

+ func (x *ListNexusOutgoingServicesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListNexusOutgoingServicesRequest) Reset()

+ func (x *ListNexusOutgoingServicesRequest) String() string

+ type ListNexusOutgoingServicesResponse struct

+ NextPageToken []byte

+ Services []*v11.OutgoingService

+ func (*ListNexusOutgoingServicesResponse) Descriptor() ([]byte, []int)

+ func (*ListNexusOutgoingServicesResponse) ProtoMessage()

+ func (this *ListNexusOutgoingServicesResponse) Equal(that interface{}) bool

+ func (val *ListNexusOutgoingServicesResponse) Marshal() ([]byte, error)

+ func (val *ListNexusOutgoingServicesResponse) Size() int

+ func (val *ListNexusOutgoingServicesResponse) Unmarshal(buf []byte) error

+ func (x *ListNexusOutgoingServicesResponse) GetNextPageToken() []byte

+ func (x *ListNexusOutgoingServicesResponse) GetServices() []*v11.OutgoingService

+ func (x *ListNexusOutgoingServicesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListNexusOutgoingServicesResponse) Reset()

+ func (x *ListNexusOutgoingServicesResponse) String() string

type OperatorServiceClient

+ CreateNexusIncomingService func(ctx context.Context, in *CreateNexusIncomingServiceRequest, ...) (*CreateNexusIncomingServiceResponse, error)

+ CreateNexusOutgoingService func(ctx context.Context, in *CreateNexusOutgoingServiceRequest, ...) (*CreateNexusOutgoingServiceResponse, error)

+ DeleteNexusOutgoingService func(ctx context.Context, in *DeleteNexusOutgoingServiceRequest, ...) (*DeleteNexusOutgoingServiceResponse, error)

+ GetNexusOutgoingService func(ctx context.Context, in *GetNexusOutgoingServiceRequest, ...) (*GetNexusOutgoingServiceResponse, error)

+ ListNexusOutgoingServices func(ctx context.Context, in *ListNexusOutgoingServicesRequest, ...) (*ListNexusOutgoingServicesResponse, error)

+ UpdateNexusIncomingService func(ctx context.Context, in *UpdateNexusIncomingServiceRequest, ...) (*UpdateNexusIncomingServiceResponse, error)

+ UpdateNexusOutgoingService func(ctx context.Context, in *UpdateNexusOutgoingServiceRequest, ...) (*UpdateNexusOutgoingServiceResponse, error)

type OperatorServiceServer

+ CreateNexusIncomingService func(context.Context, *CreateNexusIncomingServiceRequest) (*CreateNexusIncomingServiceResponse, error)

+ CreateNexusOutgoingService func(context.Context, *CreateNexusOutgoingServiceRequest) (*CreateNexusOutgoingServiceResponse, error)

+ DeleteNexusOutgoingService func(context.Context, *DeleteNexusOutgoingServiceRequest) (*DeleteNexusOutgoingServiceResponse, error)

+ GetNexusOutgoingService func(context.Context, *GetNexusOutgoingServiceRequest) (*GetNexusOutgoingServiceResponse, error)

+ ListNexusOutgoingServices func(context.Context, *ListNexusOutgoingServicesRequest) (*ListNexusOutgoingServicesResponse, error)

+ UpdateNexusIncomingService func(context.Context, *UpdateNexusIncomingServiceRequest) (*UpdateNexusIncomingServiceResponse, error)

+ UpdateNexusOutgoingService func(context.Context, *UpdateNexusOutgoingServiceRequest) (*UpdateNexusOutgoingServiceResponse, error)

type UnimplementedOperatorServiceServer

+ func (UnimplementedOperatorServiceServer) CreateNexusIncomingService(context.Context, *CreateNexusIncomingServiceRequest) (*CreateNexusIncomingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) CreateNexusOutgoingService(context.Context, *CreateNexusOutgoingServiceRequest) (*CreateNexusOutgoingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) DeleteNexusOutgoingService(context.Context, *DeleteNexusOutgoingServiceRequest) (*DeleteNexusOutgoingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) GetNexusOutgoingService(context.Context, *GetNexusOutgoingServiceRequest) (*GetNexusOutgoingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) ListNexusOutgoingServices(context.Context, *ListNexusOutgoingServicesRequest) (*ListNexusOutgoingServicesResponse, error)

+ func (UnimplementedOperatorServiceServer) UpdateNexusIncomingService(context.Context, *UpdateNexusIncomingServiceRequest) (*UpdateNexusIncomingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) UpdateNexusOutgoingService(context.Context, *UpdateNexusOutgoingServiceRequest) (*UpdateNexusOutgoingServiceResponse, error)

+ type UpdateNexusIncomingServiceRequest struct

+ Id string

+ Spec *v11.IncomingServiceSpec

+ Version int64

+ func (*UpdateNexusIncomingServiceRequest) Descriptor() ([]byte, []int)

+ func (*UpdateNexusIncomingServiceRequest) ProtoMessage()

+ func (this *UpdateNexusIncomingServiceRequest) Equal(that interface{}) bool

+ func (val *UpdateNexusIncomingServiceRequest) Marshal() ([]byte, error)

+ func (val *UpdateNexusIncomingServiceRequest) Size() int

+ func (val *UpdateNexusIncomingServiceRequest) Unmarshal(buf []byte) error

+ func (x *UpdateNexusIncomingServiceRequest) GetId() string

+ func (x *UpdateNexusIncomingServiceRequest) GetSpec() *v11.IncomingServiceSpec

+ func (x *UpdateNexusIncomingServiceRequest) GetVersion() int64

+ func (x *UpdateNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateNexusIncomingServiceRequest) Reset()

+ func (x *UpdateNexusIncomingServiceRequest) String() string

+ type UpdateNexusIncomingServiceResponse struct

+ Service *v11.IncomingService

+ func (*UpdateNexusIncomingServiceResponse) Descriptor() ([]byte, []int)

+ func (*UpdateNexusIncomingServiceResponse) ProtoMessage()

+ func (this *UpdateNexusIncomingServiceResponse) Equal(that interface{}) bool

+ func (val *UpdateNexusIncomingServiceResponse) Marshal() ([]byte, error)

+ func (val *UpdateNexusIncomingServiceResponse) Size() int

+ func (val *UpdateNexusIncomingServiceResponse) Unmarshal(buf []byte) error

+ func (x *UpdateNexusIncomingServiceResponse) GetService() *v11.IncomingService

+ func (x *UpdateNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateNexusIncomingServiceResponse) Reset()

+ func (x *UpdateNexusIncomingServiceResponse) String() string

+ type UpdateNexusOutgoingServiceRequest struct

+ Name string

+ Namespace string

+ Spec *v11.OutgoingServiceSpec

+ Version int64

+ func (*UpdateNexusOutgoingServiceRequest) Descriptor() ([]byte, []int)

+ func (*UpdateNexusOutgoingServiceRequest) ProtoMessage()

+ func (this *UpdateNexusOutgoingServiceRequest) Equal(that interface{}) bool

+ func (val *UpdateNexusOutgoingServiceRequest) Marshal() ([]byte, error)

+ func (val *UpdateNexusOutgoingServiceRequest) Size() int

+ func (val *UpdateNexusOutgoingServiceRequest) Unmarshal(buf []byte) error

+ func (x *UpdateNexusOutgoingServiceRequest) GetName() string

+ func (x *UpdateNexusOutgoingServiceRequest) GetNamespace() string

+ func (x *UpdateNexusOutgoingServiceRequest) GetSpec() *v11.OutgoingServiceSpec

+ func (x *UpdateNexusOutgoingServiceRequest) GetVersion() int64

+ func (x *UpdateNexusOutgoingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateNexusOutgoingServiceRequest) Reset()

+ func (x *UpdateNexusOutgoingServiceRequest) String() string

+ type UpdateNexusOutgoingServiceResponse struct

+ Service *v11.OutgoingService

+ func (*UpdateNexusOutgoingServiceResponse) Descriptor() ([]byte, []int)

+ func (*UpdateNexusOutgoingServiceResponse) ProtoMessage()

+ func (this *UpdateNexusOutgoingServiceResponse) Equal(that interface{}) bool

+ func (val *UpdateNexusOutgoingServiceResponse) Marshal() ([]byte, error)

+ func (val *UpdateNexusOutgoingServiceResponse) Size() int

+ func (val *UpdateNexusOutgoingServiceResponse) Unmarshal(buf []byte) error

+ func (x *UpdateNexusOutgoingServiceResponse) GetService() *v11.OutgoingService

+ func (x *UpdateNexusOutgoingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateNexusOutgoingServiceResponse) Reset()

+ func (x *UpdateNexusOutgoingServiceResponse) String() string

Mar 11, 2024

Changes in this version

type CreateOrUpdateNexusIncomingServiceRequest

+ TargetNamespace string

+ TargetTaskQueue string

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetTargetNamespace() string

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetTargetTaskQueue() string

Mar 11, 2024

Changes in this version

type CreateOrUpdateNexusIncomingServiceRequest

+ Metadata map[string]*anypb.Any

+ Name string

+ Namespace string

+ TaskQueue string

+ Version int64

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetMetadata() map[string]*anypb.Any

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetName() string

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetNamespace() string

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetTaskQueue() string

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetVersion() int64

Jan 31, 2024

Changes in this version

+ const OperatorService_CreateOrUpdateNexusIncomingService_FullMethodName

+ const OperatorService_DeleteNexusIncomingService_FullMethodName

+ const OperatorService_GetNexusIncomingService_FullMethodName

+ const OperatorService_ListNexusIncomingServices_FullMethodName

+ type CreateOrUpdateNexusIncomingServiceRequest struct

+ Service *v11.IncomingService

+ func (*CreateOrUpdateNexusIncomingServiceRequest) Descriptor() ([]byte, []int)

+ func (*CreateOrUpdateNexusIncomingServiceRequest) ProtoMessage()

+ func (this *CreateOrUpdateNexusIncomingServiceRequest) Equal(that interface{}) bool

+ func (val *CreateOrUpdateNexusIncomingServiceRequest) Marshal() ([]byte, error)

+ func (val *CreateOrUpdateNexusIncomingServiceRequest) Size() int

+ func (val *CreateOrUpdateNexusIncomingServiceRequest) Unmarshal(buf []byte) error

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) GetService() *v11.IncomingService

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) Reset()

+ func (x *CreateOrUpdateNexusIncomingServiceRequest) String() string

+ type CreateOrUpdateNexusIncomingServiceResponse struct

+ Service *v11.IncomingService

+ func (*CreateOrUpdateNexusIncomingServiceResponse) Descriptor() ([]byte, []int)

+ func (*CreateOrUpdateNexusIncomingServiceResponse) ProtoMessage()

+ func (this *CreateOrUpdateNexusIncomingServiceResponse) Equal(that interface{}) bool

+ func (val *CreateOrUpdateNexusIncomingServiceResponse) Marshal() ([]byte, error)

+ func (val *CreateOrUpdateNexusIncomingServiceResponse) Size() int

+ func (val *CreateOrUpdateNexusIncomingServiceResponse) Unmarshal(buf []byte) error

+ func (x *CreateOrUpdateNexusIncomingServiceResponse) GetService() *v11.IncomingService

+ func (x *CreateOrUpdateNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateOrUpdateNexusIncomingServiceResponse) Reset()

+ func (x *CreateOrUpdateNexusIncomingServiceResponse) String() string

type DeleteNamespaceRequest

+ NamespaceDeleteDelay *durationpb.Duration

+ func (x *DeleteNamespaceRequest) GetNamespaceDeleteDelay() *durationpb.Duration

+ type DeleteNexusIncomingServiceRequest struct

+ Name string

+ func (*DeleteNexusIncomingServiceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteNexusIncomingServiceRequest) ProtoMessage()

+ func (this *DeleteNexusIncomingServiceRequest) Equal(that interface{}) bool

+ func (val *DeleteNexusIncomingServiceRequest) Marshal() ([]byte, error)

+ func (val *DeleteNexusIncomingServiceRequest) Size() int

+ func (val *DeleteNexusIncomingServiceRequest) Unmarshal(buf []byte) error

+ func (x *DeleteNexusIncomingServiceRequest) GetName() string

+ func (x *DeleteNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteNexusIncomingServiceRequest) Reset()

+ func (x *DeleteNexusIncomingServiceRequest) String() string

+ type DeleteNexusIncomingServiceResponse struct

+ func (*DeleteNexusIncomingServiceResponse) Descriptor() ([]byte, []int)

+ func (*DeleteNexusIncomingServiceResponse) ProtoMessage()

+ func (this *DeleteNexusIncomingServiceResponse) Equal(that interface{}) bool

+ func (val *DeleteNexusIncomingServiceResponse) Marshal() ([]byte, error)

+ func (val *DeleteNexusIncomingServiceResponse) Size() int

+ func (val *DeleteNexusIncomingServiceResponse) Unmarshal(buf []byte) error

+ func (x *DeleteNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteNexusIncomingServiceResponse) Reset()

+ func (x *DeleteNexusIncomingServiceResponse) String() string

+ type GetNexusIncomingServiceRequest struct

+ Name string

+ func (*GetNexusIncomingServiceRequest) Descriptor() ([]byte, []int)

+ func (*GetNexusIncomingServiceRequest) ProtoMessage()

+ func (this *GetNexusIncomingServiceRequest) Equal(that interface{}) bool

+ func (val *GetNexusIncomingServiceRequest) Marshal() ([]byte, error)

+ func (val *GetNexusIncomingServiceRequest) Size() int

+ func (val *GetNexusIncomingServiceRequest) Unmarshal(buf []byte) error

+ func (x *GetNexusIncomingServiceRequest) GetName() string

+ func (x *GetNexusIncomingServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetNexusIncomingServiceRequest) Reset()

+ func (x *GetNexusIncomingServiceRequest) String() string

+ type GetNexusIncomingServiceResponse struct

+ Service *v11.IncomingService

+ func (*GetNexusIncomingServiceResponse) Descriptor() ([]byte, []int)

+ func (*GetNexusIncomingServiceResponse) ProtoMessage()

+ func (this *GetNexusIncomingServiceResponse) Equal(that interface{}) bool

+ func (val *GetNexusIncomingServiceResponse) Marshal() ([]byte, error)

+ func (val *GetNexusIncomingServiceResponse) Size() int

+ func (val *GetNexusIncomingServiceResponse) Unmarshal(buf []byte) error

+ func (x *GetNexusIncomingServiceResponse) GetService() *v11.IncomingService

+ func (x *GetNexusIncomingServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *GetNexusIncomingServiceResponse) Reset()

+ func (x *GetNexusIncomingServiceResponse) String() string

+ type ListNexusIncomingServicesRequest struct

+ NextPageToken []byte

+ PageSize int32

+ func (*ListNexusIncomingServicesRequest) Descriptor() ([]byte, []int)

+ func (*ListNexusIncomingServicesRequest) ProtoMessage()

+ func (this *ListNexusIncomingServicesRequest) Equal(that interface{}) bool

+ func (val *ListNexusIncomingServicesRequest) Marshal() ([]byte, error)

+ func (val *ListNexusIncomingServicesRequest) Size() int

+ func (val *ListNexusIncomingServicesRequest) Unmarshal(buf []byte) error

+ func (x *ListNexusIncomingServicesRequest) GetNextPageToken() []byte

+ func (x *ListNexusIncomingServicesRequest) GetPageSize() int32

+ func (x *ListNexusIncomingServicesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListNexusIncomingServicesRequest) Reset()

+ func (x *ListNexusIncomingServicesRequest) String() string

+ type ListNexusIncomingServicesResponse struct

+ NextPageToken []byte

+ Services []*v11.IncomingService

+ func (*ListNexusIncomingServicesResponse) Descriptor() ([]byte, []int)

+ func (*ListNexusIncomingServicesResponse) ProtoMessage()

+ func (this *ListNexusIncomingServicesResponse) Equal(that interface{}) bool

+ func (val *ListNexusIncomingServicesResponse) Marshal() ([]byte, error)

+ func (val *ListNexusIncomingServicesResponse) Size() int

+ func (val *ListNexusIncomingServicesResponse) Unmarshal(buf []byte) error

+ func (x *ListNexusIncomingServicesResponse) GetNextPageToken() []byte

+ func (x *ListNexusIncomingServicesResponse) GetServices() []*v11.IncomingService

+ func (x *ListNexusIncomingServicesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListNexusIncomingServicesResponse) Reset()

+ func (x *ListNexusIncomingServicesResponse) String() string

type OperatorServiceClient

+ CreateOrUpdateNexusIncomingService func(ctx context.Context, in *CreateOrUpdateNexusIncomingServiceRequest, ...) (*CreateOrUpdateNexusIncomingServiceResponse, error)

+ DeleteNexusIncomingService func(ctx context.Context, in *DeleteNexusIncomingServiceRequest, ...) (*DeleteNexusIncomingServiceResponse, error)

+ GetNexusIncomingService func(ctx context.Context, in *GetNexusIncomingServiceRequest, ...) (*GetNexusIncomingServiceResponse, error)

+ ListNexusIncomingServices func(ctx context.Context, in *ListNexusIncomingServicesRequest, ...) (*ListNexusIncomingServicesResponse, error)

type OperatorServiceServer

+ CreateOrUpdateNexusIncomingService func(context.Context, *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)

+ DeleteNexusIncomingService func(context.Context, *DeleteNexusIncomingServiceRequest) (*DeleteNexusIncomingServiceResponse, error)

+ GetNexusIncomingService func(context.Context, *GetNexusIncomingServiceRequest) (*GetNexusIncomingServiceResponse, error)

+ ListNexusIncomingServices func(context.Context, *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, error)

type UnimplementedOperatorServiceServer

+ func (UnimplementedOperatorServiceServer) CreateOrUpdateNexusIncomingService(context.Context, *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) DeleteNexusIncomingService(context.Context, *DeleteNexusIncomingServiceRequest) (*DeleteNexusIncomingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) GetNexusIncomingService(context.Context, *GetNexusIncomingServiceRequest) (*GetNexusIncomingServiceResponse, error)

+ func (UnimplementedOperatorServiceServer) ListNexusIncomingServices(context.Context, *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, error)

Nov 28, 2023

retracted

Changes in this version

+ const OperatorService_AddOrUpdateRemoteCluster_FullMethodName

+ const OperatorService_AddSearchAttributes_FullMethodName

+ const OperatorService_DeleteNamespace_FullMethodName

+ const OperatorService_ListClusters_FullMethodName

+ const OperatorService_ListSearchAttributes_FullMethodName

+ const OperatorService_RemoveRemoteCluster_FullMethodName

+ const OperatorService_RemoveSearchAttributes_FullMethodName

+ var File_temporal_api_operatorservice_v1_request_response_proto protoreflect.FileDescriptor

+ var File_temporal_api_operatorservice_v1_service_proto protoreflect.FileDescriptor

+ var OperatorService_ServiceDesc = grpc.ServiceDesc

type AddOrUpdateRemoteClusterRequest

+ func (x *AddOrUpdateRemoteClusterRequest) ProtoReflect() protoreflect.Message

type AddOrUpdateRemoteClusterResponse

+ func (x *AddOrUpdateRemoteClusterResponse) ProtoReflect() protoreflect.Message

type AddSearchAttributesRequest

+ func (x *AddSearchAttributesRequest) ProtoReflect() protoreflect.Message

type AddSearchAttributesResponse

+ func (x *AddSearchAttributesResponse) ProtoReflect() protoreflect.Message

type ClusterMetadata

+ func (x *ClusterMetadata) ProtoReflect() protoreflect.Message

type DeleteNamespaceRequest

+ func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message

type DeleteNamespaceResponse

+ func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message

type ListClustersRequest

+ func (x *ListClustersRequest) ProtoReflect() protoreflect.Message

type ListClustersResponse

+ func (x *ListClustersResponse) ProtoReflect() protoreflect.Message

type ListSearchAttributesRequest

+ func (x *ListSearchAttributesRequest) ProtoReflect() protoreflect.Message

type ListSearchAttributesResponse

+ func (x *ListSearchAttributesResponse) ProtoReflect() protoreflect.Message

type RemoveRemoteClusterRequest

+ func (x *RemoveRemoteClusterRequest) ProtoReflect() protoreflect.Message

type RemoveRemoteClusterResponse

+ func (x *RemoveRemoteClusterResponse) ProtoReflect() protoreflect.Message

type RemoveSearchAttributesRequest

+ func (x *RemoveSearchAttributesRequest) ProtoReflect() protoreflect.Message

type RemoveSearchAttributesResponse

+ func (x *RemoveSearchAttributesResponse) ProtoReflect() protoreflect.Message

+ type UnsafeOperatorServiceServer interface

Oct 27, 2023

Changes in this version

+ func RegisterOperatorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterOperatorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OperatorServiceClient) error

+ func RegisterOperatorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterOperatorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OperatorServiceServer) error

type DeleteNamespaceRequest

+ NamespaceId string

+ func (m *DeleteNamespaceRequest) GetNamespaceId() string

Feb 2, 2023

Changes in this version

type AddSearchAttributesRequest

+ Namespace string

+ func (m *AddSearchAttributesRequest) GetNamespace() string

type ListSearchAttributesRequest

+ Namespace string

+ func (m *ListSearchAttributesRequest) GetNamespace() string

type RemoveSearchAttributesRequest

+ Namespace string

+ func (m *RemoveSearchAttributesRequest) GetNamespace() string

Sep 13, 2022

Changes in this version

+ type ClusterMetadata struct

+ Address string

+ ClusterId string

+ ClusterName string

+ HistoryShardCount int32

+ InitialFailoverVersion int64

+ IsConnectionEnabled bool

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

+ func (*ClusterMetadata) ProtoMessage()

+ func (m *ClusterMetadata) GetAddress() string

+ func (m *ClusterMetadata) GetClusterId() string

+ func (m *ClusterMetadata) GetClusterName() string

+ func (m *ClusterMetadata) GetHistoryShardCount() int32

+ func (m *ClusterMetadata) GetInitialFailoverVersion() int64

+ func (m *ClusterMetadata) GetIsConnectionEnabled() bool

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

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

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

+ func (m *ClusterMetadata) Reset()

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

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

+ func (m *ClusterMetadata) XXX_DiscardUnknown()

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

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

+ func (m *ClusterMetadata) XXX_Size() int

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

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

+ func (this *ClusterMetadata) GoString() string

+ func (this *ClusterMetadata) String() string

Jun 16, 2022

Changes in this version

+ type AddOrUpdateRemoteClusterRequest struct

+ EnableRemoteClusterConnection bool

+ FrontendAddress string

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

+ func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

+ func (m *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

+ func (m *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

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

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

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

+ func (m *AddOrUpdateRemoteClusterRequest) Reset()

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

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

+ func (m *AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddOrUpdateRemoteClusterRequest) XXX_Size() int

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

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

+ func (this *AddOrUpdateRemoteClusterRequest) GoString() string

+ func (this *AddOrUpdateRemoteClusterRequest) String() string

+ type AddOrUpdateRemoteClusterResponse struct

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

+ func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

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

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

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

+ func (m *AddOrUpdateRemoteClusterResponse) Reset()

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

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

+ func (m *AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown()

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

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

+ func (m *AddOrUpdateRemoteClusterResponse) XXX_Size() int

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

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

+ func (this *AddOrUpdateRemoteClusterResponse) GoString() string

+ func (this *AddOrUpdateRemoteClusterResponse) String() string

+ type DescribeClusterRequest struct

+ ClusterName string

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

+ func (*DescribeClusterRequest) ProtoMessage()

+ func (m *DescribeClusterRequest) GetClusterName() string

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

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

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

+ func (m *DescribeClusterRequest) Reset()

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

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

+ func (m *DescribeClusterRequest) XXX_DiscardUnknown()

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

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

+ func (m *DescribeClusterRequest) XXX_Size() int

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

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

+ func (this *DescribeClusterRequest) GoString() string

+ func (this *DescribeClusterRequest) String() string

+ type DescribeClusterResponse struct

+ ClusterId string

+ ClusterName string

+ FailoverVersionIncrement int64

+ HistoryShardCount int32

+ InitialFailoverVersion int64

+ IsGlobalNamespaceEnabled bool

+ MembershipInfo *v12.MembershipInfo

+ PersistenceStore string

+ ServerVersion string

+ SupportedClients map[string]string

+ VersionInfo *v13.VersionInfo

+ VisibilityStore string

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

+ func (*DescribeClusterResponse) ProtoMessage()

+ func (m *DescribeClusterResponse) GetClusterId() string

+ func (m *DescribeClusterResponse) GetClusterName() string

+ func (m *DescribeClusterResponse) GetFailoverVersionIncrement() int64

+ func (m *DescribeClusterResponse) GetHistoryShardCount() int32

+ func (m *DescribeClusterResponse) GetInitialFailoverVersion() int64

+ func (m *DescribeClusterResponse) GetIsGlobalNamespaceEnabled() bool

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

+ func (m *DescribeClusterResponse) GetPersistenceStore() string

+ func (m *DescribeClusterResponse) GetServerVersion() string

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

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

+ func (m *DescribeClusterResponse) GetVisibilityStore() string

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

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

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

+ func (m *DescribeClusterResponse) Reset()

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

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

+ func (m *DescribeClusterResponse) XXX_DiscardUnknown()

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

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

+ func (m *DescribeClusterResponse) XXX_Size() int

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

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

+ func (this *DescribeClusterResponse) GoString() string

+ func (this *DescribeClusterResponse) String() string

+ type ListClusterMembersRequest struct

+ HostId string

+ LastHeartbeatWithin *time.Duration

+ NextPageToken []byte

+ PageSize int32

+ Role v1.ClusterMemberRole

+ RpcAddress string

+ SessionStartedAfterTime *time.Time

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

+ func (*ListClusterMembersRequest) ProtoMessage()

+ func (m *ListClusterMembersRequest) GetHostId() string

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

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

+ func (m *ListClusterMembersRequest) GetPageSize() int32

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

+ func (m *ListClusterMembersRequest) GetRpcAddress() string

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

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

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

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

+ func (m *ListClusterMembersRequest) Reset()

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

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

+ func (m *ListClusterMembersRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListClusterMembersRequest) XXX_Size() int

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

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

+ func (this *ListClusterMembersRequest) GoString() string

+ func (this *ListClusterMembersRequest) String() string

+ type ListClusterMembersResponse struct

+ ActiveMembers []*v12.ClusterMember

+ NextPageToken []byte

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

+ func (*ListClusterMembersResponse) ProtoMessage()

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

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

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

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

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

+ func (m *ListClusterMembersResponse) Reset()

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

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

+ func (m *ListClusterMembersResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListClusterMembersResponse) XXX_Size() int

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

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

+ func (this *ListClusterMembersResponse) GoString() string

+ func (this *ListClusterMembersResponse) String() string

+ type ListClustersRequest struct

+ NextPageToken []byte

+ PageSize int32

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

+ func (*ListClustersRequest) ProtoMessage()

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

+ func (m *ListClustersRequest) GetPageSize() int32

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

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

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

+ func (m *ListClustersRequest) Reset()

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

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

+ func (m *ListClustersRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListClustersRequest) XXX_Size() int

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

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

+ func (this *ListClustersRequest) GoString() string

+ func (this *ListClustersRequest) String() string

+ type ListClustersResponse struct

+ Clusters []*v12.ClusterMetadata

+ NextPageToken []byte

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

+ func (*ListClustersResponse) ProtoMessage()

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

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

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

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

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

+ func (m *ListClustersResponse) Reset()

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

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

+ func (m *ListClustersResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListClustersResponse) XXX_Size() int

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

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

+ func (this *ListClustersResponse) GoString() string

+ func (this *ListClustersResponse) String() string

type OperatorServiceClient

+ AddOrUpdateRemoteCluster func(ctx context.Context, in *AddOrUpdateRemoteClusterRequest, ...) (*AddOrUpdateRemoteClusterResponse, error)

+ DescribeCluster func(ctx context.Context, in *DescribeClusterRequest, opts ...grpc.CallOption) (*DescribeClusterResponse, error)

+ ListClusterMembers func(ctx context.Context, in *ListClusterMembersRequest, opts ...grpc.CallOption) (*ListClusterMembersResponse, error)

+ ListClusters func(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)

+ RemoveRemoteCluster func(ctx context.Context, in *RemoveRemoteClusterRequest, opts ...grpc.CallOption) (*RemoveRemoteClusterResponse, error)

type OperatorServiceServer

+ AddOrUpdateRemoteCluster func(context.Context, *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)

+ DescribeCluster func(context.Context, *DescribeClusterRequest) (*DescribeClusterResponse, error)

+ ListClusterMembers func(context.Context, *ListClusterMembersRequest) (*ListClusterMembersResponse, error)

+ ListClusters func(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

+ RemoveRemoteCluster func(context.Context, *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)

+ type RemoveRemoteClusterRequest struct

+ ClusterName string

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

+ func (*RemoveRemoteClusterRequest) ProtoMessage()

+ func (m *RemoveRemoteClusterRequest) GetClusterName() string

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

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

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

+ func (m *RemoveRemoteClusterRequest) Reset()

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

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

+ func (m *RemoveRemoteClusterRequest) XXX_DiscardUnknown()

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

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

+ func (m *RemoveRemoteClusterRequest) XXX_Size() int

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

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

+ func (this *RemoveRemoteClusterRequest) GoString() string

+ func (this *RemoveRemoteClusterRequest) String() string

+ type RemoveRemoteClusterResponse struct

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

+ func (*RemoveRemoteClusterResponse) ProtoMessage()

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

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

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

+ func (m *RemoveRemoteClusterResponse) Reset()

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

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

+ func (m *RemoveRemoteClusterResponse) XXX_DiscardUnknown()

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

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

+ func (m *RemoveRemoteClusterResponse) XXX_Size() int

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

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

+ func (this *RemoveRemoteClusterResponse) GoString() string

+ func (this *RemoveRemoteClusterResponse) String() string

type UnimplementedOperatorServiceServer

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

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

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

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

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

Jun 2, 2022

Changes in this version

+ var ErrIntOverflowRequestResponse = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRequestResponse = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")

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

+ type AddSearchAttributesRequest struct

+ SearchAttributes map[string]v1.IndexedValueType

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

+ func (*AddSearchAttributesRequest) ProtoMessage()

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

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

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

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

+ func (m *AddSearchAttributesRequest) Reset()

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

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

+ func (m *AddSearchAttributesRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddSearchAttributesRequest) XXX_Size() int

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

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

+ func (this *AddSearchAttributesRequest) GoString() string

+ func (this *AddSearchAttributesRequest) String() string

+ type AddSearchAttributesResponse struct

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

+ func (*AddSearchAttributesResponse) ProtoMessage()

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

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

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

+ func (m *AddSearchAttributesResponse) Reset()

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

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

+ func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()

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

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

+ func (m *AddSearchAttributesResponse) XXX_Size() int

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

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

+ func (this *AddSearchAttributesResponse) GoString() string

+ func (this *AddSearchAttributesResponse) String() string

+ type DeleteNamespaceRequest struct

+ Namespace string

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

+ func (*DeleteNamespaceRequest) ProtoMessage()

+ func (m *DeleteNamespaceRequest) GetNamespace() string

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

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

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

+ func (m *DeleteNamespaceRequest) Reset()

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

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

+ func (m *DeleteNamespaceRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteNamespaceRequest) XXX_Size() int

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

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

+ func (this *DeleteNamespaceRequest) GoString() string

+ func (this *DeleteNamespaceRequest) String() string

+ type DeleteNamespaceResponse struct

+ DeletedNamespace string

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

+ func (*DeleteNamespaceResponse) ProtoMessage()

+ func (m *DeleteNamespaceResponse) GetDeletedNamespace() string

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

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

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

+ func (m *DeleteNamespaceResponse) Reset()

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

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

+ func (m *DeleteNamespaceResponse) XXX_DiscardUnknown()

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

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

+ func (m *DeleteNamespaceResponse) XXX_Size() int

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

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

+ func (this *DeleteNamespaceResponse) GoString() string

+ func (this *DeleteNamespaceResponse) String() string

+ type DeleteWorkflowExecutionRequest struct

+ Namespace string

+ WorkflowExecution *v11.WorkflowExecution

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

+ func (*DeleteWorkflowExecutionRequest) ProtoMessage()

+ func (m *DeleteWorkflowExecutionRequest) GetNamespace() string

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

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

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

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

+ func (m *DeleteWorkflowExecutionRequest) Reset()

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

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

+ func (m *DeleteWorkflowExecutionRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteWorkflowExecutionRequest) XXX_Size() int

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

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

+ func (this *DeleteWorkflowExecutionRequest) GoString() string

+ func (this *DeleteWorkflowExecutionRequest) String() string

+ type DeleteWorkflowExecutionResponse struct

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

+ func (*DeleteWorkflowExecutionResponse) ProtoMessage()

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

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

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

+ func (m *DeleteWorkflowExecutionResponse) Reset()

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

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

+ func (m *DeleteWorkflowExecutionResponse) XXX_DiscardUnknown()

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

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

+ func (m *DeleteWorkflowExecutionResponse) XXX_Size() int

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

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

+ func (this *DeleteWorkflowExecutionResponse) GoString() string

+ func (this *DeleteWorkflowExecutionResponse) String() string

+ type ListSearchAttributesRequest struct

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

+ func (*ListSearchAttributesRequest) ProtoMessage()

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

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

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

+ func (m *ListSearchAttributesRequest) Reset()

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

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

+ func (m *ListSearchAttributesRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListSearchAttributesRequest) XXX_Size() int

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

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

+ func (this *ListSearchAttributesRequest) GoString() string

+ func (this *ListSearchAttributesRequest) String() string

+ type ListSearchAttributesResponse struct

+ CustomAttributes map[string]v1.IndexedValueType

+ StorageSchema map[string]string

+ SystemAttributes map[string]v1.IndexedValueType

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

+ func (*ListSearchAttributesResponse) ProtoMessage()

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

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

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

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

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

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

+ func (m *ListSearchAttributesResponse) Reset()

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

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

+ func (m *ListSearchAttributesResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListSearchAttributesResponse) XXX_Size() int

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

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

+ func (this *ListSearchAttributesResponse) GoString() string

+ func (this *ListSearchAttributesResponse) String() string

+ type OperatorServiceClient interface

+ AddSearchAttributes func(ctx context.Context, in *AddSearchAttributesRequest, opts ...grpc.CallOption) (*AddSearchAttributesResponse, error)

+ DeleteNamespace func(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error)

+ DeleteWorkflowExecution func(ctx context.Context, in *DeleteWorkflowExecutionRequest, ...) (*DeleteWorkflowExecutionResponse, error)

+ ListSearchAttributes func(ctx context.Context, in *ListSearchAttributesRequest, opts ...grpc.CallOption) (*ListSearchAttributesResponse, error)

+ RemoveSearchAttributes func(ctx context.Context, in *RemoveSearchAttributesRequest, ...) (*RemoveSearchAttributesResponse, error)

+ func NewOperatorServiceClient(cc *grpc.ClientConn) OperatorServiceClient

+ type OperatorServiceServer interface

+ AddSearchAttributes func(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

+ DeleteNamespace func(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)

+ DeleteWorkflowExecution func(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)

+ ListSearchAttributes func(context.Context, *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)

+ RemoveSearchAttributes func(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)

+ type RemoveSearchAttributesRequest struct

+ SearchAttributes []string

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

+ func (*RemoveSearchAttributesRequest) ProtoMessage()

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

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

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

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

+ func (m *RemoveSearchAttributesRequest) Reset()

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

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

+ func (m *RemoveSearchAttributesRequest) XXX_DiscardUnknown()

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

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

+ func (m *RemoveSearchAttributesRequest) XXX_Size() int

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

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

+ func (this *RemoveSearchAttributesRequest) GoString() string

+ func (this *RemoveSearchAttributesRequest) String() string

+ type RemoveSearchAttributesResponse struct

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

+ func (*RemoveSearchAttributesResponse) ProtoMessage()

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

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

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

+ func (m *RemoveSearchAttributesResponse) Reset()

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

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

+ func (m *RemoveSearchAttributesResponse) XXX_DiscardUnknown()

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

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

+ func (m *RemoveSearchAttributesResponse) XXX_Size() int

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

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

+ func (this *RemoveSearchAttributesResponse) GoString() string

+ func (this *RemoveSearchAttributesResponse) String() string

+ type UnimplementedOperatorServiceServer struct

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

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

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

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

+ func (*UnimplementedOperatorServiceServer) RemoveSearchAttributes(ctx context.Context, req *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)