operator

package
v0.0.0-...-ac20c72 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2024 License: Apache-2.0 Imports: 10 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	Operator_GetCapabilities_FullMethodName       = "/cnpgi.operator.v1.Operator/GetCapabilities"
	Operator_ValidateClusterCreate_FullMethodName = "/cnpgi.operator.v1.Operator/ValidateClusterCreate"
	Operator_ValidateClusterChange_FullMethodName = "/cnpgi.operator.v1.Operator/ValidateClusterChange"
	Operator_MutateCluster_FullMethodName         = "/cnpgi.operator.v1.Operator/MutateCluster"
	Operator_SetStatusInCluster_FullMethodName    = "/cnpgi.operator.v1.Operator/SetStatusInCluster"
	Operator_Deregister_FullMethodName            = "/cnpgi.operator.v1.Operator/Deregister"
)

Variables

View Source 
var (
	OperatorCapability_RPC_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_VALIDATE_CLUSTER_CREATE",
		2: "TYPE_VALIDATE_CLUSTER_CHANGE",
		3: "TYPE_MUTATE_CLUSTER",
		5: "TYPE_SET_STATUS_IN_CLUSTER",
		6: "TYPE_DEREGISTER",
	}
	OperatorCapability_RPC_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":             0,
		"TYPE_VALIDATE_CLUSTER_CREATE": 1,
		"TYPE_VALIDATE_CLUSTER_CHANGE": 2,
		"TYPE_MUTATE_CLUSTER":          3,
		"TYPE_SET_STATUS_IN_CLUSTER":   5,
		"TYPE_DEREGISTER":              6,
	}
)

Enum value maps for OperatorCapability_RPC_Type.

View Source 
var File_proto_operator_proto protoreflect.FileDescriptor
View Source 
var Operator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cnpgi.operator.v1.Operator",
	HandlerType: (*OperatorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCapabilities",
			Handler:    _Operator_GetCapabilities_Handler,
		},
		{
			MethodName: "ValidateClusterCreate",
			Handler:    _Operator_ValidateClusterCreate_Handler,
		},
		{
			MethodName: "ValidateClusterChange",
			Handler:    _Operator_ValidateClusterChange_Handler,
		},
		{
			MethodName: "MutateCluster",
			Handler:    _Operator_MutateCluster_Handler,
		},
		{
			MethodName: "SetStatusInCluster",
			Handler:    _Operator_SetStatusInCluster_Handler,
		},
		{
			MethodName: "Deregister",
			Handler:    _Operator_Deregister_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/operator.proto",
}

Operator_ServiceDesc is the grpc.ServiceDesc for Operator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOperatorServer 

func RegisterOperatorServer(s grpc.ServiceRegistrar, srv OperatorServer)

Types

type DeregisterRequest 

type DeregisterRequest struct {

	// This field is REQUIRED. Value of this field is the JSON
	// serialization of the Cluster that should receive the
	// default values
	Definition []byte `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

func (*DeregisterRequest) Descriptor deprecated 

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

Deprecated: Use DeregisterRequest.ProtoReflect.Descriptor instead.

func (*DeregisterRequest) GetDefinition 

func (x *DeregisterRequest) GetDefinition() []byte

func (*DeregisterRequest) ProtoMessage 

func (*DeregisterRequest) ProtoMessage()

func (*DeregisterRequest) ProtoReflect 

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

func (*DeregisterRequest) Reset 

func (x *DeregisterRequest) Reset()

func (*DeregisterRequest) String 

func (x *DeregisterRequest) String() string

type DeregisterResponse 

type DeregisterResponse struct {
	// contains filtered or unexported fields
}

func (*DeregisterResponse) Descriptor deprecated 

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

Deprecated: Use DeregisterResponse.ProtoReflect.Descriptor instead.

func (*DeregisterResponse) ProtoMessage 

func (*DeregisterResponse) ProtoMessage()

func (*DeregisterResponse) ProtoReflect 

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

func (*DeregisterResponse) Reset 

func (x *DeregisterResponse) Reset()

func (*DeregisterResponse) String 

func (x *DeregisterResponse) String() string

type OperatorCapabilitiesRequest 

type OperatorCapabilitiesRequest struct {
	// contains filtered or unexported fields
}

func (*OperatorCapabilitiesRequest) Descriptor deprecated 

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

Deprecated: Use OperatorCapabilitiesRequest.ProtoReflect.Descriptor instead.

func (*OperatorCapabilitiesRequest) ProtoMessage 

func (*OperatorCapabilitiesRequest) ProtoMessage()

func (*OperatorCapabilitiesRequest) ProtoReflect 

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

func (*OperatorCapabilitiesRequest) Reset 

func (x *OperatorCapabilitiesRequest) Reset()

func (*OperatorCapabilitiesRequest) String 

func (x *OperatorCapabilitiesRequest) String() string

type OperatorCapabilitiesResult 

type OperatorCapabilitiesResult struct {

	// All the capabilities that the controller service supports. This
	// field is OPTIONAL.
	Capabilities []*OperatorCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorCapabilitiesResult) Descriptor deprecated 

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

Deprecated: Use OperatorCapabilitiesResult.ProtoReflect.Descriptor instead.

func (*OperatorCapabilitiesResult) GetCapabilities 

func (x *OperatorCapabilitiesResult) GetCapabilities() []*OperatorCapability

func (*OperatorCapabilitiesResult) ProtoMessage 

func (*OperatorCapabilitiesResult) ProtoMessage()

func (*OperatorCapabilitiesResult) ProtoReflect 

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

func (*OperatorCapabilitiesResult) Reset 

func (x *OperatorCapabilitiesResult) Reset()

func (*OperatorCapabilitiesResult) String 

func (x *OperatorCapabilitiesResult) String() string

type OperatorCapability 

type OperatorCapability struct {

	// Types that are assignable to Type:
	//
	//	*OperatorCapability_Rpc
	Type isOperatorCapability_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*OperatorCapability) Descriptor deprecated 

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

Deprecated: Use OperatorCapability.ProtoReflect.Descriptor instead.

func (*OperatorCapability) GetRpc 

func (x *OperatorCapability) GetRpc() *OperatorCapability_RPC

func (*OperatorCapability) GetType 

func (m *OperatorCapability) GetType() isOperatorCapability_Type

func (*OperatorCapability) ProtoMessage 

func (*OperatorCapability) ProtoMessage()

func (*OperatorCapability) ProtoReflect 

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

func (*OperatorCapability) Reset 

func (x *OperatorCapability) Reset()

func (*OperatorCapability) String 

func (x *OperatorCapability) String() string

type OperatorCapability_RPC 

type OperatorCapability_RPC struct {
	Type OperatorCapability_RPC_Type `protobuf:"varint,1,opt,name=type,proto3,enum=cnpgi.operator.v1.OperatorCapability_RPC_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorCapability_RPC) Descriptor deprecated 

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

Deprecated: Use OperatorCapability_RPC.ProtoReflect.Descriptor instead.

func (*OperatorCapability_RPC) GetType 

func (x *OperatorCapability_RPC) GetType() OperatorCapability_RPC_Type

func (*OperatorCapability_RPC) ProtoMessage 

func (*OperatorCapability_RPC) ProtoMessage()

func (*OperatorCapability_RPC) ProtoReflect 

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

func (*OperatorCapability_RPC) Reset 

func (x *OperatorCapability_RPC) Reset()

func (*OperatorCapability_RPC) String 

func (x *OperatorCapability_RPC) String() string

type OperatorCapability_RPC_Type 

type OperatorCapability_RPC_Type int32
const (
	OperatorCapability_RPC_TYPE_UNSPECIFIED OperatorCapability_RPC_Type = 0
	// TYPE_VALIDATE_CLUSTER_CREATE indicates that the Plugin is able to
	// reply to the ValidateClusterCreate RPC request
	OperatorCapability_RPC_TYPE_VALIDATE_CLUSTER_CREATE OperatorCapability_RPC_Type = 1
	// TYPE_VALIDATE_CLUSTER_CHANGE indicates that the Plugin is able to
	// reply to the ValidateClusterChange RPC request
	OperatorCapability_RPC_TYPE_VALIDATE_CLUSTER_CHANGE OperatorCapability_RPC_Type = 2
	// TYPE_MUTATE_CLUSTER indicates that the Plugin is able to
	// reply to the MutateCluster RPC request
	OperatorCapability_RPC_TYPE_MUTATE_CLUSTER OperatorCapability_RPC_Type = 3
	// TYPE_SET_STATUS_IN_CLUSTER indicates that the Plugin is able to
	// reply to the SetStatusInCluster RPC request
	OperatorCapability_RPC_TYPE_SET_STATUS_IN_CLUSTER OperatorCapability_RPC_Type = 5
	// TYPE_DEREGISTER indicates that the Plugin is able to execute the cleanup logic once it is removed from
	// the cluster definition
	OperatorCapability_RPC_TYPE_DEREGISTER OperatorCapability_RPC_Type = 6
)

func (OperatorCapability_RPC_Type) Descriptor 

func (OperatorCapability_RPC_Type) Descriptor() protoreflect.EnumDescriptor

func (OperatorCapability_RPC_Type) Enum 

func (x OperatorCapability_RPC_Type) Enum() *OperatorCapability_RPC_Type

func (OperatorCapability_RPC_Type) EnumDescriptor deprecated 

func (OperatorCapability_RPC_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use OperatorCapability_RPC_Type.Descriptor instead.

func (OperatorCapability_RPC_Type) Number 

func (x OperatorCapability_RPC_Type) Number() protoreflect.EnumNumber

func (OperatorCapability_RPC_Type) String 

func (x OperatorCapability_RPC_Type) String() string

func (OperatorCapability_RPC_Type) Type 

func (OperatorCapability_RPC_Type) Type() protoreflect.EnumType

type OperatorCapability_Rpc 

type OperatorCapability_Rpc struct {
	Rpc *OperatorCapability_RPC `protobuf:"bytes,1,opt,name=rpc,proto3,oneof"`
}

type OperatorClient 

type OperatorClient interface {
	// GetCapabilities gets the capabilities of the WAL service
	GetCapabilities(ctx context.Context, in *OperatorCapabilitiesRequest, opts ...grpc.CallOption) (*OperatorCapabilitiesResult, error)
	// ValidateCreate improves the behavior of the validating webhook that
	// is called on creation of the Cluster resources
	ValidateClusterCreate(ctx context.Context, in *OperatorValidateClusterCreateRequest, opts ...grpc.CallOption) (*OperatorValidateClusterCreateResult, error)
	// ValidateClusterChange improves the behavior of the validating webhook of
	// is called on updates of the Cluster resources
	ValidateClusterChange(ctx context.Context, in *OperatorValidateClusterChangeRequest, opts ...grpc.CallOption) (*OperatorValidateClusterChangeResult, error)
	// MutateCluster fills in the defaults inside a Cluster resource
	MutateCluster(ctx context.Context, in *OperatorMutateClusterRequest, opts ...grpc.CallOption) (*OperatorMutateClusterResult, error)
	// SetStatusInCluster is invoked at the end of the reconciliation loop and it is used to set the plugin status
	// inside the .status.plugins[pluginName] map key
	SetStatusInCluster(ctx context.Context, in *SetStatusInClusterRequest, opts ...grpc.CallOption) (*SetStatusInClusterResponse, error)
	// Deregister is invoked when the plugin is removed from the cluster definition. It is expected that the plugin
	// executes its cleanup logic when this method is invoked.
	Deregister(ctx context.Context, in *DeregisterRequest, opts ...grpc.CallOption) (*DeregisterResponse, error)
}

OperatorClient is the client API for Operator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOperatorClient 

func NewOperatorClient(cc grpc.ClientConnInterface) OperatorClient

type OperatorMutateClusterRequest 

type OperatorMutateClusterRequest struct {

	// This field is REQUIRED. Value of this field is the JSON
	// serialization of the Cluster that should receive the
	// default values
	Definition []byte `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorMutateClusterRequest) Descriptor deprecated 

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

Deprecated: Use OperatorMutateClusterRequest.ProtoReflect.Descriptor instead.

func (*OperatorMutateClusterRequest) GetDefinition 

func (x *OperatorMutateClusterRequest) GetDefinition() []byte

func (*OperatorMutateClusterRequest) ProtoMessage 

func (*OperatorMutateClusterRequest) ProtoMessage()

func (*OperatorMutateClusterRequest) ProtoReflect 

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

func (*OperatorMutateClusterRequest) Reset 

func (x *OperatorMutateClusterRequest) Reset()

func (*OperatorMutateClusterRequest) String 

func (x *OperatorMutateClusterRequest) String() string

type OperatorMutateClusterResult 

type OperatorMutateClusterResult struct {

	// This field is OPTIONAL. Value of this field is a JSONPatch
	// to be applied on the passed Cluster definition
	JsonPatch []byte `protobuf:"bytes,1,opt,name=json_patch,json=jsonPatch,proto3" json:"json_patch,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorMutateClusterResult) Descriptor deprecated 

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

Deprecated: Use OperatorMutateClusterResult.ProtoReflect.Descriptor instead.

func (*OperatorMutateClusterResult) GetJsonPatch 

func (x *OperatorMutateClusterResult) GetJsonPatch() []byte

func (*OperatorMutateClusterResult) ProtoMessage 

func (*OperatorMutateClusterResult) ProtoMessage()

func (*OperatorMutateClusterResult) ProtoReflect 

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

func (*OperatorMutateClusterResult) Reset 

func (x *OperatorMutateClusterResult) Reset()

func (*OperatorMutateClusterResult) String 

func (x *OperatorMutateClusterResult) String() string

type OperatorServer 

type OperatorServer interface {
	// GetCapabilities gets the capabilities of the WAL service
	GetCapabilities(context.Context, *OperatorCapabilitiesRequest) (*OperatorCapabilitiesResult, error)
	// ValidateCreate improves the behavior of the validating webhook that
	// is called on creation of the Cluster resources
	ValidateClusterCreate(context.Context, *OperatorValidateClusterCreateRequest) (*OperatorValidateClusterCreateResult, error)
	// ValidateClusterChange improves the behavior of the validating webhook of
	// is called on updates of the Cluster resources
	ValidateClusterChange(context.Context, *OperatorValidateClusterChangeRequest) (*OperatorValidateClusterChangeResult, error)
	// MutateCluster fills in the defaults inside a Cluster resource
	MutateCluster(context.Context, *OperatorMutateClusterRequest) (*OperatorMutateClusterResult, error)
	// SetStatusInCluster is invoked at the end of the reconciliation loop and it is used to set the plugin status
	// inside the .status.plugins[pluginName] map key
	SetStatusInCluster(context.Context, *SetStatusInClusterRequest) (*SetStatusInClusterResponse, error)
	// Deregister is invoked when the plugin is removed from the cluster definition. It is expected that the plugin
	// executes its cleanup logic when this method is invoked.
	Deregister(context.Context, *DeregisterRequest) (*DeregisterResponse, error)
	// contains filtered or unexported methods
}

OperatorServer is the server API for Operator service. All implementations must embed UnimplementedOperatorServer for forward compatibility

type OperatorValidateClusterChangeRequest 

type OperatorValidateClusterChangeRequest struct {

	// This field is REQUIRED. Value of this field is the JSON
	// serialization of the current Cluster definition
	OldCluster []byte `protobuf:"bytes,1,opt,name=old_cluster,json=oldCluster,proto3" json:"old_cluster,omitempty"`
	// This field is REQUIRED. Value of this field is the JSON
	// serialization of the updated Cluster definition
	NewCluster []byte `protobuf:"bytes,2,opt,name=new_cluster,json=newCluster,proto3" json:"new_cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorValidateClusterChangeRequest) Descriptor deprecated 

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

Deprecated: Use OperatorValidateClusterChangeRequest.ProtoReflect.Descriptor instead.

func (*OperatorValidateClusterChangeRequest) GetNewCluster 

func (x *OperatorValidateClusterChangeRequest) GetNewCluster() []byte

func (*OperatorValidateClusterChangeRequest) GetOldCluster 

func (x *OperatorValidateClusterChangeRequest) GetOldCluster() []byte

func (*OperatorValidateClusterChangeRequest) ProtoMessage 

func (*OperatorValidateClusterChangeRequest) ProtoMessage()

func (*OperatorValidateClusterChangeRequest) ProtoReflect 

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

func (*OperatorValidateClusterChangeRequest) Reset 

func (x *OperatorValidateClusterChangeRequest) Reset()

func (*OperatorValidateClusterChangeRequest) String 

func (x *OperatorValidateClusterChangeRequest) String() string

type OperatorValidateClusterChangeResult 

type OperatorValidateClusterChangeResult struct {

	// This field is OPTIONAL. Value of this field is a set
	// of validation errors
	ValidationErrors []*ValidationError `protobuf:"bytes,1,rep,name=validation_errors,json=validationErrors,proto3" json:"validation_errors,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorValidateClusterChangeResult) Descriptor deprecated 

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

Deprecated: Use OperatorValidateClusterChangeResult.ProtoReflect.Descriptor instead.

func (*OperatorValidateClusterChangeResult) GetValidationErrors 

func (x *OperatorValidateClusterChangeResult) GetValidationErrors() []*ValidationError

func (*OperatorValidateClusterChangeResult) ProtoMessage 

func (*OperatorValidateClusterChangeResult) ProtoMessage()

func (*OperatorValidateClusterChangeResult) ProtoReflect 

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

func (*OperatorValidateClusterChangeResult) Reset 

func (x *OperatorValidateClusterChangeResult) Reset()

func (*OperatorValidateClusterChangeResult) String 

func (x *OperatorValidateClusterChangeResult) String() string

type OperatorValidateClusterCreateRequest 

type OperatorValidateClusterCreateRequest struct {

	// This field is REQUIRED. Value of this field is the JSON
	// serialization of the Cluster that is being created
	Definition []byte `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorValidateClusterCreateRequest) Descriptor deprecated 

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

Deprecated: Use OperatorValidateClusterCreateRequest.ProtoReflect.Descriptor instead.

func (*OperatorValidateClusterCreateRequest) GetDefinition 

func (x *OperatorValidateClusterCreateRequest) GetDefinition() []byte

func (*OperatorValidateClusterCreateRequest) ProtoMessage 

func (*OperatorValidateClusterCreateRequest) ProtoMessage()

func (*OperatorValidateClusterCreateRequest) ProtoReflect 

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

func (*OperatorValidateClusterCreateRequest) Reset 

func (x *OperatorValidateClusterCreateRequest) Reset()

func (*OperatorValidateClusterCreateRequest) String 

func (x *OperatorValidateClusterCreateRequest) String() string

type OperatorValidateClusterCreateResult 

type OperatorValidateClusterCreateResult struct {

	// This field is OPTIONAL. Value of this field is a set
	// of validation errors
	ValidationErrors []*ValidationError `protobuf:"bytes,1,rep,name=validation_errors,json=validationErrors,proto3" json:"validation_errors,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorValidateClusterCreateResult) Descriptor deprecated 

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

Deprecated: Use OperatorValidateClusterCreateResult.ProtoReflect.Descriptor instead.

func (*OperatorValidateClusterCreateResult) GetValidationErrors 

func (x *OperatorValidateClusterCreateResult) GetValidationErrors() []*ValidationError

func (*OperatorValidateClusterCreateResult) ProtoMessage 

func (*OperatorValidateClusterCreateResult) ProtoMessage()

func (*OperatorValidateClusterCreateResult) ProtoReflect 

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

func (*OperatorValidateClusterCreateResult) Reset 

func (x *OperatorValidateClusterCreateResult) Reset()

func (*OperatorValidateClusterCreateResult) String 

func (x *OperatorValidateClusterCreateResult) String() string

type SetStatusInClusterRequest 

type SetStatusInClusterRequest struct {

	// This field is REQUIRED. Value of this field is the JSON
	// serialization of the current Cluster definition
	Cluster []byte `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStatusInClusterRequest) Descriptor deprecated 

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

Deprecated: Use SetStatusInClusterRequest.ProtoReflect.Descriptor instead.

func (*SetStatusInClusterRequest) GetCluster 

func (x *SetStatusInClusterRequest) GetCluster() []byte

func (*SetStatusInClusterRequest) ProtoMessage 

func (*SetStatusInClusterRequest) ProtoMessage()

func (*SetStatusInClusterRequest) ProtoReflect 

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

func (*SetStatusInClusterRequest) Reset 

func (x *SetStatusInClusterRequest) Reset()

func (*SetStatusInClusterRequest) String 

func (x *SetStatusInClusterRequest) String() string

type SetStatusInClusterResponse 

type SetStatusInClusterResponse struct {

	// This field is OPTIONAL. No value means no-op, otherwise the passed json is set inside the
	// .status.plugins[pluginName] key
	JsonStatus []byte `protobuf:"bytes,1,opt,name=json_status,json=jsonStatus,proto3" json:"json_status,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStatusInClusterResponse) Descriptor deprecated 

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

Deprecated: Use SetStatusInClusterResponse.ProtoReflect.Descriptor instead.

func (*SetStatusInClusterResponse) GetJsonStatus 

func (x *SetStatusInClusterResponse) GetJsonStatus() []byte

func (*SetStatusInClusterResponse) ProtoMessage 

func (*SetStatusInClusterResponse) ProtoMessage()

func (*SetStatusInClusterResponse) ProtoReflect 

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

func (*SetStatusInClusterResponse) Reset 

func (x *SetStatusInClusterResponse) Reset()

func (*SetStatusInClusterResponse) String 

func (x *SetStatusInClusterResponse) String() string

type UnimplementedOperatorServer 

type UnimplementedOperatorServer struct {
}

UnimplementedOperatorServer must be embedded to have forward compatible implementations.

func (UnimplementedOperatorServer) Deregister 

func (UnimplementedOperatorServer) Deregister(context.Context, *DeregisterRequest) (*DeregisterResponse, error)

func (UnimplementedOperatorServer) GetCapabilities 

func (UnimplementedOperatorServer) GetCapabilities(context.Context, *OperatorCapabilitiesRequest) (*OperatorCapabilitiesResult, error)

func (UnimplementedOperatorServer) MutateCluster 

func (UnimplementedOperatorServer) MutateCluster(context.Context, *OperatorMutateClusterRequest) (*OperatorMutateClusterResult, error)

func (UnimplementedOperatorServer) SetStatusInCluster 

func (UnimplementedOperatorServer) SetStatusInCluster(context.Context, *SetStatusInClusterRequest) (*SetStatusInClusterResponse, error)

func (UnimplementedOperatorServer) ValidateClusterChange 

func (UnimplementedOperatorServer) ValidateClusterChange(context.Context, *OperatorValidateClusterChangeRequest) (*OperatorValidateClusterChangeResult, error)

func (UnimplementedOperatorServer) ValidateClusterCreate 

func (UnimplementedOperatorServer) ValidateClusterCreate(context.Context, *OperatorValidateClusterCreateRequest) (*OperatorValidateClusterCreateResult, error)

type UnsafeOperatorServer 

type UnsafeOperatorServer interface {
	// contains filtered or unexported methods
}

UnsafeOperatorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperatorServer will result in compilation errors.

type ValidationError 

type ValidationError struct {

	// This field is REQUIRED. Value of this field is
	PathComponents []string `protobuf:"bytes,1,rep,name=path_components,json=pathComponents,proto3" json:"path_components,omitempty"`
	// This field is REQUIRED. Value of this field is
	// the value that caused a validation error
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// This field is REQUIRED. Value of this field is a
	// description of the validation error
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidationError) Descriptor deprecated 

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

Deprecated: Use ValidationError.ProtoReflect.Descriptor instead.

func (*ValidationError) Error 

func (v *ValidationError) Error() string

func (*ValidationError) GetMessage 

func (x *ValidationError) GetMessage() string

func (*ValidationError) GetPathComponents 

func (x *ValidationError) GetPathComponents() []string

func (*ValidationError) GetValue 

func (x *ValidationError) GetValue() string

func (*ValidationError) ProtoMessage 

func (*ValidationError) ProtoMessage()

func (*ValidationError) ProtoReflect 

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

func (*ValidationError) Reset 

func (x *ValidationError) Reset()

func (*ValidationError) String 

func (x *ValidationError) String() string

type ValidationErrors 

type ValidationErrors []*ValidationError

ValidationErrors is a list of validation errors.

func (ValidationErrors) Error 

func (v ValidationErrors) Error() string

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.