pb

package
v0.7.5 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RoleType_name = map[int32]string{
		0: "ApiServer",
		1: "Ingress",
	}
	RoleType_value = map[string]int32{
		"ApiServer": 0,
		"Ingress":   1,
	}
)

Enum value maps for RoleType.

View Source 
var (
	Target_name = map[int32]string{
		0: "k8sAllNodes",
		1: "k8sControlPlane",
		2: "k8sComputePlane",
	}
	Target_value = map[string]int32{
		"k8sAllNodes":     0,
		"k8sControlPlane": 1,
		"k8sComputePlane": 2,
	}
)

Enum value maps for Target.

View Source 
var (
	NodeType_name = map[int32]string{
		0: "worker",
		1: "master",
		2: "apiEndpoint",
	}
	NodeType_value = map[string]int32{
		"worker":      0,
		"master":      1,
		"apiEndpoint": 2,
	}
)

Enum value maps for NodeType.

View Source 
var (
	StaticNodepoolInfo_name = map[int32]string{
		0: "STATIC_PROVIDER",
		1: "STATIC_REGION",
		2: "STATIC_ZONE",
	}
	StaticNodepoolInfo_value = map[string]int32{
		"STATIC_PROVIDER": 0,
		"STATIC_REGION":   1,
		"STATIC_ZONE":     2,
	}
)

Enum value maps for StaticNodepoolInfo.

View Source 
var (
	ClusterType_name = map[int32]string{
		0: "K8s",
		1: "LB",
	}
	ClusterType_value = map[string]int32{
		"K8s": 0,
		"LB":  1,
	}
)

Enum value maps for ClusterType.

View Source 
var (
	Workflow_Stage_name = map[int32]string{
		0: "NONE",
		1: "TERRAFORMER",
		2: "ANSIBLER",
		3: "KUBE_ELEVEN",
		4: "KUBER",
		5: "SCHEDULER",
		7: "DESTROY_TERRAFORMER",
		8: "DESTROY_KUBER",
		9: "DELETE_NODES",
	}
	Workflow_Stage_value = map[string]int32{
		"NONE":                0,
		"TERRAFORMER":         1,
		"ANSIBLER":            2,
		"KUBE_ELEVEN":         3,
		"KUBER":               4,
		"SCHEDULER":           5,
		"DESTROY_TERRAFORMER": 7,
		"DESTROY_KUBER":       8,
		"DELETE_NODES":        9,
	}
)

Enum value maps for Workflow_Stage.

View Source 
var (
	Workflow_Status_name = map[int32]string{
		0: "DONE",
		1: "ERROR",
		2: "IN_PROGRESS",
	}
	Workflow_Status_value = map[string]int32{
		"DONE":        0,
		"ERROR":       1,
		"IN_PROGRESS": 2,
	}
)

Enum value maps for Workflow_Status.

View Source 
var (
	IdType_name = map[int32]string{
		0: "NAME",
		1: "HASH",
	}
	IdType_value = map[string]int32{
		"NAME": 0,
		"HASH": 1,
	}
)

Enum value maps for IdType.

View Source 
var AnsiblerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "claudie.AnsiblerService",
	HandlerType: (*AnsiblerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InstallNodeRequirements",
			Handler:    _AnsiblerService_InstallNodeRequirements_Handler,
		},
		{
			MethodName: "InstallVPN",
			Handler:    _AnsiblerService_InstallVPN_Handler,
		},
		{
			MethodName: "SetUpLoadbalancers",
			Handler:    _AnsiblerService_SetUpLoadbalancers_Handler,
		},
		{
			MethodName: "TeardownLoadBalancers",
			Handler:    _AnsiblerService_TeardownLoadBalancers_Handler,
		},
		{
			MethodName: "UpdateAPIEndpoint",
			Handler:    _AnsiblerService_UpdateAPIEndpoint_Handler,
		},
		{
			MethodName: "RemoveClaudieUtilities",
			Handler:    _AnsiblerService_RemoveClaudieUtilities_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/ansibler.proto",
}

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

View Source 
var ContextBoxService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "claudie.ContextBoxService",
	HandlerType: (*ContextBoxServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SaveConfigOperator",
			Handler:    _ContextBoxService_SaveConfigOperator_Handler,
		},
		{
			MethodName: "SaveConfigScheduler",
			Handler:    _ContextBoxService_SaveConfigScheduler_Handler,
		},
		{
			MethodName: "SaveConfigBuilder",
			Handler:    _ContextBoxService_SaveConfigBuilder_Handler,
		},
		{
			MethodName: "SaveWorkflowState",
			Handler:    _ContextBoxService_SaveWorkflowState_Handler,
		},
		{
			MethodName: "GetConfigFromDB",
			Handler:    _ContextBoxService_GetConfigFromDB_Handler,
		},
		{
			MethodName: "GetConfigScheduler",
			Handler:    _ContextBoxService_GetConfigScheduler_Handler,
		},
		{
			MethodName: "GetConfigBuilder",
			Handler:    _ContextBoxService_GetConfigBuilder_Handler,
		},
		{
			MethodName: "GetAllConfigs",
			Handler:    _ContextBoxService_GetAllConfigs_Handler,
		},
		{
			MethodName: "DeleteConfig",
			Handler:    _ContextBoxService_DeleteConfig_Handler,
		},
		{
			MethodName: "DeleteConfigFromDB",
			Handler:    _ContextBoxService_DeleteConfigFromDB_Handler,
		},
		{
			MethodName: "UpdateNodepool",
			Handler:    _ContextBoxService_UpdateNodepool_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/contextBox.proto",
}

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

View Source 
var File_proto_ansibler_proto protoreflect.FileDescriptor
View Source 
var File_proto_claudie_operator_proto protoreflect.FileDescriptor
View Source 
var File_proto_config_proto protoreflect.FileDescriptor
View Source 
var File_proto_contextBox_proto protoreflect.FileDescriptor
View Source 
var File_proto_kubeEleven_proto protoreflect.FileDescriptor
View Source 
var File_proto_kuber_proto protoreflect.FileDescriptor
View Source 
var File_proto_terraformer_proto protoreflect.FileDescriptor
View Source 
var KubeElevenService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "claudie.KubeElevenService",
	HandlerType: (*KubeElevenServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildCluster",
			Handler:    _KubeElevenService_BuildCluster_Handler,
		},
		{
			MethodName: "DestroyCluster",
			Handler:    _KubeElevenService_DestroyCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/kubeEleven.proto",
}

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

View Source 
var KuberService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "claudie.KuberService",
	HandlerType: (*KuberServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RemoveLBScrapeConfig",
			Handler:    _KuberService_RemoveLBScrapeConfig_Handler,
		},
		{
			MethodName: "StoreLBScrapeConfig",
			Handler:    _KuberService_StoreLBScrapeConfig_Handler,
		},
		{
			MethodName: "StoreClusterMetadata",
			Handler:    _KuberService_StoreClusterMetadata_Handler,
		},
		{
			MethodName: "DeleteClusterMetadata",
			Handler:    _KuberService_DeleteClusterMetadata_Handler,
		},
		{
			MethodName: "SetUpStorage",
			Handler:    _KuberService_SetUpStorage_Handler,
		},
		{
			MethodName: "StoreKubeconfig",
			Handler:    _KuberService_StoreKubeconfig_Handler,
		},
		{
			MethodName: "DeleteKubeconfig",
			Handler:    _KuberService_DeleteKubeconfig_Handler,
		},
		{
			MethodName: "DeleteNodes",
			Handler:    _KuberService_DeleteNodes_Handler,
		},
		{
			MethodName: "PatchNodes",
			Handler:    _KuberService_PatchNodes_Handler,
		},
		{
			MethodName: "SetUpClusterAutoscaler",
			Handler:    _KuberService_SetUpClusterAutoscaler_Handler,
		},
		{
			MethodName: "DestroyClusterAutoscaler",
			Handler:    _KuberService_DestroyClusterAutoscaler_Handler,
		},
		{
			MethodName: "PatchClusterInfoConfigMap",
			Handler:    _KuberService_PatchClusterInfoConfigMap_Handler,
		},
		{
			MethodName: "CiliumRolloutRestart",
			Handler:    _KuberService_CiliumRolloutRestart_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/kuber.proto",
}

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

View Source 
var OperatorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "claudie.OperatorService",
	HandlerType: (*OperatorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendAutoscalerEvent",
			Handler:    _OperatorService_SendAutoscalerEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/claudie-operator.proto",
}

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

View Source 
var TerraformerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "claudie.TerraformerService",
	HandlerType: (*TerraformerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildInfrastructure",
			Handler:    _TerraformerService_BuildInfrastructure_Handler,
		},
		{
			MethodName: "DestroyInfrastructure",
			Handler:    _TerraformerService_DestroyInfrastructure_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/terraformer.proto",
}

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

Functions

func RegisterAnsiblerServiceServer 

func RegisterAnsiblerServiceServer(s grpc.ServiceRegistrar, srv AnsiblerServiceServer)

func RegisterContextBoxServiceServer 

func RegisterContextBoxServiceServer(s grpc.ServiceRegistrar, srv ContextBoxServiceServer)

func RegisterKubeElevenServiceServer 

func RegisterKubeElevenServiceServer(s grpc.ServiceRegistrar, srv KubeElevenServiceServer)

func RegisterKuberServiceServer 

func RegisterKuberServiceServer(s grpc.ServiceRegistrar, srv KuberServiceServer)

func RegisterOperatorServiceServer added in v0.4.1 

func RegisterOperatorServiceServer(s grpc.ServiceRegistrar, srv OperatorServiceServer)

func RegisterTerraformerServiceServer 

func RegisterTerraformerServiceServer(s grpc.ServiceRegistrar, srv TerraformerServiceServer)

Types

type AnsiblerServiceClient 

type AnsiblerServiceClient interface {
	// InstallNodeRequirements installs any requirements there are on all of the nodes.
	InstallNodeRequirements(ctx context.Context, in *InstallRequest, opts ...grpc.CallOption) (*InstallResponse, error)
	// InstallVPN sets up a VPN between the nodes in the k8s cluster and LB clusters.
	InstallVPN(ctx context.Context, in *InstallRequest, opts ...grpc.CallOption) (*InstallResponse, error)
	// SetUpLoadbalancers sets up the load balancers together with the DNS and verifies their configuration.
	SetUpLoadbalancers(ctx context.Context, in *SetUpLBRequest, opts ...grpc.CallOption) (*SetUpLBResponse, error)
	// TeardownLoadBalancers correctly destroys the load balancers attached to a k8s
	// cluster by choosing a new ApiServer endpoint.
	TeardownLoadBalancers(ctx context.Context, in *TeardownLBRequest, opts ...grpc.CallOption) (*TeardownLBResponse, error)
	// UpdateAPIEndpoint handles changes of API endpoint between control nodes.
	// It will update the current stage based on the information from the desired state.
	UpdateAPIEndpoint(ctx context.Context, in *UpdateAPIEndpointRequest, opts ...grpc.CallOption) (*UpdateAPIEndpointResponse, error)
	// Removes utilities installed by claudie via ansible playbooks.
	RemoveClaudieUtilities(ctx context.Context, in *RemoveClaudieUtilitiesRequest, opts ...grpc.CallOption) (*RemoveClaudieUtilitiesResponse, error)
}

AnsiblerServiceClient is the client API for AnsiblerService 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 NewAnsiblerServiceClient 

func NewAnsiblerServiceClient(cc grpc.ClientConnInterface) AnsiblerServiceClient

type AnsiblerServiceServer 

type AnsiblerServiceServer interface {
	// InstallNodeRequirements installs any requirements there are on all of the nodes.
	InstallNodeRequirements(context.Context, *InstallRequest) (*InstallResponse, error)
	// InstallVPN sets up a VPN between the nodes in the k8s cluster and LB clusters.
	InstallVPN(context.Context, *InstallRequest) (*InstallResponse, error)
	// SetUpLoadbalancers sets up the load balancers together with the DNS and verifies their configuration.
	SetUpLoadbalancers(context.Context, *SetUpLBRequest) (*SetUpLBResponse, error)
	// TeardownLoadBalancers correctly destroys the load balancers attached to a k8s
	// cluster by choosing a new ApiServer endpoint.
	TeardownLoadBalancers(context.Context, *TeardownLBRequest) (*TeardownLBResponse, error)
	// UpdateAPIEndpoint handles changes of API endpoint between control nodes.
	// It will update the current stage based on the information from the desired state.
	UpdateAPIEndpoint(context.Context, *UpdateAPIEndpointRequest) (*UpdateAPIEndpointResponse, error)
	// Removes utilities installed by claudie via ansible playbooks.
	RemoveClaudieUtilities(context.Context, *RemoveClaudieUtilitiesRequest) (*RemoveClaudieUtilitiesResponse, error)
	// contains filtered or unexported methods
}

AnsiblerServiceServer is the server API for AnsiblerService service. All implementations must embed UnimplementedAnsiblerServiceServer for forward compatibility

type AutoscalerConf added in v0.2.2 

type AutoscalerConf struct {

	// Minimum number of nodes in node pool.
	Min int32 `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	// Maximum number of nodes in node pool.
	Max int32 `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

Autoscaler configuration on per node pool basis.

func (*AutoscalerConf) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use AutoscalerConf.ProtoReflect.Descriptor instead.

func (*AutoscalerConf) GetMax added in v0.2.2 

func (x *AutoscalerConf) GetMax() int32

func (*AutoscalerConf) GetMin added in v0.2.2 

func (x *AutoscalerConf) GetMin() int32

func (*AutoscalerConf) ProtoMessage added in v0.2.2 

func (*AutoscalerConf) ProtoMessage()

func (*AutoscalerConf) ProtoReflect added in v0.2.2 

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

func (*AutoscalerConf) Reset added in v0.2.2 

func (x *AutoscalerConf) Reset()

func (*AutoscalerConf) String added in v0.2.2 

func (x *AutoscalerConf) String() string

type BuildClusterRequest 

type BuildClusterRequest struct {
	Desired     *K8Scluster  `protobuf:"bytes,1,opt,name=desired,proto3" json:"desired,omitempty"`
	DesiredLbs  []*LBcluster `protobuf:"bytes,2,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	ProjectName string       `protobuf:"bytes,3,opt,name=projectName,proto3" json:"projectName,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildClusterRequest) Descriptor deprecated 

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

Deprecated: Use BuildClusterRequest.ProtoReflect.Descriptor instead.

func (*BuildClusterRequest) GetDesired 

func (x *BuildClusterRequest) GetDesired() *K8Scluster

func (*BuildClusterRequest) GetDesiredLbs 

func (x *BuildClusterRequest) GetDesiredLbs() []*LBcluster

func (*BuildClusterRequest) GetProjectName 

func (x *BuildClusterRequest) GetProjectName() string

func (*BuildClusterRequest) ProtoMessage 

func (*BuildClusterRequest) ProtoMessage()

func (*BuildClusterRequest) ProtoReflect 

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

func (*BuildClusterRequest) Reset 

func (x *BuildClusterRequest) Reset()

func (*BuildClusterRequest) String 

func (x *BuildClusterRequest) String() string

type BuildClusterResponse 

type BuildClusterResponse struct {
	Desired    *K8Scluster  `protobuf:"bytes,1,opt,name=desired,proto3" json:"desired,omitempty"`
	DesiredLbs []*LBcluster `protobuf:"bytes,2,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildClusterResponse) Descriptor deprecated 

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

Deprecated: Use BuildClusterResponse.ProtoReflect.Descriptor instead.

func (*BuildClusterResponse) GetDesired 

func (x *BuildClusterResponse) GetDesired() *K8Scluster

func (*BuildClusterResponse) GetDesiredLbs 

func (x *BuildClusterResponse) GetDesiredLbs() []*LBcluster

func (*BuildClusterResponse) ProtoMessage 

func (*BuildClusterResponse) ProtoMessage()

func (*BuildClusterResponse) ProtoReflect 

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

func (*BuildClusterResponse) Reset 

func (x *BuildClusterResponse) Reset()

func (*BuildClusterResponse) String 

func (x *BuildClusterResponse) String() string

type BuildInfrastructureRequest 

type BuildInfrastructureRequest struct {
	Current     *K8Scluster  `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	Desired     *K8Scluster  `protobuf:"bytes,2,opt,name=desired,proto3" json:"desired,omitempty"`
	CurrentLbs  []*LBcluster `protobuf:"bytes,3,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	DesiredLbs  []*LBcluster `protobuf:"bytes,4,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	ProjectName string       `protobuf:"bytes,5,opt,name=projectName,proto3" json:"projectName,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildInfrastructureRequest) Descriptor deprecated 

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

Deprecated: Use BuildInfrastructureRequest.ProtoReflect.Descriptor instead.

func (*BuildInfrastructureRequest) GetCurrent 

func (x *BuildInfrastructureRequest) GetCurrent() *K8Scluster

func (*BuildInfrastructureRequest) GetCurrentLbs 

func (x *BuildInfrastructureRequest) GetCurrentLbs() []*LBcluster

func (*BuildInfrastructureRequest) GetDesired 

func (x *BuildInfrastructureRequest) GetDesired() *K8Scluster

func (*BuildInfrastructureRequest) GetDesiredLbs 

func (x *BuildInfrastructureRequest) GetDesiredLbs() []*LBcluster

func (*BuildInfrastructureRequest) GetProjectName 

func (x *BuildInfrastructureRequest) GetProjectName() string

func (*BuildInfrastructureRequest) ProtoMessage 

func (*BuildInfrastructureRequest) ProtoMessage()

func (*BuildInfrastructureRequest) ProtoReflect 

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

func (*BuildInfrastructureRequest) Reset 

func (x *BuildInfrastructureRequest) Reset()

func (*BuildInfrastructureRequest) String 

func (x *BuildInfrastructureRequest) String() string

type BuildInfrastructureResponse 

type BuildInfrastructureResponse struct {

	// Types that are assignable to Response:
	//
	//	*BuildInfrastructureResponse_Ok
	//	*BuildInfrastructureResponse_Fail
	Response isBuildInfrastructureResponse_Response `protobuf_oneof:"Response"`
	// contains filtered or unexported fields
}

func (*BuildInfrastructureResponse) Descriptor deprecated 

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

Deprecated: Use BuildInfrastructureResponse.ProtoReflect.Descriptor instead.

func (*BuildInfrastructureResponse) GetFail added in v0.4.0 

func (x *BuildInfrastructureResponse) GetFail() *BuildInfrastructureResponse_InfrastructureData

func (*BuildInfrastructureResponse) GetOk added in v0.4.0 

func (x *BuildInfrastructureResponse) GetOk() *BuildInfrastructureResponse_InfrastructureData

func (*BuildInfrastructureResponse) GetResponse added in v0.4.0 

func (m *BuildInfrastructureResponse) GetResponse() isBuildInfrastructureResponse_Response

func (*BuildInfrastructureResponse) ProtoMessage 

func (*BuildInfrastructureResponse) ProtoMessage()

func (*BuildInfrastructureResponse) ProtoReflect 

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

func (*BuildInfrastructureResponse) Reset 

func (x *BuildInfrastructureResponse) Reset()

func (*BuildInfrastructureResponse) String 

func (x *BuildInfrastructureResponse) String() string

type BuildInfrastructureResponse_Fail added in v0.4.0 

type BuildInfrastructureResponse_Fail struct {
	Fail *BuildInfrastructureResponse_InfrastructureData `protobuf:"bytes,7,opt,name=fail,proto3,oneof"`
}

type BuildInfrastructureResponse_InfrastructureData added in v0.4.0 

type BuildInfrastructureResponse_InfrastructureData struct {
	Current    *K8Scluster  `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	Desired    *K8Scluster  `protobuf:"bytes,2,opt,name=desired,proto3" json:"desired,omitempty"`
	CurrentLbs []*LBcluster `protobuf:"bytes,3,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	DesiredLbs []*LBcluster `protobuf:"bytes,4,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	// if any partial failures occur this field will contain them and the
	// Response will be of type *fail*.
	Failed []string `protobuf:"bytes,5,rep,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildInfrastructureResponse_InfrastructureData) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use BuildInfrastructureResponse_InfrastructureData.ProtoReflect.Descriptor instead.

func (*BuildInfrastructureResponse_InfrastructureData) GetCurrent added in v0.4.0 

func (x *BuildInfrastructureResponse_InfrastructureData) GetCurrent() *K8Scluster

func (*BuildInfrastructureResponse_InfrastructureData) GetCurrentLbs added in v0.4.0 

func (x *BuildInfrastructureResponse_InfrastructureData) GetCurrentLbs() []*LBcluster

func (*BuildInfrastructureResponse_InfrastructureData) GetDesired added in v0.4.0 

func (x *BuildInfrastructureResponse_InfrastructureData) GetDesired() *K8Scluster

func (*BuildInfrastructureResponse_InfrastructureData) GetDesiredLbs added in v0.4.0 

func (x *BuildInfrastructureResponse_InfrastructureData) GetDesiredLbs() []*LBcluster

func (*BuildInfrastructureResponse_InfrastructureData) GetFailed added in v0.4.0 

func (x *BuildInfrastructureResponse_InfrastructureData) GetFailed() []string

func (*BuildInfrastructureResponse_InfrastructureData) ProtoMessage added in v0.4.0 

func (*BuildInfrastructureResponse_InfrastructureData) ProtoMessage()

func (*BuildInfrastructureResponse_InfrastructureData) ProtoReflect added in v0.4.0 

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

func (*BuildInfrastructureResponse_InfrastructureData) Reset added in v0.4.0 

func (x *BuildInfrastructureResponse_InfrastructureData) Reset()

func (*BuildInfrastructureResponse_InfrastructureData) String added in v0.4.0 

func (x *BuildInfrastructureResponse_InfrastructureData) String() string

type BuildInfrastructureResponse_Ok added in v0.4.0 

type BuildInfrastructureResponse_Ok struct {
	Ok *BuildInfrastructureResponse_InfrastructureData `protobuf:"bytes,6,opt,name=ok,proto3,oneof"`
}

type CiliumRolloutRestartRequest added in v0.5.0 

type CiliumRolloutRestartRequest struct {
	Cluster *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*CiliumRolloutRestartRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use CiliumRolloutRestartRequest.ProtoReflect.Descriptor instead.

func (*CiliumRolloutRestartRequest) GetCluster added in v0.5.0 

func (x *CiliumRolloutRestartRequest) GetCluster() *K8Scluster

func (*CiliumRolloutRestartRequest) ProtoMessage added in v0.5.0 

func (*CiliumRolloutRestartRequest) ProtoMessage()

func (*CiliumRolloutRestartRequest) ProtoReflect added in v0.5.0 

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

func (*CiliumRolloutRestartRequest) Reset added in v0.5.0 

func (x *CiliumRolloutRestartRequest) Reset()

func (*CiliumRolloutRestartRequest) String added in v0.5.0 

func (x *CiliumRolloutRestartRequest) String() string

type CiliumRolloutRestartResponse added in v0.5.0 

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

func (*CiliumRolloutRestartResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use CiliumRolloutRestartResponse.ProtoReflect.Descriptor instead.

func (*CiliumRolloutRestartResponse) ProtoMessage added in v0.5.0 

func (*CiliumRolloutRestartResponse) ProtoMessage()

func (*CiliumRolloutRestartResponse) ProtoReflect added in v0.5.0 

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

func (*CiliumRolloutRestartResponse) Reset added in v0.5.0 

func (x *CiliumRolloutRestartResponse) Reset()

func (*CiliumRolloutRestartResponse) String added in v0.5.0 

func (x *CiliumRolloutRestartResponse) String() string

type ClusterInfo 

type ClusterInfo struct {

	// Name of the cluster.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Random hash of the cluster.
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// Public SSH key for the nodes.
	PublicKey string `protobuf:"bytes,3,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	// Private SSH key for the nodes.
	PrivateKey string `protobuf:"bytes,4,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
	// Array of node pools this cluster is made of.
	NodePools []*NodePool `protobuf:"bytes,5,rep,name=nodePools,proto3" json:"nodePools,omitempty"`
	// contains filtered or unexported fields
}

ClusterInfo holds general information about the clusters.

func (*ClusterInfo) Descriptor deprecated 

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

Deprecated: Use ClusterInfo.ProtoReflect.Descriptor instead.

func (*ClusterInfo) GetHash 

func (x *ClusterInfo) GetHash() string

func (*ClusterInfo) GetName 

func (x *ClusterInfo) GetName() string

func (*ClusterInfo) GetNodePools 

func (x *ClusterInfo) GetNodePools() []*NodePool

func (*ClusterInfo) GetPrivateKey 

func (x *ClusterInfo) GetPrivateKey() string

func (*ClusterInfo) GetPublicKey 

func (x *ClusterInfo) GetPublicKey() string

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoReflect 

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

func (*ClusterInfo) Reset 

func (x *ClusterInfo) Reset()

func (*ClusterInfo) String 

func (x *ClusterInfo) String() string

type ClusterType 

type ClusterType int32

ClusterType specifies the type of the cluster. 

const (
	// Kubernetes cluster.
	ClusterType_K8s ClusterType = 0
	// Load balancer cluster.
	ClusterType_LB ClusterType = 1
)

func (ClusterType) Descriptor 

func (ClusterType) Descriptor() protoreflect.EnumDescriptor

func (ClusterType) Enum 

func (x ClusterType) Enum() *ClusterType

func (ClusterType) EnumDescriptor deprecated 

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

Deprecated: Use ClusterType.Descriptor instead.

func (ClusterType) Number 

func (x ClusterType) Number() protoreflect.EnumNumber

func (ClusterType) String 

func (x ClusterType) String() string

func (ClusterType) Type 

func (ClusterType) Type() protoreflect.EnumType

type Config 

type Config struct {

	// Config ID in the DB.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Config name - same as input manifest name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// resourceName represents the input manifest resource name in Kubernetes
	ResourceName string `protobuf:"bytes,3,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	// resourceNamespace represents the input manifest resource namespace in Kubernetes
	ResourceNamespace string `protobuf:"bytes,4,opt,name=resourceNamespace,proto3" json:"resourceNamespace,omitempty"`
	// Client defined manifest.
	Manifest string `protobuf:"bytes,5,opt,name=manifest,proto3" json:"manifest,omitempty"`
	// Desired state based on the input manifest manifest.
	DesiredState *Project `protobuf:"bytes,6,opt,name=desiredState,proto3" json:"desiredState,omitempty"`
	// Current state of the infrastructure.
	CurrentState *Project `protobuf:"bytes,7,opt,name=currentState,proto3" json:"currentState,omitempty"`
	// Manifest state checksum.
	MsChecksum []byte `protobuf:"bytes,8,opt,name=msChecksum,proto3" json:"msChecksum,omitempty"`
	// Desired state checksum.
	DsChecksum []byte `protobuf:"bytes,9,opt,name=dsChecksum,proto3" json:"dsChecksum,omitempty"`
	// Current state checksum.
	CsChecksum []byte `protobuf:"bytes,10,opt,name=csChecksum,proto3" json:"csChecksum,omitempty"`
	// Builder time to live counter.
	BuilderTTL int32 `protobuf:"varint,11,opt,name=builderTTL,proto3" json:"builderTTL,omitempty"`
	// Scheduler time to live counter.
	SchedulerTTL int32 `protobuf:"varint,12,opt,name=schedulerTTL,proto3" json:"schedulerTTL,omitempty"`
	// Per-cluster workflow state.
	State map[string]*Workflow `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

Config holds data for a single manifest.

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetBuilderTTL 

func (x *Config) GetBuilderTTL() int32

func (*Config) GetCsChecksum 

func (x *Config) GetCsChecksum() []byte

func (*Config) GetCurrentState 

func (x *Config) GetCurrentState() *Project

func (*Config) GetDesiredState 

func (x *Config) GetDesiredState() *Project

func (*Config) GetDsChecksum 

func (x *Config) GetDsChecksum() []byte

func (*Config) GetId 

func (x *Config) GetId() string

func (*Config) GetManifest 

func (x *Config) GetManifest() string

func (*Config) GetMsChecksum 

func (x *Config) GetMsChecksum() []byte

func (*Config) GetName 

func (x *Config) GetName() string

func (*Config) GetResourceName added in v0.4.1 

func (x *Config) GetResourceName() string

func (*Config) GetResourceNamespace added in v0.4.1 

func (x *Config) GetResourceNamespace() string

func (*Config) GetSchedulerTTL 

func (x *Config) GetSchedulerTTL() int32

func (*Config) GetState added in v0.2.2 

func (x *Config) GetState() map[string]*Workflow

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type ContextBoxServiceClient 

type ContextBoxServiceClient interface {
	// SaveConfigOperator saves the config parsed by claudie-operator.
	SaveConfigOperator(ctx context.Context, in *SaveConfigRequest, opts ...grpc.CallOption) (*SaveConfigResponse, error)
	// SaveConfigScheduler saves the config parsed by Scheduler.
	SaveConfigScheduler(ctx context.Context, in *SaveConfigRequest, opts ...grpc.CallOption) (*SaveConfigResponse, error)
	// SaveConfigBuilder saves the config parsed by Builder.
	SaveConfigBuilder(ctx context.Context, in *SaveConfigRequest, opts ...grpc.CallOption) (*SaveConfigResponse, error)
	// SaveWorkflowState saves the information about the state of the config.
	SaveWorkflowState(ctx context.Context, in *SaveWorkflowStateRequest, opts ...grpc.CallOption) (*SaveWorkflowStateResponse, error)
	// GetConfigFromDB gets a single config from the database.
	GetConfigFromDB(ctx context.Context, in *GetConfigFromDBRequest, opts ...grpc.CallOption) (*GetConfigFromDBResponse, error)
	// GetConfigScheduler gets a config from Scheduler's queue of pending configs.
	GetConfigScheduler(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	// GetConfigBuilder gets a config from Builder's queue of pending configs.
	GetConfigBuilder(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	// GetAllConfigs gets all configs from the database.
	GetAllConfigs(ctx context.Context, in *GetAllConfigsRequest, opts ...grpc.CallOption) (*GetAllConfigsResponse, error)
	// DeleteConfig sets the manifest to null, effectively forcing the deletion of the infrastructure
	// defined by the manifest on the very next config (diff) check.
	DeleteConfig(ctx context.Context, in *DeleteConfigRequest, opts ...grpc.CallOption) (*DeleteConfigResponse, error)
	// DeleteConfigFromDB deletes the config from the database.
	DeleteConfigFromDB(ctx context.Context, in *DeleteConfigRequest, opts ...grpc.CallOption) (*DeleteConfigResponse, error)
	// UpdateNodepool updates specific nodepool from the config. Used mainly for autoscaling.
	UpdateNodepool(ctx context.Context, in *UpdateNodepoolRequest, opts ...grpc.CallOption) (*UpdateNodepoolResponse, error)
}

ContextBoxServiceClient is the client API for ContextBoxService 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 NewContextBoxServiceClient 

func NewContextBoxServiceClient(cc grpc.ClientConnInterface) ContextBoxServiceClient

type ContextBoxServiceServer 

type ContextBoxServiceServer interface {
	// SaveConfigOperator saves the config parsed by claudie-operator.
	SaveConfigOperator(context.Context, *SaveConfigRequest) (*SaveConfigResponse, error)
	// SaveConfigScheduler saves the config parsed by Scheduler.
	SaveConfigScheduler(context.Context, *SaveConfigRequest) (*SaveConfigResponse, error)
	// SaveConfigBuilder saves the config parsed by Builder.
	SaveConfigBuilder(context.Context, *SaveConfigRequest) (*SaveConfigResponse, error)
	// SaveWorkflowState saves the information about the state of the config.
	SaveWorkflowState(context.Context, *SaveWorkflowStateRequest) (*SaveWorkflowStateResponse, error)
	// GetConfigFromDB gets a single config from the database.
	GetConfigFromDB(context.Context, *GetConfigFromDBRequest) (*GetConfigFromDBResponse, error)
	// GetConfigScheduler gets a config from Scheduler's queue of pending configs.
	GetConfigScheduler(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	// GetConfigBuilder gets a config from Builder's queue of pending configs.
	GetConfigBuilder(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	// GetAllConfigs gets all configs from the database.
	GetAllConfigs(context.Context, *GetAllConfigsRequest) (*GetAllConfigsResponse, error)
	// DeleteConfig sets the manifest to null, effectively forcing the deletion of the infrastructure
	// defined by the manifest on the very next config (diff) check.
	DeleteConfig(context.Context, *DeleteConfigRequest) (*DeleteConfigResponse, error)
	// DeleteConfigFromDB deletes the config from the database.
	DeleteConfigFromDB(context.Context, *DeleteConfigRequest) (*DeleteConfigResponse, error)
	// UpdateNodepool updates specific nodepool from the config. Used mainly for autoscaling.
	UpdateNodepool(context.Context, *UpdateNodepoolRequest) (*UpdateNodepoolResponse, error)
	// contains filtered or unexported methods
}

ContextBoxServiceServer is the server API for ContextBoxService service. All implementations must embed UnimplementedContextBoxServiceServer for forward compatibility

type DNS 

type DNS struct {

	// DNS zone for the DNS records.
	DnsZone string `protobuf:"bytes,1,opt,name=dnsZone,proto3" json:"dnsZone,omitempty"`
	// User specified hostname. (optional)
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Provider for the DNS records.
	Provider *Provider `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
	// The whole hostname of the DNS record.
	Endpoint string `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

DNS holds general information about the DNS records.

func (*DNS) Descriptor deprecated 

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

Deprecated: Use DNS.ProtoReflect.Descriptor instead.

func (*DNS) GetDnsZone 

func (x *DNS) GetDnsZone() string

func (*DNS) GetEndpoint 

func (x *DNS) GetEndpoint() string

func (*DNS) GetHostname 

func (x *DNS) GetHostname() string

func (*DNS) GetProvider 

func (x *DNS) GetProvider() *Provider

func (*DNS) ProtoMessage 

func (*DNS) ProtoMessage()

func (*DNS) ProtoReflect 

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

func (*DNS) Reset 

func (x *DNS) Reset()

func (*DNS) String 

func (x *DNS) String() string

type DeleteClusterMetadataRequest 

type DeleteClusterMetadataRequest struct {
	Cluster *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteClusterMetadataRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterMetadataRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterMetadataRequest) GetCluster 

func (x *DeleteClusterMetadataRequest) GetCluster() *K8Scluster

func (*DeleteClusterMetadataRequest) ProtoMessage 

func (*DeleteClusterMetadataRequest) ProtoMessage()

func (*DeleteClusterMetadataRequest) ProtoReflect 

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

func (*DeleteClusterMetadataRequest) Reset 

func (x *DeleteClusterMetadataRequest) Reset()

func (*DeleteClusterMetadataRequest) String 

func (x *DeleteClusterMetadataRequest) String() string

type DeleteClusterMetadataResponse 

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

func (*DeleteClusterMetadataResponse) Descriptor deprecated 

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

Deprecated: Use DeleteClusterMetadataResponse.ProtoReflect.Descriptor instead.

func (*DeleteClusterMetadataResponse) ProtoMessage 

func (*DeleteClusterMetadataResponse) ProtoMessage()

func (*DeleteClusterMetadataResponse) ProtoReflect 

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

func (*DeleteClusterMetadataResponse) Reset 

func (x *DeleteClusterMetadataResponse) Reset()

func (*DeleteClusterMetadataResponse) String 

func (x *DeleteClusterMetadataResponse) String() string

type DeleteConfigRequest 

type DeleteConfigRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type IdType `protobuf:"varint,2,opt,name=type,proto3,enum=claudie.IdType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Delete

func (*DeleteConfigRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConfigRequest.ProtoReflect.Descriptor instead.

func (*DeleteConfigRequest) GetId 

func (x *DeleteConfigRequest) GetId() string

func (*DeleteConfigRequest) GetType 

func (x *DeleteConfigRequest) GetType() IdType

func (*DeleteConfigRequest) ProtoMessage 

func (*DeleteConfigRequest) ProtoMessage()

func (*DeleteConfigRequest) ProtoReflect 

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

func (*DeleteConfigRequest) Reset 

func (x *DeleteConfigRequest) Reset()

func (*DeleteConfigRequest) String 

func (x *DeleteConfigRequest) String() string

type DeleteConfigResponse 

type DeleteConfigResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConfigResponse) Descriptor deprecated 

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

Deprecated: Use DeleteConfigResponse.ProtoReflect.Descriptor instead.

func (*DeleteConfigResponse) GetId 

func (x *DeleteConfigResponse) GetId() string

func (*DeleteConfigResponse) ProtoMessage 

func (*DeleteConfigResponse) ProtoMessage()

func (*DeleteConfigResponse) ProtoReflect 

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

func (*DeleteConfigResponse) Reset 

func (x *DeleteConfigResponse) Reset()

func (*DeleteConfigResponse) String 

func (x *DeleteConfigResponse) String() string

type DeleteKubeconfigRequest 

type DeleteKubeconfigRequest struct {
	Cluster *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKubeconfigRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKubeconfigRequest.ProtoReflect.Descriptor instead.

func (*DeleteKubeconfigRequest) GetCluster 

func (x *DeleteKubeconfigRequest) GetCluster() *K8Scluster

func (*DeleteKubeconfigRequest) ProtoMessage 

func (*DeleteKubeconfigRequest) ProtoMessage()

func (*DeleteKubeconfigRequest) ProtoReflect 

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

func (*DeleteKubeconfigRequest) Reset 

func (x *DeleteKubeconfigRequest) Reset()

func (*DeleteKubeconfigRequest) String 

func (x *DeleteKubeconfigRequest) String() string

type DeleteKubeconfigResponse 

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

func (*DeleteKubeconfigResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKubeconfigResponse.ProtoReflect.Descriptor instead.

func (*DeleteKubeconfigResponse) ProtoMessage 

func (*DeleteKubeconfigResponse) ProtoMessage()

func (*DeleteKubeconfigResponse) ProtoReflect 

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

func (*DeleteKubeconfigResponse) Reset 

func (x *DeleteKubeconfigResponse) Reset()

func (*DeleteKubeconfigResponse) String 

func (x *DeleteKubeconfigResponse) String() string

type DeleteNodesRequest 

type DeleteNodesRequest struct {
	Cluster     *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	WorkerNodes []string    `protobuf:"bytes,2,rep,name=workerNodes,proto3" json:"workerNodes,omitempty"`
	MasterNodes []string    `protobuf:"bytes,3,rep,name=masterNodes,proto3" json:"masterNodes,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNodesRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNodesRequest.ProtoReflect.Descriptor instead.

func (*DeleteNodesRequest) GetCluster 

func (x *DeleteNodesRequest) GetCluster() *K8Scluster

func (*DeleteNodesRequest) GetMasterNodes 

func (x *DeleteNodesRequest) GetMasterNodes() []string

func (*DeleteNodesRequest) GetWorkerNodes 

func (x *DeleteNodesRequest) GetWorkerNodes() []string

func (*DeleteNodesRequest) ProtoMessage 

func (*DeleteNodesRequest) ProtoMessage()

func (*DeleteNodesRequest) ProtoReflect 

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

func (*DeleteNodesRequest) Reset 

func (x *DeleteNodesRequest) Reset()

func (*DeleteNodesRequest) String 

func (x *DeleteNodesRequest) String() string

type DeleteNodesResponse 

type DeleteNodesResponse struct {
	Cluster *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNodesResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNodesResponse.ProtoReflect.Descriptor instead.

func (*DeleteNodesResponse) GetCluster 

func (x *DeleteNodesResponse) GetCluster() *K8Scluster

func (*DeleteNodesResponse) ProtoMessage 

func (*DeleteNodesResponse) ProtoMessage()

func (*DeleteNodesResponse) ProtoReflect 

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

func (*DeleteNodesResponse) Reset 

func (x *DeleteNodesResponse) Reset()

func (*DeleteNodesResponse) String 

func (x *DeleteNodesResponse) String() string

type DestroyClusterAutoscalerRequest added in v0.2.2 

type DestroyClusterAutoscalerRequest struct {
	ProjectName string      `protobuf:"bytes,1,opt,name=projectName,proto3" json:"projectName,omitempty"`
	Cluster     *K8Scluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyClusterAutoscalerRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use DestroyClusterAutoscalerRequest.ProtoReflect.Descriptor instead.

func (*DestroyClusterAutoscalerRequest) GetCluster added in v0.2.2 

func (x *DestroyClusterAutoscalerRequest) GetCluster() *K8Scluster

func (*DestroyClusterAutoscalerRequest) GetProjectName added in v0.2.2 

func (x *DestroyClusterAutoscalerRequest) GetProjectName() string

func (*DestroyClusterAutoscalerRequest) ProtoMessage added in v0.2.2 

func (*DestroyClusterAutoscalerRequest) ProtoMessage()

func (*DestroyClusterAutoscalerRequest) ProtoReflect added in v0.2.2 

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

func (*DestroyClusterAutoscalerRequest) Reset added in v0.2.2 

func (x *DestroyClusterAutoscalerRequest) Reset()

func (*DestroyClusterAutoscalerRequest) String added in v0.2.2 

func (x *DestroyClusterAutoscalerRequest) String() string

type DestroyClusterAutoscalerResponse added in v0.2.2 

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

func (*DestroyClusterAutoscalerResponse) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use DestroyClusterAutoscalerResponse.ProtoReflect.Descriptor instead.

func (*DestroyClusterAutoscalerResponse) ProtoMessage added in v0.2.2 

func (*DestroyClusterAutoscalerResponse) ProtoMessage()

func (*DestroyClusterAutoscalerResponse) ProtoReflect added in v0.2.2 

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

func (*DestroyClusterAutoscalerResponse) Reset added in v0.2.2 

func (x *DestroyClusterAutoscalerResponse) Reset()

func (*DestroyClusterAutoscalerResponse) String added in v0.2.2 

func (x *DestroyClusterAutoscalerResponse) String() string

type DestroyClusterRequest added in v0.6.2 

type DestroyClusterRequest struct {
	ProjectName string       `protobuf:"bytes,1,opt,name=projectName,proto3" json:"projectName,omitempty"`
	Current     *K8Scluster  `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	CurrentLbs  []*LBcluster `protobuf:"bytes,3,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyClusterRequest) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use DestroyClusterRequest.ProtoReflect.Descriptor instead.

func (*DestroyClusterRequest) GetCurrent added in v0.6.2 

func (x *DestroyClusterRequest) GetCurrent() *K8Scluster

func (*DestroyClusterRequest) GetCurrentLbs added in v0.6.2 

func (x *DestroyClusterRequest) GetCurrentLbs() []*LBcluster

func (*DestroyClusterRequest) GetProjectName added in v0.6.2 

func (x *DestroyClusterRequest) GetProjectName() string

func (*DestroyClusterRequest) ProtoMessage added in v0.6.2 

func (*DestroyClusterRequest) ProtoMessage()

func (*DestroyClusterRequest) ProtoReflect added in v0.6.2 

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

func (*DestroyClusterRequest) Reset added in v0.6.2 

func (x *DestroyClusterRequest) Reset()

func (*DestroyClusterRequest) String added in v0.6.2 

func (x *DestroyClusterRequest) String() string

type DestroyClusterResponse added in v0.6.2 

type DestroyClusterResponse struct {
	Current    *K8Scluster  `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	CurrentLbs []*LBcluster `protobuf:"bytes,2,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyClusterResponse) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use DestroyClusterResponse.ProtoReflect.Descriptor instead.

func (*DestroyClusterResponse) GetCurrent added in v0.6.2 

func (x *DestroyClusterResponse) GetCurrent() *K8Scluster

func (*DestroyClusterResponse) GetCurrentLbs added in v0.6.2 

func (x *DestroyClusterResponse) GetCurrentLbs() []*LBcluster

func (*DestroyClusterResponse) ProtoMessage added in v0.6.2 

func (*DestroyClusterResponse) ProtoMessage()

func (*DestroyClusterResponse) ProtoReflect added in v0.6.2 

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

func (*DestroyClusterResponse) Reset added in v0.6.2 

func (x *DestroyClusterResponse) Reset()

func (*DestroyClusterResponse) String added in v0.6.2 

func (x *DestroyClusterResponse) String() string

type DestroyInfrastructureRequest 

type DestroyInfrastructureRequest struct {
	ProjectName string       `protobuf:"bytes,1,opt,name=projectName,proto3" json:"projectName,omitempty"`
	Current     *K8Scluster  `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	CurrentLbs  []*LBcluster `protobuf:"bytes,3,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyInfrastructureRequest) Descriptor deprecated 

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

Deprecated: Use DestroyInfrastructureRequest.ProtoReflect.Descriptor instead.

func (*DestroyInfrastructureRequest) GetCurrent 

func (x *DestroyInfrastructureRequest) GetCurrent() *K8Scluster

func (*DestroyInfrastructureRequest) GetCurrentLbs 

func (x *DestroyInfrastructureRequest) GetCurrentLbs() []*LBcluster

func (*DestroyInfrastructureRequest) GetProjectName 

func (x *DestroyInfrastructureRequest) GetProjectName() string

func (*DestroyInfrastructureRequest) ProtoMessage 

func (*DestroyInfrastructureRequest) ProtoMessage()

func (*DestroyInfrastructureRequest) ProtoReflect 

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

func (*DestroyInfrastructureRequest) Reset 

func (x *DestroyInfrastructureRequest) Reset()

func (*DestroyInfrastructureRequest) String 

func (x *DestroyInfrastructureRequest) String() string

type DestroyInfrastructureResponse 

type DestroyInfrastructureResponse struct {
	Current    *K8Scluster  `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	CurrentLbs []*LBcluster `protobuf:"bytes,2,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyInfrastructureResponse) Descriptor deprecated 

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

Deprecated: Use DestroyInfrastructureResponse.ProtoReflect.Descriptor instead.

func (*DestroyInfrastructureResponse) GetCurrent 

func (x *DestroyInfrastructureResponse) GetCurrent() *K8Scluster

func (*DestroyInfrastructureResponse) GetCurrentLbs 

func (x *DestroyInfrastructureResponse) GetCurrentLbs() []*LBcluster

func (*DestroyInfrastructureResponse) ProtoMessage 

func (*DestroyInfrastructureResponse) ProtoMessage()

func (*DestroyInfrastructureResponse) ProtoReflect 

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

func (*DestroyInfrastructureResponse) Reset 

func (x *DestroyInfrastructureResponse) Reset()

func (*DestroyInfrastructureResponse) String 

func (x *DestroyInfrastructureResponse) String() string

type DynamicNodePool added in v0.4.0 

type DynamicNodePool struct {

	// Machine type of the nodes.
	ServerType string `protobuf:"bytes,1,opt,name=serverType,proto3" json:"serverType,omitempty"`
	// OS image of the nodes.
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// Storage disk size of the nodes.
	StorageDiskSize int32 `protobuf:"varint,3,opt,name=storageDiskSize,proto3" json:"storageDiskSize,omitempty"`
	// Geograhical region of the nodes.
	Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
	// Datacentre zone for the nodes.
	Zone string `protobuf:"bytes,5,opt,name=zone,proto3" json:"zone,omitempty"`
	// Number of the nodes in the node pool.
	Count int32 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	// Provider configuarion of the node pool.
	Provider *Provider `protobuf:"bytes,7,opt,name=provider,proto3" json:"provider,omitempty"`
	// Nodepool metadata.
	Metadata map[string]*MetaValue `` /* 157-byte string literal not displayed */
	// Autoscaler configuration. (optional)
	AutoscalerConfig *AutoscalerConf `protobuf:"bytes,9,opt,name=autoscalerConfig,proto3" json:"autoscalerConfig,omitempty"`
	// MachineSpec configuration. (optional)
	MachineSpec *MachineSpec `protobuf:"bytes,10,opt,name=machineSpec,proto3" json:"machineSpec,omitempty"`
	// contains filtered or unexported fields
}

DynamicNodePool represents dynamic node pool used in cluster.

func (*DynamicNodePool) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DynamicNodePool.ProtoReflect.Descriptor instead.

func (*DynamicNodePool) GetAutoscalerConfig added in v0.4.0 

func (x *DynamicNodePool) GetAutoscalerConfig() *AutoscalerConf

func (*DynamicNodePool) GetCount added in v0.4.0 

func (x *DynamicNodePool) GetCount() int32

func (*DynamicNodePool) GetImage added in v0.4.0 

func (x *DynamicNodePool) GetImage() string

func (*DynamicNodePool) GetMachineSpec added in v0.6.0 

func (x *DynamicNodePool) GetMachineSpec() *MachineSpec

func (*DynamicNodePool) GetMetadata added in v0.4.0 

func (x *DynamicNodePool) GetMetadata() map[string]*MetaValue

func (*DynamicNodePool) GetProvider added in v0.4.0 

func (x *DynamicNodePool) GetProvider() *Provider

func (*DynamicNodePool) GetRegion added in v0.4.0 

func (x *DynamicNodePool) GetRegion() string

func (*DynamicNodePool) GetServerType added in v0.4.0 

func (x *DynamicNodePool) GetServerType() string

func (*DynamicNodePool) GetStorageDiskSize added in v0.4.0 

func (x *DynamicNodePool) GetStorageDiskSize() int32

func (*DynamicNodePool) GetZone added in v0.4.0 

func (x *DynamicNodePool) GetZone() string

func (*DynamicNodePool) ProtoMessage added in v0.4.0 

func (*DynamicNodePool) ProtoMessage()

func (*DynamicNodePool) ProtoReflect added in v0.4.0 

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

func (*DynamicNodePool) Reset added in v0.4.0 

func (x *DynamicNodePool) Reset()

func (*DynamicNodePool) String added in v0.4.0 

func (x *DynamicNodePool) String() string

type GetAllConfigsRequest 

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

func (*GetAllConfigsRequest) Descriptor deprecated 

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

Deprecated: Use GetAllConfigsRequest.ProtoReflect.Descriptor instead.

func (*GetAllConfigsRequest) ProtoMessage 

func (*GetAllConfigsRequest) ProtoMessage()

func (*GetAllConfigsRequest) ProtoReflect 

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

func (*GetAllConfigsRequest) Reset 

func (x *GetAllConfigsRequest) Reset()

func (*GetAllConfigsRequest) String 

func (x *GetAllConfigsRequest) String() string

type GetAllConfigsResponse 

type GetAllConfigsResponse struct {
	Configs []*Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllConfigsResponse) Descriptor deprecated 

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

Deprecated: Use GetAllConfigsResponse.ProtoReflect.Descriptor instead.

func (*GetAllConfigsResponse) GetConfigs 

func (x *GetAllConfigsResponse) GetConfigs() []*Config

func (*GetAllConfigsResponse) ProtoMessage 

func (*GetAllConfigsResponse) ProtoMessage()

func (*GetAllConfigsResponse) ProtoReflect 

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

func (*GetAllConfigsResponse) Reset 

func (x *GetAllConfigsResponse) Reset()

func (*GetAllConfigsResponse) String 

func (x *GetAllConfigsResponse) String() string

type GetConfigFromDBRequest 

type GetConfigFromDBRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type IdType `protobuf:"varint,2,opt,name=type,proto3,enum=claudie.IdType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigFromDBRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigFromDBRequest.ProtoReflect.Descriptor instead.

func (*GetConfigFromDBRequest) GetId 

func (x *GetConfigFromDBRequest) GetId() string

func (*GetConfigFromDBRequest) GetType 

func (x *GetConfigFromDBRequest) GetType() IdType

func (*GetConfigFromDBRequest) ProtoMessage 

func (*GetConfigFromDBRequest) ProtoMessage()

func (*GetConfigFromDBRequest) ProtoReflect 

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

func (*GetConfigFromDBRequest) Reset 

func (x *GetConfigFromDBRequest) Reset()

func (*GetConfigFromDBRequest) String 

func (x *GetConfigFromDBRequest) String() string

type GetConfigFromDBResponse 

type GetConfigFromDBResponse struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigFromDBResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigFromDBResponse.ProtoReflect.Descriptor instead.

func (*GetConfigFromDBResponse) GetConfig 

func (x *GetConfigFromDBResponse) GetConfig() *Config

func (*GetConfigFromDBResponse) ProtoMessage 

func (*GetConfigFromDBResponse) ProtoMessage()

func (*GetConfigFromDBResponse) ProtoReflect 

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

func (*GetConfigFromDBResponse) Reset 

func (x *GetConfigFromDBResponse) Reset()

func (*GetConfigFromDBResponse) String 

func (x *GetConfigFromDBResponse) String() string

type GetConfigRequest 

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

Get

func (*GetConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect 

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

func (*GetConfigRequest) Reset 

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (x *GetConfigRequest) String() string

type GetConfigResponse 

type GetConfigResponse struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.

func (*GetConfigResponse) GetConfig 

func (x *GetConfigResponse) GetConfig() *Config

func (*GetConfigResponse) ProtoMessage 

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) ProtoReflect 

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

func (*GetConfigResponse) Reset 

func (x *GetConfigResponse) Reset()

func (*GetConfigResponse) String 

func (x *GetConfigResponse) String() string

type IdType 

type IdType int32
const (
	IdType_NAME IdType = 0
	IdType_HASH IdType = 1
)

func (IdType) Descriptor 

func (IdType) Descriptor() protoreflect.EnumDescriptor

func (IdType) Enum 

func (x IdType) Enum() *IdType

func (IdType) EnumDescriptor deprecated 

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

Deprecated: Use IdType.Descriptor instead.

func (IdType) Number 

func (x IdType) Number() protoreflect.EnumNumber

func (IdType) String 

func (x IdType) String() string

func (IdType) Type 

func (IdType) Type() protoreflect.EnumType

type InstallRequest 

type InstallRequest struct {
	Desired     *K8Scluster  `protobuf:"bytes,1,opt,name=desired,proto3" json:"desired,omitempty"`
	DesiredLbs  []*LBcluster `protobuf:"bytes,2,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	ProjectName string       `protobuf:"bytes,3,opt,name=projectName,proto3" json:"projectName,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallRequest) Descriptor deprecated 

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

Deprecated: Use InstallRequest.ProtoReflect.Descriptor instead.

func (*InstallRequest) GetDesired 

func (x *InstallRequest) GetDesired() *K8Scluster

func (*InstallRequest) GetDesiredLbs 

func (x *InstallRequest) GetDesiredLbs() []*LBcluster

func (*InstallRequest) GetProjectName 

func (x *InstallRequest) GetProjectName() string

func (*InstallRequest) ProtoMessage 

func (*InstallRequest) ProtoMessage()

func (*InstallRequest) ProtoReflect 

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

func (*InstallRequest) Reset 

func (x *InstallRequest) Reset()

func (*InstallRequest) String 

func (x *InstallRequest) String() string

type InstallResponse 

type InstallResponse struct {
	Desired    *K8Scluster  `protobuf:"bytes,1,opt,name=desired,proto3" json:"desired,omitempty"`
	DesiredLbs []*LBcluster `protobuf:"bytes,2,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallResponse) Descriptor deprecated 

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

Deprecated: Use InstallResponse.ProtoReflect.Descriptor instead.

func (*InstallResponse) GetDesired 

func (x *InstallResponse) GetDesired() *K8Scluster

func (*InstallResponse) GetDesiredLbs 

func (x *InstallResponse) GetDesiredLbs() []*LBcluster

func (*InstallResponse) ProtoMessage 

func (*InstallResponse) ProtoMessage()

func (*InstallResponse) ProtoReflect 

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

func (*InstallResponse) Reset 

func (x *InstallResponse) Reset()

func (*InstallResponse) String 

func (x *InstallResponse) String() string

type K8Scluster 

type K8Scluster struct {

	// General info about the cluster.
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=clusterInfo,proto3" json:"clusterInfo,omitempty"`
	// Network range for the VPN.
	Network string `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
	// Kubeconfig of the cluster.
	Kubeconfig string `protobuf:"bytes,3,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	// Kubernetes version.
	Kubernetes string `protobuf:"bytes,4,opt,name=kubernetes,proto3" json:"kubernetes,omitempty"`
	// contains filtered or unexported fields
}

K8scluster represents a single kubernetes cluster specified in the manifest.

func (*K8Scluster) Descriptor deprecated 

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

Deprecated: Use K8Scluster.ProtoReflect.Descriptor instead.

func (*K8Scluster) GetClusterInfo 

func (x *K8Scluster) GetClusterInfo() *ClusterInfo

func (*K8Scluster) GetKubeconfig 

func (x *K8Scluster) GetKubeconfig() string

func (*K8Scluster) GetKubernetes 

func (x *K8Scluster) GetKubernetes() string

func (*K8Scluster) GetNetwork 

func (x *K8Scluster) GetNetwork() string

func (*K8Scluster) ProtoMessage 

func (*K8Scluster) ProtoMessage()

func (*K8Scluster) ProtoReflect 

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

func (*K8Scluster) Reset 

func (x *K8Scluster) Reset()

func (*K8Scluster) String 

func (x *K8Scluster) String() string

type KubeElevenServiceClient 

type KubeElevenServiceClient interface {
	// BuildCluster builds the kubernetes clusters specified in the provided config.
	BuildCluster(ctx context.Context, in *BuildClusterRequest, opts ...grpc.CallOption) (*BuildClusterResponse, error)
	// DestroyCluster destroys the kubernetes clusters specified in the provided config.
	DestroyCluster(ctx context.Context, in *DestroyClusterRequest, opts ...grpc.CallOption) (*DestroyClusterResponse, error)
}

KubeElevenServiceClient is the client API for KubeElevenService 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 NewKubeElevenServiceClient 

func NewKubeElevenServiceClient(cc grpc.ClientConnInterface) KubeElevenServiceClient

type KubeElevenServiceServer 

type KubeElevenServiceServer interface {
	// BuildCluster builds the kubernetes clusters specified in the provided config.
	BuildCluster(context.Context, *BuildClusterRequest) (*BuildClusterResponse, error)
	// DestroyCluster destroys the kubernetes clusters specified in the provided config.
	DestroyCluster(context.Context, *DestroyClusterRequest) (*DestroyClusterResponse, error)
	// contains filtered or unexported methods
}

KubeElevenServiceServer is the server API for KubeElevenService service. All implementations must embed UnimplementedKubeElevenServiceServer for forward compatibility

type KuberServiceClient 

type KuberServiceClient interface {
	// RemoveLBScrapeConfig removes scrape config for every LB detached from this cluster.
	RemoveLBScrapeConfig(ctx context.Context, in *RemoveLBScrapeConfigRequest, opts ...grpc.CallOption) (*RemoveLBScrapeConfigResponse, error)
	// StoreLBScrapeConfig stores scrape config for every LB attached to this cluster.
	StoreLBScrapeConfig(ctx context.Context, in *StoreLBScrapeConfigRequest, opts ...grpc.CallOption) (*StoreLBScrapeConfigResponse, error)
	// StoreClusterMetadata creates a secret, which holds the private key and a list of public IP addresses of the cluster supplied.
	StoreClusterMetadata(ctx context.Context, in *StoreClusterMetadataRequest, opts ...grpc.CallOption) (*StoreClusterMetadataResponse, error)
	// DeleteClusterMetadata deletes the secret holding the private key and public IP addresses of the cluster supplied.
	DeleteClusterMetadata(ctx context.Context, in *DeleteClusterMetadataRequest, opts ...grpc.CallOption) (*DeleteClusterMetadataResponse, error)
	// SetUpStorage installs Longhorn into the cluster.
	SetUpStorage(ctx context.Context, in *SetUpStorageRequest, opts ...grpc.CallOption) (*SetUpStorageResponse, error)
	// StoreKubeconfig creates a secret, which holds the kubeconfig of a Claudie-created cluster.
	StoreKubeconfig(ctx context.Context, in *StoreKubeconfigRequest, opts ...grpc.CallOption) (*StoreKubeconfigResponse, error)
	// DeleteKubeconfig removes the secret that holds the kubeconfig of a Claudie-created cluster.
	DeleteKubeconfig(ctx context.Context, in *DeleteKubeconfigRequest, opts ...grpc.CallOption) (*DeleteKubeconfigResponse, error)
	// DeleteNodes deletes the specified nodes from a k8s cluster.
	DeleteNodes(ctx context.Context, in *DeleteNodesRequest, opts ...grpc.CallOption) (*DeleteNodesResponse, error)
	// PatchNodes applies attributes like providerID, labels or taints to the nodes.
	PatchNodes(ctx context.Context, in *PatchNodesRequest, opts ...grpc.CallOption) (*PatchNodesResponse, error)
	// SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter for every cluster specified.
	SetUpClusterAutoscaler(ctx context.Context, in *SetUpClusterAutoscalerRequest, opts ...grpc.CallOption) (*SetUpClusterAutoscalerResponse, error)
	// DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter for every cluster specified.
	DestroyClusterAutoscaler(ctx context.Context, in *DestroyClusterAutoscalerRequest, opts ...grpc.CallOption) (*DestroyClusterAutoscalerResponse, error)
	// PatchClusterInfoConfigMap updates the cluster-info config map in the kube-public namespace with the the
	// kubeconfig. This needs to be done after an api endpoint change as the config map in the kube-public namespace
	// is used by kubeadm when joining.
	PatchClusterInfoConfigMap(ctx context.Context, in *PatchClusterInfoConfigMapRequest, opts ...grpc.CallOption) (*PatchClusterInfoConfigMapResponse, error)
	// CiliumRolloutRestart performs a rollout restart of the cilium daemonset.
	CiliumRolloutRestart(ctx context.Context, in *CiliumRolloutRestartRequest, opts ...grpc.CallOption) (*CiliumRolloutRestartResponse, error)
}

KuberServiceClient is the client API for KuberService 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 NewKuberServiceClient 

func NewKuberServiceClient(cc grpc.ClientConnInterface) KuberServiceClient

type KuberServiceServer 

type KuberServiceServer interface {
	// RemoveLBScrapeConfig removes scrape config for every LB detached from this cluster.
	RemoveLBScrapeConfig(context.Context, *RemoveLBScrapeConfigRequest) (*RemoveLBScrapeConfigResponse, error)
	// StoreLBScrapeConfig stores scrape config for every LB attached to this cluster.
	StoreLBScrapeConfig(context.Context, *StoreLBScrapeConfigRequest) (*StoreLBScrapeConfigResponse, error)
	// StoreClusterMetadata creates a secret, which holds the private key and a list of public IP addresses of the cluster supplied.
	StoreClusterMetadata(context.Context, *StoreClusterMetadataRequest) (*StoreClusterMetadataResponse, error)
	// DeleteClusterMetadata deletes the secret holding the private key and public IP addresses of the cluster supplied.
	DeleteClusterMetadata(context.Context, *DeleteClusterMetadataRequest) (*DeleteClusterMetadataResponse, error)
	// SetUpStorage installs Longhorn into the cluster.
	SetUpStorage(context.Context, *SetUpStorageRequest) (*SetUpStorageResponse, error)
	// StoreKubeconfig creates a secret, which holds the kubeconfig of a Claudie-created cluster.
	StoreKubeconfig(context.Context, *StoreKubeconfigRequest) (*StoreKubeconfigResponse, error)
	// DeleteKubeconfig removes the secret that holds the kubeconfig of a Claudie-created cluster.
	DeleteKubeconfig(context.Context, *DeleteKubeconfigRequest) (*DeleteKubeconfigResponse, error)
	// DeleteNodes deletes the specified nodes from a k8s cluster.
	DeleteNodes(context.Context, *DeleteNodesRequest) (*DeleteNodesResponse, error)
	// PatchNodes applies attributes like providerID, labels or taints to the nodes.
	PatchNodes(context.Context, *PatchNodesRequest) (*PatchNodesResponse, error)
	// SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter for every cluster specified.
	SetUpClusterAutoscaler(context.Context, *SetUpClusterAutoscalerRequest) (*SetUpClusterAutoscalerResponse, error)
	// DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter for every cluster specified.
	DestroyClusterAutoscaler(context.Context, *DestroyClusterAutoscalerRequest) (*DestroyClusterAutoscalerResponse, error)
	// PatchClusterInfoConfigMap updates the cluster-info config map in the kube-public namespace with the the
	// kubeconfig. This needs to be done after an api endpoint change as the config map in the kube-public namespace
	// is used by kubeadm when joining.
	PatchClusterInfoConfigMap(context.Context, *PatchClusterInfoConfigMapRequest) (*PatchClusterInfoConfigMapResponse, error)
	// CiliumRolloutRestart performs a rollout restart of the cilium daemonset.
	CiliumRolloutRestart(context.Context, *CiliumRolloutRestartRequest) (*CiliumRolloutRestartResponse, error)
	// contains filtered or unexported methods
}

KuberServiceServer is the server API for KuberService service. All implementations must embed UnimplementedKuberServiceServer for forward compatibility

type LBcluster 

type LBcluster struct {

	// General info about the cluster.
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=clusterInfo,proto3" json:"clusterInfo,omitempty"`
	// Array of Load balancer roles.
	Roles []*Role `protobuf:"bytes,2,rep,name=roles,proto3" json:"roles,omitempty"`
	// DNS information.
	Dns *DNS `protobuf:"bytes,3,opt,name=dns,proto3" json:"dns,omitempty"`
	// Kubernetes cluster name of the cluster this load balancer is attached to.
	TargetedK8S string `protobuf:"bytes,4,opt,name=targetedK8s,proto3" json:"targetedK8s,omitempty"`
	// contains filtered or unexported fields
}

LBcluster represents a single load balancer cluster specified in the manifest.

func (*LBcluster) Descriptor deprecated 

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

Deprecated: Use LBcluster.ProtoReflect.Descriptor instead.

func (*LBcluster) GetClusterInfo 

func (x *LBcluster) GetClusterInfo() *ClusterInfo

func (*LBcluster) GetDns 

func (x *LBcluster) GetDns() *DNS

func (*LBcluster) GetRoles 

func (x *LBcluster) GetRoles() []*Role

func (*LBcluster) GetTargetedK8S 

func (x *LBcluster) GetTargetedK8S() string

func (*LBcluster) ProtoMessage 

func (*LBcluster) ProtoMessage()

func (*LBcluster) ProtoReflect 

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

func (*LBcluster) Reset 

func (x *LBcluster) Reset()

func (*LBcluster) String 

func (x *LBcluster) String() string

type MachineSpec added in v0.6.0 

type MachineSpec struct {
	CpuCount int32 `protobuf:"varint,1,opt,name=cpuCount,proto3" json:"cpuCount,omitempty"`
	Memory   int32 `protobuf:"varint,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// contains filtered or unexported fields
}

MachineSpec further specifies the requested server type.

func (*MachineSpec) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use MachineSpec.ProtoReflect.Descriptor instead.

func (*MachineSpec) GetCpuCount added in v0.6.0 

func (x *MachineSpec) GetCpuCount() int32

func (*MachineSpec) GetMemory added in v0.6.0 

func (x *MachineSpec) GetMemory() int32

func (*MachineSpec) ProtoMessage added in v0.6.0 

func (*MachineSpec) ProtoMessage()

func (*MachineSpec) ProtoReflect added in v0.6.0 

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

func (*MachineSpec) Reset added in v0.6.0 

func (x *MachineSpec) Reset()

func (*MachineSpec) String added in v0.6.0 

func (x *MachineSpec) String() string

type MetaValue added in v0.2.2 

type MetaValue struct {

	// Possible values for the node pool metadata.
	//
	// Types that are assignable to MetaValueOneOf:
	//
	//	*MetaValue_Cidr
	MetaValueOneOf isMetaValue_MetaValueOneOf `protobuf_oneof:"MetaValueOneOf"`
	// contains filtered or unexported fields
}

MetaValue for the node pool metadata.

func (*MetaValue) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use MetaValue.ProtoReflect.Descriptor instead.

func (*MetaValue) GetCidr added in v0.2.2 

func (x *MetaValue) GetCidr() string

func (*MetaValue) GetMetaValueOneOf added in v0.2.2 

func (m *MetaValue) GetMetaValueOneOf() isMetaValue_MetaValueOneOf

func (*MetaValue) ProtoMessage added in v0.2.2 

func (*MetaValue) ProtoMessage()

func (*MetaValue) ProtoReflect added in v0.2.2 

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

func (*MetaValue) Reset added in v0.2.2 

func (x *MetaValue) Reset()

func (*MetaValue) String added in v0.2.2 

func (x *MetaValue) String() string

type MetaValue_Cidr added in v0.2.2 

type MetaValue_Cidr struct {
	// Subnet CIDR in private VPC for the node pool.
	Cidr string `protobuf:"bytes,1,opt,name=cidr,proto3,oneof"`
}

type Node 

type Node struct {

	// Name of the node.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Private IP of the node in the VPN.
	Private string `protobuf:"bytes,2,opt,name=private,proto3" json:"private,omitempty"`
	// Public IP of the node.
	Public string `protobuf:"bytes,3,opt,name=public,proto3" json:"public,omitempty"`
	// Type of the node.
	NodeType NodeType `protobuf:"varint,4,opt,name=nodeType,proto3,enum=claudie.NodeType" json:"nodeType,omitempty"`
	// contains filtered or unexported fields
}

Node represents a single node from the node pool.

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetNodeType 

func (x *Node) GetNodeType() NodeType

func (*Node) GetPrivate 

func (x *Node) GetPrivate() string

func (*Node) GetPublic 

func (x *Node) GetPublic() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodePool 

type NodePool struct {

	// Dynamic or Static node pool info.
	//
	// Types that are assignable to NodePoolType:
	//
	//	*NodePool_DynamicNodePool
	//	*NodePool_StaticNodePool
	NodePoolType isNodePool_NodePoolType `protobuf_oneof:"NodePoolType"`
	// Name of static node pool.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Array of nodes in this node pool.
	Nodes []*Node `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// Flag to differentiate between control and compute nodes.
	IsControl bool `protobuf:"varint,5,opt,name=isControl,proto3" json:"isControl,omitempty"`
	// User defined labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// User defined taints.
	Taints []*Taint `protobuf:"bytes,7,rep,name=taints,proto3" json:"taints,omitempty"`
	// User definded annotations.
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

NodePool represents a single node pool used in cluster.

func (*NodePool) Descriptor deprecated 

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

Deprecated: Use NodePool.ProtoReflect.Descriptor instead.

func (*NodePool) GetAnnotations added in v0.7.0 

func (x *NodePool) GetAnnotations() map[string]string

func (*NodePool) GetDynamicNodePool added in v0.4.0 

func (x *NodePool) GetDynamicNodePool() *DynamicNodePool

func (*NodePool) GetIsControl 

func (x *NodePool) GetIsControl() bool

func (*NodePool) GetLabels added in v0.4.2 

func (x *NodePool) GetLabels() map[string]string

func (*NodePool) GetName 

func (x *NodePool) GetName() string

func (*NodePool) GetNodePoolType added in v0.4.0 

func (m *NodePool) GetNodePoolType() isNodePool_NodePoolType

func (*NodePool) GetNodes 

func (x *NodePool) GetNodes() []*Node

func (*NodePool) GetStaticNodePool added in v0.4.0 

func (x *NodePool) GetStaticNodePool() *StaticNodePool

func (*NodePool) GetTaints added in v0.4.2 

func (x *NodePool) GetTaints() []*Taint

func (*NodePool) ProtoMessage 

func (*NodePool) ProtoMessage()

func (*NodePool) ProtoReflect 

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

func (*NodePool) Reset 

func (x *NodePool) Reset()

func (*NodePool) String 

func (x *NodePool) String() string

type NodePool_DynamicNodePool added in v0.4.0 

type NodePool_DynamicNodePool struct {
	DynamicNodePool *DynamicNodePool `protobuf:"bytes,1,opt,name=dynamicNodePool,proto3,oneof"`
}

type NodePool_StaticNodePool added in v0.4.0 

type NodePool_StaticNodePool struct {
	StaticNodePool *StaticNodePool `protobuf:"bytes,2,opt,name=staticNodePool,proto3,oneof"`
}

type NodeType 

type NodeType int32

NodeType specifies the type of the node. 

const (
	// Worker/Compute node.
	NodeType_worker NodeType = 0
	// Master/Control node.
	NodeType_master NodeType = 1
	// Master node, which is also an API endpoint.
	NodeType_apiEndpoint NodeType = 2
)

func (NodeType) Descriptor 

func (NodeType) Descriptor() protoreflect.EnumDescriptor

func (NodeType) Enum 

func (x NodeType) Enum() *NodeType

func (NodeType) EnumDescriptor deprecated 

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

Deprecated: Use NodeType.Descriptor instead.

func (NodeType) Number 

func (x NodeType) Number() protoreflect.EnumNumber

func (NodeType) String 

func (x NodeType) String() string

func (NodeType) Type 

func (NodeType) Type() protoreflect.EnumType

type OperatorServiceClient added in v0.4.1 

type OperatorServiceClient interface {
	// SendAutoscalerEvent sends events to claudie-operator when a scale up/down occurs
	SendAutoscalerEvent(ctx context.Context, in *SendAutoscalerEventRequest, opts ...grpc.CallOption) (*SendAutoscalerEventResponse, error)
}

OperatorServiceClient is the client API for OperatorService 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 NewOperatorServiceClient added in v0.4.1 

func NewOperatorServiceClient(cc grpc.ClientConnInterface) OperatorServiceClient

type OperatorServiceServer added in v0.4.1 

type OperatorServiceServer interface {
	// SendAutoscalerEvent sends events to claudie-operator when a scale up/down occurs
	SendAutoscalerEvent(context.Context, *SendAutoscalerEventRequest) (*SendAutoscalerEventResponse, error)
	// contains filtered or unexported methods
}

OperatorServiceServer is the server API for OperatorService service. All implementations must embed UnimplementedOperatorServiceServer for forward compatibility

type PatchClusterInfoConfigMapRequest added in v0.3.1 

type PatchClusterInfoConfigMapRequest struct {
	DesiredCluster *K8Scluster `protobuf:"bytes,1,opt,name=desiredCluster,proto3" json:"desiredCluster,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchClusterInfoConfigMapRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use PatchClusterInfoConfigMapRequest.ProtoReflect.Descriptor instead.

func (*PatchClusterInfoConfigMapRequest) GetDesiredCluster added in v0.3.1 

func (x *PatchClusterInfoConfigMapRequest) GetDesiredCluster() *K8Scluster

func (*PatchClusterInfoConfigMapRequest) ProtoMessage added in v0.3.1 

func (*PatchClusterInfoConfigMapRequest) ProtoMessage()

func (*PatchClusterInfoConfigMapRequest) ProtoReflect added in v0.3.1 

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

func (*PatchClusterInfoConfigMapRequest) Reset added in v0.3.1 

func (x *PatchClusterInfoConfigMapRequest) Reset()

func (*PatchClusterInfoConfigMapRequest) String added in v0.3.1 

func (x *PatchClusterInfoConfigMapRequest) String() string

type PatchClusterInfoConfigMapResponse added in v0.3.1 

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

func (*PatchClusterInfoConfigMapResponse) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use PatchClusterInfoConfigMapResponse.ProtoReflect.Descriptor instead.

func (*PatchClusterInfoConfigMapResponse) ProtoMessage added in v0.3.1 

func (*PatchClusterInfoConfigMapResponse) ProtoMessage()

func (*PatchClusterInfoConfigMapResponse) ProtoReflect added in v0.3.1 

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

func (*PatchClusterInfoConfigMapResponse) Reset added in v0.3.1 

func (x *PatchClusterInfoConfigMapResponse) Reset()

func (*PatchClusterInfoConfigMapResponse) String added in v0.3.1 

func (x *PatchClusterInfoConfigMapResponse) String() string

type PatchNodesRequest added in v0.4.2 

type PatchNodesRequest struct {
	Cluster *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchNodesRequest) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use PatchNodesRequest.ProtoReflect.Descriptor instead.

func (*PatchNodesRequest) GetCluster added in v0.4.2 

func (x *PatchNodesRequest) GetCluster() *K8Scluster

func (*PatchNodesRequest) ProtoMessage added in v0.4.2 

func (*PatchNodesRequest) ProtoMessage()

func (*PatchNodesRequest) ProtoReflect added in v0.4.2 

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

func (*PatchNodesRequest) Reset added in v0.4.2 

func (x *PatchNodesRequest) Reset()

func (*PatchNodesRequest) String added in v0.4.2 

func (x *PatchNodesRequest) String() string

type PatchNodesResponse added in v0.4.2 

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

func (*PatchNodesResponse) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use PatchNodesResponse.ProtoReflect.Descriptor instead.

func (*PatchNodesResponse) ProtoMessage added in v0.4.2 

func (*PatchNodesResponse) ProtoMessage()

func (*PatchNodesResponse) ProtoReflect added in v0.4.2 

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

func (*PatchNodesResponse) Reset added in v0.4.2 

func (x *PatchNodesResponse) Reset()

func (*PatchNodesResponse) String added in v0.4.2 

func (x *PatchNodesResponse) String() string

type Project 

type Project struct {

	// Name of the project - same as input manifest name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Array of Kubernetes clusters.
	Clusters []*K8Scluster `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// Array of Load Balancer clusters.
	LoadBalancerClusters []*LBcluster `protobuf:"bytes,3,rep,name=loadBalancerClusters,proto3" json:"loadBalancerClusters,omitempty"`
	// contains filtered or unexported fields
}

Project represents the desired and current state of the manifest.

func (*Project) Descriptor deprecated 

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetClusters 

func (x *Project) GetClusters() []*K8Scluster

func (*Project) GetLoadBalancerClusters 

func (x *Project) GetLoadBalancerClusters() []*LBcluster

func (*Project) GetName 

func (x *Project) GetName() string

func (*Project) ProtoMessage 

func (*Project) ProtoMessage()

func (*Project) ProtoReflect 

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

func (*Project) Reset 

func (x *Project) Reset()

func (*Project) String 

func (x *Project) String() string

type Provider 

type Provider struct {

	// Provider name defined in input manifest.
	SpecName string `protobuf:"bytes,1,opt,name=specName,proto3" json:"specName,omitempty"`
	// Cloud provider name.
	CloudProviderName string `protobuf:"bytes,2,opt,name=cloudProviderName,proto3" json:"cloudProviderName,omitempty"`
	// Secret Credentials of the provider.
	// GCP - Service account key.
	// Hetzner - API token.
	// HetznerDNS - API token.
	// OCI - Private key.
	// AWS - Secret key.
	// Azure - Client secret.
	// Cloudflare - API token.
	Credentials string `protobuf:"bytes,3,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// GCP project. [GCP provider]
	GcpProject string `protobuf:"bytes,4,opt,name=gcpProject,proto3" json:"gcpProject,omitempty"`
	// OCID of the user. [OCI provider]
	OciUserOcid string `protobuf:"bytes,5,opt,name=ociUserOcid,proto3" json:"ociUserOcid,omitempty"`
	// OCID of the tenancy. [OCI provider]
	OciTenancyOcid string `protobuf:"bytes,6,opt,name=ociTenancyOcid,proto3" json:"ociTenancyOcid,omitempty"`
	// Fingerprint of the private key saved in Credentials. [OCI provider]
	OciFingerprint string `protobuf:"bytes,7,opt,name=ociFingerprint,proto3" json:"ociFingerprint,omitempty"`
	// OCID of the compartment. [OCI provider]
	OciCompartmentOcid string `protobuf:"bytes,8,opt,name=ociCompartmentOcid,proto3" json:"ociCompartmentOcid,omitempty"`
	// AWS access key to the secret key saved in the Credentials [AWS provider]
	AwsAccessKey string `protobuf:"bytes,9,opt,name=awsAccessKey,proto3" json:"awsAccessKey,omitempty"`
	// Azure ID of the subscription. [Azure provider]
	AzureSubscriptionId string `protobuf:"bytes,10,opt,name=azureSubscriptionId,proto3" json:"azureSubscriptionId,omitempty"`
	// Azure ID of the Tenant. [Azure provider]
	AzureTenantId string `protobuf:"bytes,11,opt,name=azureTenantId,proto3" json:"azureTenantId,omitempty"`
	// AzureID of the Client. [Azure provider]
	AzureClientId string `protobuf:"bytes,12,opt,name=azureClientId,proto3" json:"azureClientId,omitempty"`
	// contains filtered or unexported fields
}

func (*Provider) Descriptor deprecated 

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

Deprecated: Use Provider.ProtoReflect.Descriptor instead.

func (*Provider) GetAwsAccessKey 

func (x *Provider) GetAwsAccessKey() string

func (*Provider) GetAzureClientId 

func (x *Provider) GetAzureClientId() string

func (*Provider) GetAzureSubscriptionId 

func (x *Provider) GetAzureSubscriptionId() string

func (*Provider) GetAzureTenantId 

func (x *Provider) GetAzureTenantId() string

func (*Provider) GetCloudProviderName 

func (x *Provider) GetCloudProviderName() string

func (*Provider) GetCredentials 

func (x *Provider) GetCredentials() string

func (*Provider) GetGcpProject 

func (x *Provider) GetGcpProject() string

func (*Provider) GetOciCompartmentOcid 

func (x *Provider) GetOciCompartmentOcid() string

func (*Provider) GetOciFingerprint 

func (x *Provider) GetOciFingerprint() string

func (*Provider) GetOciTenancyOcid 

func (x *Provider) GetOciTenancyOcid() string

func (*Provider) GetOciUserOcid 

func (x *Provider) GetOciUserOcid() string

func (*Provider) GetSpecName 

func (x *Provider) GetSpecName() string

func (*Provider) ProtoMessage 

func (*Provider) ProtoMessage()

func (*Provider) ProtoReflect 

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

func (*Provider) Reset 

func (x *Provider) Reset()

func (*Provider) String 

func (x *Provider) String() string

type RemoveClaudieUtilitiesRequest added in v0.6.2 

type RemoveClaudieUtilitiesRequest struct {
	Current     *K8Scluster  `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	CurrentLbs  []*LBcluster `protobuf:"bytes,2,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	ProjectName string       `protobuf:"bytes,3,opt,name=projectName,proto3" json:"projectName,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveClaudieUtilitiesRequest) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use RemoveClaudieUtilitiesRequest.ProtoReflect.Descriptor instead.

func (*RemoveClaudieUtilitiesRequest) GetCurrent added in v0.6.2 

func (x *RemoveClaudieUtilitiesRequest) GetCurrent() *K8Scluster

func (*RemoveClaudieUtilitiesRequest) GetCurrentLbs added in v0.6.2 

func (x *RemoveClaudieUtilitiesRequest) GetCurrentLbs() []*LBcluster

func (*RemoveClaudieUtilitiesRequest) GetProjectName added in v0.6.2 

func (x *RemoveClaudieUtilitiesRequest) GetProjectName() string

func (*RemoveClaudieUtilitiesRequest) ProtoMessage added in v0.6.2 

func (*RemoveClaudieUtilitiesRequest) ProtoMessage()

func (*RemoveClaudieUtilitiesRequest) ProtoReflect added in v0.6.2 

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

func (*RemoveClaudieUtilitiesRequest) Reset added in v0.6.2 

func (x *RemoveClaudieUtilitiesRequest) Reset()

func (*RemoveClaudieUtilitiesRequest) String added in v0.6.2 

func (x *RemoveClaudieUtilitiesRequest) String() string

type RemoveClaudieUtilitiesResponse added in v0.6.2 

type RemoveClaudieUtilitiesResponse struct {
	Current    *K8Scluster  `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	CurrentLbs []*LBcluster `protobuf:"bytes,2,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveClaudieUtilitiesResponse) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use RemoveClaudieUtilitiesResponse.ProtoReflect.Descriptor instead.

func (*RemoveClaudieUtilitiesResponse) GetCurrent added in v0.6.2 

func (x *RemoveClaudieUtilitiesResponse) GetCurrent() *K8Scluster

func (*RemoveClaudieUtilitiesResponse) GetCurrentLbs added in v0.6.2 

func (x *RemoveClaudieUtilitiesResponse) GetCurrentLbs() []*LBcluster

func (*RemoveClaudieUtilitiesResponse) ProtoMessage added in v0.6.2 

func (*RemoveClaudieUtilitiesResponse) ProtoMessage()

func (*RemoveClaudieUtilitiesResponse) ProtoReflect added in v0.6.2 

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

func (*RemoveClaudieUtilitiesResponse) Reset added in v0.6.2 

func (x *RemoveClaudieUtilitiesResponse) Reset()

func (*RemoveClaudieUtilitiesResponse) String added in v0.6.2 

func (x *RemoveClaudieUtilitiesResponse) String() string

type RemoveLBScrapeConfigRequest added in v0.4.2 

type RemoveLBScrapeConfigRequest struct {
	Cluster *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveLBScrapeConfigRequest) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use RemoveLBScrapeConfigRequest.ProtoReflect.Descriptor instead.

func (*RemoveLBScrapeConfigRequest) GetCluster added in v0.4.2 

func (x *RemoveLBScrapeConfigRequest) GetCluster() *K8Scluster

func (*RemoveLBScrapeConfigRequest) ProtoMessage added in v0.4.2 

func (*RemoveLBScrapeConfigRequest) ProtoMessage()

func (*RemoveLBScrapeConfigRequest) ProtoReflect added in v0.4.2 

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

func (*RemoveLBScrapeConfigRequest) Reset added in v0.4.2 

func (x *RemoveLBScrapeConfigRequest) Reset()

func (*RemoveLBScrapeConfigRequest) String added in v0.4.2 

func (x *RemoveLBScrapeConfigRequest) String() string

type RemoveLBScrapeConfigResponse added in v0.4.2 

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

func (*RemoveLBScrapeConfigResponse) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use RemoveLBScrapeConfigResponse.ProtoReflect.Descriptor instead.

func (*RemoveLBScrapeConfigResponse) ProtoMessage added in v0.4.2 

func (*RemoveLBScrapeConfigResponse) ProtoMessage()

func (*RemoveLBScrapeConfigResponse) ProtoReflect added in v0.4.2 

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

func (*RemoveLBScrapeConfigResponse) Reset added in v0.4.2 

func (x *RemoveLBScrapeConfigResponse) Reset()

func (*RemoveLBScrapeConfigResponse) String added in v0.4.2 

func (x *RemoveLBScrapeConfigResponse) String() string

type Role 

type Role struct {

	// Name of the role.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Protocol that load balancer uses to forward traffic. ["tcp", "udp"]
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// Port that load balancer will forward from.
	Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// Port that load balancer will forward to.
	TargetPort int32 `protobuf:"varint,4,opt,name=targetPort,proto3" json:"targetPort,omitempty"`
	// TODO: remove in favor of targetPools.
	// Targeted nodes in Kubernetes clusters.
	Target      Target   `protobuf:"varint,5,opt,name=target,proto3,enum=claudie.Target" json:"target,omitempty"`
	TargetPools []string `protobuf:"bytes,7,rep,name=targetPools,proto3" json:"targetPools,omitempty"`
	// Type of the role.
	RoleType RoleType `protobuf:"varint,6,opt,name=roleType,proto3,enum=claudie.RoleType" json:"roleType,omitempty"`
	// contains filtered or unexported fields
}

Role represents a single loadbalancer role from the manifest.

func (*Role) Descriptor deprecated 

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

Deprecated: Use Role.ProtoReflect.Descriptor instead.

func (*Role) GetName 

func (x *Role) GetName() string

func (*Role) GetPort 

func (x *Role) GetPort() int32

func (*Role) GetProtocol 

func (x *Role) GetProtocol() string

func (*Role) GetRoleType 

func (x *Role) GetRoleType() RoleType

func (*Role) GetTarget 

func (x *Role) GetTarget() Target

func (*Role) GetTargetPools added in v0.7.2 

func (x *Role) GetTargetPools() []string

func (*Role) GetTargetPort 

func (x *Role) GetTargetPort() int32

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) ProtoReflect 

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

func (*Role) Reset 

func (x *Role) Reset()

func (*Role) String 

func (x *Role) String() string

type RoleType 

type RoleType int32

RoleType specifies the type of the role. 

const (
	// API server load balancer.
	RoleType_ApiServer RoleType = 0
	// Ingress load balancer.
	RoleType_Ingress RoleType = 1
)

func (RoleType) Descriptor 

func (RoleType) Descriptor() protoreflect.EnumDescriptor

func (RoleType) Enum 

func (x RoleType) Enum() *RoleType

func (RoleType) EnumDescriptor deprecated 

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

Deprecated: Use RoleType.Descriptor instead.

func (RoleType) Number 

func (x RoleType) Number() protoreflect.EnumNumber

func (RoleType) String 

func (x RoleType) String() string

func (RoleType) Type 

func (RoleType) Type() protoreflect.EnumType

type SaveConfigRequest 

type SaveConfigRequest struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveConfigRequest) Descriptor deprecated 

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

Deprecated: Use SaveConfigRequest.ProtoReflect.Descriptor instead.

func (*SaveConfigRequest) GetConfig 

func (x *SaveConfigRequest) GetConfig() *Config

func (*SaveConfigRequest) ProtoMessage 

func (*SaveConfigRequest) ProtoMessage()

func (*SaveConfigRequest) ProtoReflect 

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

func (*SaveConfigRequest) Reset 

func (x *SaveConfigRequest) Reset()

func (*SaveConfigRequest) String 

func (x *SaveConfigRequest) String() string

type SaveConfigResponse 

type SaveConfigResponse struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveConfigResponse) Descriptor deprecated 

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

Deprecated: Use SaveConfigResponse.ProtoReflect.Descriptor instead.

func (*SaveConfigResponse) GetConfig 

func (x *SaveConfigResponse) GetConfig() *Config

func (*SaveConfigResponse) ProtoMessage 

func (*SaveConfigResponse) ProtoMessage()

func (*SaveConfigResponse) ProtoReflect 

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

func (*SaveConfigResponse) Reset 

func (x *SaveConfigResponse) Reset()

func (*SaveConfigResponse) String 

func (x *SaveConfigResponse) String() string

type SaveWorkflowStateRequest added in v0.2.2 

type SaveWorkflowStateRequest struct {
	ConfigName  string    `protobuf:"bytes,1,opt,name=configName,proto3" json:"configName,omitempty"`
	ClusterName string    `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Workflow    *Workflow `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

Save

func (*SaveWorkflowStateRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use SaveWorkflowStateRequest.ProtoReflect.Descriptor instead.

func (*SaveWorkflowStateRequest) GetClusterName added in v0.2.2 

func (x *SaveWorkflowStateRequest) GetClusterName() string

func (*SaveWorkflowStateRequest) GetConfigName added in v0.2.2 

func (x *SaveWorkflowStateRequest) GetConfigName() string

func (*SaveWorkflowStateRequest) GetWorkflow added in v0.2.2 

func (x *SaveWorkflowStateRequest) GetWorkflow() *Workflow

func (*SaveWorkflowStateRequest) ProtoMessage added in v0.2.2 

func (*SaveWorkflowStateRequest) ProtoMessage()

func (*SaveWorkflowStateRequest) ProtoReflect added in v0.2.2 

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

func (*SaveWorkflowStateRequest) Reset added in v0.2.2 

func (x *SaveWorkflowStateRequest) Reset()

func (*SaveWorkflowStateRequest) String added in v0.2.2 

func (x *SaveWorkflowStateRequest) String() string

type SaveWorkflowStateResponse added in v0.2.2 

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

func (*SaveWorkflowStateResponse) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use SaveWorkflowStateResponse.ProtoReflect.Descriptor instead.

func (*SaveWorkflowStateResponse) ProtoMessage added in v0.2.2 

func (*SaveWorkflowStateResponse) ProtoMessage()

func (*SaveWorkflowStateResponse) ProtoReflect added in v0.2.2 

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

func (*SaveWorkflowStateResponse) Reset added in v0.2.2 

func (x *SaveWorkflowStateResponse) Reset()

func (*SaveWorkflowStateResponse) String added in v0.2.2 

func (x *SaveWorkflowStateResponse) String() string

type SendAutoscalerEventRequest added in v0.4.1 

type SendAutoscalerEventRequest struct {
	InputManifestName      string `protobuf:"bytes,1,opt,name=InputManifestName,proto3" json:"InputManifestName,omitempty"`
	InputManifestNamespace string `protobuf:"bytes,2,opt,name=InputManifestNamespace,proto3" json:"InputManifestNamespace,omitempty"`
	// contains filtered or unexported fields
}

func (*SendAutoscalerEventRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use SendAutoscalerEventRequest.ProtoReflect.Descriptor instead.

func (*SendAutoscalerEventRequest) GetInputManifestName added in v0.4.1 

func (x *SendAutoscalerEventRequest) GetInputManifestName() string

func (*SendAutoscalerEventRequest) GetInputManifestNamespace added in v0.4.1 

func (x *SendAutoscalerEventRequest) GetInputManifestNamespace() string

func (*SendAutoscalerEventRequest) ProtoMessage added in v0.4.1 

func (*SendAutoscalerEventRequest) ProtoMessage()

func (*SendAutoscalerEventRequest) ProtoReflect added in v0.4.1 

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

func (*SendAutoscalerEventRequest) Reset added in v0.4.1 

func (x *SendAutoscalerEventRequest) Reset()

func (*SendAutoscalerEventRequest) String added in v0.4.1 

func (x *SendAutoscalerEventRequest) String() string

type SendAutoscalerEventResponse added in v0.4.1 

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

func (*SendAutoscalerEventResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use SendAutoscalerEventResponse.ProtoReflect.Descriptor instead.

func (*SendAutoscalerEventResponse) ProtoMessage added in v0.4.1 

func (*SendAutoscalerEventResponse) ProtoMessage()

func (*SendAutoscalerEventResponse) ProtoReflect added in v0.4.1 

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

func (*SendAutoscalerEventResponse) Reset added in v0.4.1 

func (x *SendAutoscalerEventResponse) Reset()

func (*SendAutoscalerEventResponse) String added in v0.4.1 

func (x *SendAutoscalerEventResponse) String() string

type SetUpClusterAutoscalerRequest added in v0.2.2 

type SetUpClusterAutoscalerRequest struct {
	ProjectName string      `protobuf:"bytes,1,opt,name=projectName,proto3" json:"projectName,omitempty"`
	Cluster     *K8Scluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUpClusterAutoscalerRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use SetUpClusterAutoscalerRequest.ProtoReflect.Descriptor instead.

func (*SetUpClusterAutoscalerRequest) GetCluster added in v0.2.2 

func (x *SetUpClusterAutoscalerRequest) GetCluster() *K8Scluster

func (*SetUpClusterAutoscalerRequest) GetProjectName added in v0.2.2 

func (x *SetUpClusterAutoscalerRequest) GetProjectName() string

func (*SetUpClusterAutoscalerRequest) ProtoMessage added in v0.2.2 

func (*SetUpClusterAutoscalerRequest) ProtoMessage()

func (*SetUpClusterAutoscalerRequest) ProtoReflect added in v0.2.2 

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

func (*SetUpClusterAutoscalerRequest) Reset added in v0.2.2 

func (x *SetUpClusterAutoscalerRequest) Reset()

func (*SetUpClusterAutoscalerRequest) String added in v0.2.2 

func (x *SetUpClusterAutoscalerRequest) String() string

type SetUpClusterAutoscalerResponse added in v0.2.2 

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

func (*SetUpClusterAutoscalerResponse) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use SetUpClusterAutoscalerResponse.ProtoReflect.Descriptor instead.

func (*SetUpClusterAutoscalerResponse) ProtoMessage added in v0.2.2 

func (*SetUpClusterAutoscalerResponse) ProtoMessage()

func (*SetUpClusterAutoscalerResponse) ProtoReflect added in v0.2.2 

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

func (*SetUpClusterAutoscalerResponse) Reset added in v0.2.2 

func (x *SetUpClusterAutoscalerResponse) Reset()

func (*SetUpClusterAutoscalerResponse) String added in v0.2.2 

func (x *SetUpClusterAutoscalerResponse) String() string

type SetUpLBRequest 

type SetUpLBRequest struct {
	Desired             *K8Scluster  `protobuf:"bytes,1,opt,name=desired,proto3" json:"desired,omitempty"`
	CurrentLbs          []*LBcluster `protobuf:"bytes,2,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	DesiredLbs          []*LBcluster `protobuf:"bytes,3,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	PreviousAPIEndpoint string       `protobuf:"bytes,4,opt,name=previousAPIEndpoint,proto3" json:"previousAPIEndpoint,omitempty"`
	ProjectName         string       `protobuf:"bytes,5,opt,name=projectName,proto3" json:"projectName,omitempty"`
	FirstRun            bool         `protobuf:"varint,6,opt,name=firstRun,proto3" json:"firstRun,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUpLBRequest) Descriptor deprecated 

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

Deprecated: Use SetUpLBRequest.ProtoReflect.Descriptor instead.

func (*SetUpLBRequest) GetCurrentLbs 

func (x *SetUpLBRequest) GetCurrentLbs() []*LBcluster

func (*SetUpLBRequest) GetDesired 

func (x *SetUpLBRequest) GetDesired() *K8Scluster

func (*SetUpLBRequest) GetDesiredLbs 

func (x *SetUpLBRequest) GetDesiredLbs() []*LBcluster

func (*SetUpLBRequest) GetFirstRun added in v0.3.1 

func (x *SetUpLBRequest) GetFirstRun() bool

func (*SetUpLBRequest) GetPreviousAPIEndpoint 

func (x *SetUpLBRequest) GetPreviousAPIEndpoint() string

func (*SetUpLBRequest) GetProjectName 

func (x *SetUpLBRequest) GetProjectName() string

func (*SetUpLBRequest) ProtoMessage 

func (*SetUpLBRequest) ProtoMessage()

func (*SetUpLBRequest) ProtoReflect 

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

func (*SetUpLBRequest) Reset 

func (x *SetUpLBRequest) Reset()

func (*SetUpLBRequest) String 

func (x *SetUpLBRequest) String() string

type SetUpLBResponse 

type SetUpLBResponse struct {
	Desired    *K8Scluster  `protobuf:"bytes,1,opt,name=desired,proto3" json:"desired,omitempty"`
	CurrentLbs []*LBcluster `protobuf:"bytes,2,rep,name=currentLbs,proto3" json:"currentLbs,omitempty"`
	DesiredLbs []*LBcluster `protobuf:"bytes,3,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUpLBResponse) Descriptor deprecated 

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

Deprecated: Use SetUpLBResponse.ProtoReflect.Descriptor instead.

func (*SetUpLBResponse) GetCurrentLbs 

func (x *SetUpLBResponse) GetCurrentLbs() []*LBcluster

func (*SetUpLBResponse) GetDesired 

func (x *SetUpLBResponse) GetDesired() *K8Scluster

func (*SetUpLBResponse) GetDesiredLbs 

func (x *SetUpLBResponse) GetDesiredLbs() []*LBcluster

func (*SetUpLBResponse) ProtoMessage 

func (*SetUpLBResponse) ProtoMessage()

func (*SetUpLBResponse) ProtoReflect 

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

func (*SetUpLBResponse) Reset 

func (x *SetUpLBResponse) Reset()

func (*SetUpLBResponse) String 

func (x *SetUpLBResponse) String() string

type SetUpStorageRequest 

type SetUpStorageRequest struct {
	DesiredCluster *K8Scluster `protobuf:"bytes,1,opt,name=desiredCluster,proto3" json:"desiredCluster,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUpStorageRequest) Descriptor deprecated 

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

Deprecated: Use SetUpStorageRequest.ProtoReflect.Descriptor instead.

func (*SetUpStorageRequest) GetDesiredCluster 

func (x *SetUpStorageRequest) GetDesiredCluster() *K8Scluster

func (*SetUpStorageRequest) ProtoMessage 

func (*SetUpStorageRequest) ProtoMessage()

func (*SetUpStorageRequest) ProtoReflect 

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

func (*SetUpStorageRequest) Reset 

func (x *SetUpStorageRequest) Reset()

func (*SetUpStorageRequest) String 

func (x *SetUpStorageRequest) String() string

type SetUpStorageResponse 

type SetUpStorageResponse struct {
	DesiredCluster *K8Scluster `protobuf:"bytes,1,opt,name=desiredCluster,proto3" json:"desiredCluster,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUpStorageResponse) Descriptor deprecated 

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

Deprecated: Use SetUpStorageResponse.ProtoReflect.Descriptor instead.

func (*SetUpStorageResponse) GetDesiredCluster 

func (x *SetUpStorageResponse) GetDesiredCluster() *K8Scluster

func (*SetUpStorageResponse) ProtoMessage 

func (*SetUpStorageResponse) ProtoMessage()

func (*SetUpStorageResponse) ProtoReflect 

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

func (*SetUpStorageResponse) Reset 

func (x *SetUpStorageResponse) Reset()

func (*SetUpStorageResponse) String 

func (x *SetUpStorageResponse) String() string

type StaticNodePool added in v0.4.0 

type StaticNodePool struct {

	// Map of keys for each static node in [<Node Endpoint>]<Key> form.
	NodeKeys map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

StaticNodePool represents static node pool used in cluster.

func (*StaticNodePool) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use StaticNodePool.ProtoReflect.Descriptor instead.

func (*StaticNodePool) GetNodeKeys added in v0.4.0 

func (x *StaticNodePool) GetNodeKeys() map[string]string

func (*StaticNodePool) ProtoMessage added in v0.4.0 

func (*StaticNodePool) ProtoMessage()

func (*StaticNodePool) ProtoReflect added in v0.4.0 

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

func (*StaticNodePool) Reset added in v0.4.0 

func (x *StaticNodePool) Reset()

func (*StaticNodePool) String added in v0.4.0 

func (x *StaticNodePool) String() string

type StaticNodepoolInfo added in v0.4.2 

type StaticNodepoolInfo int32

Enum used to replace data not present in static nodepools. 

const (
	StaticNodepoolInfo_STATIC_PROVIDER StaticNodepoolInfo = 0
	StaticNodepoolInfo_STATIC_REGION   StaticNodepoolInfo = 1
	StaticNodepoolInfo_STATIC_ZONE     StaticNodepoolInfo = 2
)

func (StaticNodepoolInfo) Descriptor added in v0.4.2 

func (StaticNodepoolInfo) Descriptor() protoreflect.EnumDescriptor

func (StaticNodepoolInfo) Enum added in v0.4.2 

func (x StaticNodepoolInfo) Enum() *StaticNodepoolInfo

func (StaticNodepoolInfo) EnumDescriptor deprecated added in v0.4.2 

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

Deprecated: Use StaticNodepoolInfo.Descriptor instead.

func (StaticNodepoolInfo) Number added in v0.4.2 

func (x StaticNodepoolInfo) Number() protoreflect.EnumNumber

func (StaticNodepoolInfo) String added in v0.4.2 

func (x StaticNodepoolInfo) String() string

func (StaticNodepoolInfo) Type added in v0.4.2 

func (StaticNodepoolInfo) Type() protoreflect.EnumType

type StoreClusterMetadataRequest 

type StoreClusterMetadataRequest struct {
	Cluster       *K8Scluster  `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	ProjectName   string       `protobuf:"bytes,2,opt,name=projectName,proto3" json:"projectName,omitempty"`
	Loadbalancers []*LBcluster `protobuf:"bytes,3,rep,name=loadbalancers,proto3" json:"loadbalancers,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreClusterMetadataRequest) Descriptor deprecated 

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

Deprecated: Use StoreClusterMetadataRequest.ProtoReflect.Descriptor instead.

func (*StoreClusterMetadataRequest) GetCluster 

func (x *StoreClusterMetadataRequest) GetCluster() *K8Scluster

func (*StoreClusterMetadataRequest) GetLoadbalancers added in v0.6.5 

func (x *StoreClusterMetadataRequest) GetLoadbalancers() []*LBcluster

func (*StoreClusterMetadataRequest) GetProjectName added in v0.3.2 

func (x *StoreClusterMetadataRequest) GetProjectName() string

func (*StoreClusterMetadataRequest) ProtoMessage 

func (*StoreClusterMetadataRequest) ProtoMessage()

func (*StoreClusterMetadataRequest) ProtoReflect 

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

func (*StoreClusterMetadataRequest) Reset 

func (x *StoreClusterMetadataRequest) Reset()

func (*StoreClusterMetadataRequest) String 

func (x *StoreClusterMetadataRequest) String() string

type StoreClusterMetadataResponse 

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

func (*StoreClusterMetadataResponse) Descriptor deprecated 

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

Deprecated: Use StoreClusterMetadataResponse.ProtoReflect.Descriptor instead.

func (*StoreClusterMetadataResponse) ProtoMessage 

func (*StoreClusterMetadataResponse) ProtoMessage()

func (*StoreClusterMetadataResponse) ProtoReflect 

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

func (*StoreClusterMetadataResponse) Reset 

func (x *StoreClusterMetadataResponse) Reset()

func (*StoreClusterMetadataResponse) String 

func (x *StoreClusterMetadataResponse) String() string

type StoreKubeconfigRequest 

type StoreKubeconfigRequest struct {
	Cluster     *K8Scluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	ProjectName string      `protobuf:"bytes,2,opt,name=projectName,proto3" json:"projectName,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreKubeconfigRequest) Descriptor deprecated 

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

Deprecated: Use StoreKubeconfigRequest.ProtoReflect.Descriptor instead.

func (*StoreKubeconfigRequest) GetCluster 

func (x *StoreKubeconfigRequest) GetCluster() *K8Scluster

func (*StoreKubeconfigRequest) GetProjectName added in v0.3.2 

func (x *StoreKubeconfigRequest) GetProjectName() string

func (*StoreKubeconfigRequest) ProtoMessage 

func (*StoreKubeconfigRequest) ProtoMessage()

func (*StoreKubeconfigRequest) ProtoReflect 

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

func (*StoreKubeconfigRequest) Reset 

func (x *StoreKubeconfigRequest) Reset()

func (*StoreKubeconfigRequest) String 

func (x *StoreKubeconfigRequest) String() string

type StoreKubeconfigResponse 

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

func (*StoreKubeconfigResponse) Descriptor deprecated 

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

Deprecated: Use StoreKubeconfigResponse.ProtoReflect.Descriptor instead.

func (*StoreKubeconfigResponse) ProtoMessage 

func (*StoreKubeconfigResponse) ProtoMessage()

func (*StoreKubeconfigResponse) ProtoReflect 

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

func (*StoreKubeconfigResponse) Reset 

func (x *StoreKubeconfigResponse) Reset()

func (*StoreKubeconfigResponse) String 

func (x *StoreKubeconfigResponse) String() string

type StoreLBScrapeConfigRequest added in v0.4.2 

type StoreLBScrapeConfigRequest struct {
	Cluster              *K8Scluster  `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	DesiredLoadbalancers []*LBcluster `protobuf:"bytes,2,rep,name=desiredLoadbalancers,proto3" json:"desiredLoadbalancers,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreLBScrapeConfigRequest) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use StoreLBScrapeConfigRequest.ProtoReflect.Descriptor instead.

func (*StoreLBScrapeConfigRequest) GetCluster added in v0.4.2 

func (x *StoreLBScrapeConfigRequest) GetCluster() *K8Scluster

func (*StoreLBScrapeConfigRequest) GetDesiredLoadbalancers added in v0.4.2 

func (x *StoreLBScrapeConfigRequest) GetDesiredLoadbalancers() []*LBcluster

func (*StoreLBScrapeConfigRequest) ProtoMessage added in v0.4.2 

func (*StoreLBScrapeConfigRequest) ProtoMessage()

func (*StoreLBScrapeConfigRequest) ProtoReflect added in v0.4.2 

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

func (*StoreLBScrapeConfigRequest) Reset added in v0.4.2 

func (x *StoreLBScrapeConfigRequest) Reset()

func (*StoreLBScrapeConfigRequest) String added in v0.4.2 

func (x *StoreLBScrapeConfigRequest) String() string

type StoreLBScrapeConfigResponse added in v0.4.2 

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

func (*StoreLBScrapeConfigResponse) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use StoreLBScrapeConfigResponse.ProtoReflect.Descriptor instead.

func (*StoreLBScrapeConfigResponse) ProtoMessage added in v0.4.2 

func (*StoreLBScrapeConfigResponse) ProtoMessage()

func (*StoreLBScrapeConfigResponse) ProtoReflect added in v0.4.2 

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

func (*StoreLBScrapeConfigResponse) Reset added in v0.4.2 

func (x *StoreLBScrapeConfigResponse) Reset()

func (*StoreLBScrapeConfigResponse) String added in v0.4.2 

func (x *StoreLBScrapeConfigResponse) String() string

type Taint added in v0.4.2 

type Taint struct {

	// Taint key.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Taint value.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Taint effect.
	Effect string `protobuf:"bytes,3,opt,name=effect,proto3" json:"effect,omitempty"`
	// contains filtered or unexported fields
}

Taint defines a custom defined taint for the node pools.

func (*Taint) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use Taint.ProtoReflect.Descriptor instead.

func (*Taint) GetEffect added in v0.4.2 

func (x *Taint) GetEffect() string

func (*Taint) GetKey added in v0.4.2 

func (x *Taint) GetKey() string

func (*Taint) GetValue added in v0.4.2 

func (x *Taint) GetValue() string

func (*Taint) ProtoMessage added in v0.4.2 

func (*Taint) ProtoMessage()

func (*Taint) ProtoReflect added in v0.4.2 

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

func (*Taint) Reset added in v0.4.2 

func (x *Taint) Reset()

func (*Taint) String added in v0.4.2 

func (x *Taint) String() string

type Target 

type Target int32

TODO: remove in favor of targetPools Target specifies which nodes are targeted by the load balancer. 

const (
	// All nodes in cluster.
	Target_k8sAllNodes Target = 0
	// Only Control nodes.
	Target_k8sControlPlane Target = 1
	// Only Compute nodes
	Target_k8sComputePlane Target = 2
)

func (Target) Descriptor 

func (Target) Descriptor() protoreflect.EnumDescriptor

func (Target) Enum 

func (x Target) Enum() *Target

func (Target) EnumDescriptor deprecated 

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

Deprecated: Use Target.Descriptor instead.

func (Target) Number 

func (x Target) Number() protoreflect.EnumNumber

func (Target) String 

func (x Target) String() string

func (Target) Type 

func (Target) Type() protoreflect.EnumType

type TeardownLBRequest 

type TeardownLBRequest struct {
	Desired    *K8Scluster  `protobuf:"bytes,1,opt,name=desired,proto3" json:"desired,omitempty"`
	DesiredLbs []*LBcluster `protobuf:"bytes,2,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	// LB clusters which were deleted from the Claudie manifest.
	DeletedLbs  []*LBcluster `protobuf:"bytes,3,rep,name=deletedLbs,proto3" json:"deletedLbs,omitempty"`
	ProjectName string       `protobuf:"bytes,4,opt,name=projectName,proto3" json:"projectName,omitempty"`
	// contains filtered or unexported fields
}

func (*TeardownLBRequest) Descriptor deprecated 

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

Deprecated: Use TeardownLBRequest.ProtoReflect.Descriptor instead.

func (*TeardownLBRequest) GetDeletedLbs 

func (x *TeardownLBRequest) GetDeletedLbs() []*LBcluster

func (*TeardownLBRequest) GetDesired 

func (x *TeardownLBRequest) GetDesired() *K8Scluster

func (*TeardownLBRequest) GetDesiredLbs 

func (x *TeardownLBRequest) GetDesiredLbs() []*LBcluster

func (*TeardownLBRequest) GetProjectName 

func (x *TeardownLBRequest) GetProjectName() string

func (*TeardownLBRequest) ProtoMessage 

func (*TeardownLBRequest) ProtoMessage()

func (*TeardownLBRequest) ProtoReflect 

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

func (*TeardownLBRequest) Reset 

func (x *TeardownLBRequest) Reset()

func (*TeardownLBRequest) String 

func (x *TeardownLBRequest) String() string

type TeardownLBResponse 

type TeardownLBResponse struct {
	PreviousAPIEndpoint string       `protobuf:"bytes,1,opt,name=previousAPIEndpoint,proto3" json:"previousAPIEndpoint,omitempty"`
	Desired             *K8Scluster  `protobuf:"bytes,2,opt,name=desired,proto3" json:"desired,omitempty"`
	DesiredLbs          []*LBcluster `protobuf:"bytes,3,rep,name=desiredLbs,proto3" json:"desiredLbs,omitempty"`
	DeletedLbs          []*LBcluster `protobuf:"bytes,4,rep,name=deletedLbs,proto3" json:"deletedLbs,omitempty"`
	// contains filtered or unexported fields
}

func (*TeardownLBResponse) Descriptor deprecated 

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

Deprecated: Use TeardownLBResponse.ProtoReflect.Descriptor instead.

func (*TeardownLBResponse) GetDeletedLbs 

func (x *TeardownLBResponse) GetDeletedLbs() []*LBcluster

func (*TeardownLBResponse) GetDesired 

func (x *TeardownLBResponse) GetDesired() *K8Scluster

func (*TeardownLBResponse) GetDesiredLbs 

func (x *TeardownLBResponse) GetDesiredLbs() []*LBcluster

func (*TeardownLBResponse) GetPreviousAPIEndpoint 

func (x *TeardownLBResponse) GetPreviousAPIEndpoint() string

func (*TeardownLBResponse) ProtoMessage 

func (*TeardownLBResponse) ProtoMessage()

func (*TeardownLBResponse) ProtoReflect 

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

func (*TeardownLBResponse) Reset 

func (x *TeardownLBResponse) Reset()

func (*TeardownLBResponse) String 

func (x *TeardownLBResponse) String() string

type TerraformerServiceClient 

type TerraformerServiceClient interface {
	// BuildInfrastructure builds the infrastructure based on the provided desired state (includes addition/deletion of *stuff*).
	BuildInfrastructure(ctx context.Context, in *BuildInfrastructureRequest, opts ...grpc.CallOption) (*BuildInfrastructureResponse, error)
	// DestroyInfrastructure destroys the infrastructure completely.
	DestroyInfrastructure(ctx context.Context, in *DestroyInfrastructureRequest, opts ...grpc.CallOption) (*DestroyInfrastructureResponse, error)
}

TerraformerServiceClient is the client API for TerraformerService 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 NewTerraformerServiceClient 

func NewTerraformerServiceClient(cc grpc.ClientConnInterface) TerraformerServiceClient

type TerraformerServiceServer 

type TerraformerServiceServer interface {
	// BuildInfrastructure builds the infrastructure based on the provided desired state (includes addition/deletion of *stuff*).
	BuildInfrastructure(context.Context, *BuildInfrastructureRequest) (*BuildInfrastructureResponse, error)
	// DestroyInfrastructure destroys the infrastructure completely.
	DestroyInfrastructure(context.Context, *DestroyInfrastructureRequest) (*DestroyInfrastructureResponse, error)
	// contains filtered or unexported methods
}

TerraformerServiceServer is the server API for TerraformerService service. All implementations must embed UnimplementedTerraformerServiceServer for forward compatibility

type UnimplementedAnsiblerServiceServer 

type UnimplementedAnsiblerServiceServer struct {
}

UnimplementedAnsiblerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAnsiblerServiceServer) InstallNodeRequirements 

func (UnimplementedAnsiblerServiceServer) InstallNodeRequirements(context.Context, *InstallRequest) (*InstallResponse, error)

func (UnimplementedAnsiblerServiceServer) InstallVPN 

func (UnimplementedAnsiblerServiceServer) InstallVPN(context.Context, *InstallRequest) (*InstallResponse, error)

func (UnimplementedAnsiblerServiceServer) RemoveClaudieUtilities added in v0.6.2 

func (UnimplementedAnsiblerServiceServer) RemoveClaudieUtilities(context.Context, *RemoveClaudieUtilitiesRequest) (*RemoveClaudieUtilitiesResponse, error)

func (UnimplementedAnsiblerServiceServer) SetUpLoadbalancers 

func (UnimplementedAnsiblerServiceServer) SetUpLoadbalancers(context.Context, *SetUpLBRequest) (*SetUpLBResponse, error)

func (UnimplementedAnsiblerServiceServer) TeardownLoadBalancers 

func (UnimplementedAnsiblerServiceServer) TeardownLoadBalancers(context.Context, *TeardownLBRequest) (*TeardownLBResponse, error)

func (UnimplementedAnsiblerServiceServer) UpdateAPIEndpoint added in v0.3.1 

func (UnimplementedAnsiblerServiceServer) UpdateAPIEndpoint(context.Context, *UpdateAPIEndpointRequest) (*UpdateAPIEndpointResponse, error)

type UnimplementedContextBoxServiceServer 

type UnimplementedContextBoxServiceServer struct {
}

UnimplementedContextBoxServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedContextBoxServiceServer) DeleteConfig 

func (UnimplementedContextBoxServiceServer) DeleteConfig(context.Context, *DeleteConfigRequest) (*DeleteConfigResponse, error)

func (UnimplementedContextBoxServiceServer) DeleteConfigFromDB 

func (UnimplementedContextBoxServiceServer) DeleteConfigFromDB(context.Context, *DeleteConfigRequest) (*DeleteConfigResponse, error)

func (UnimplementedContextBoxServiceServer) GetAllConfigs 

func (UnimplementedContextBoxServiceServer) GetAllConfigs(context.Context, *GetAllConfigsRequest) (*GetAllConfigsResponse, error)

func (UnimplementedContextBoxServiceServer) GetConfigBuilder 

func (UnimplementedContextBoxServiceServer) GetConfigBuilder(context.Context, *GetConfigRequest) (*GetConfigResponse, error)

func (UnimplementedContextBoxServiceServer) GetConfigFromDB 

func (UnimplementedContextBoxServiceServer) GetConfigFromDB(context.Context, *GetConfigFromDBRequest) (*GetConfigFromDBResponse, error)

func (UnimplementedContextBoxServiceServer) GetConfigScheduler 

func (UnimplementedContextBoxServiceServer) GetConfigScheduler(context.Context, *GetConfigRequest) (*GetConfigResponse, error)

func (UnimplementedContextBoxServiceServer) SaveConfigBuilder 

func (UnimplementedContextBoxServiceServer) SaveConfigBuilder(context.Context, *SaveConfigRequest) (*SaveConfigResponse, error)

func (UnimplementedContextBoxServiceServer) SaveConfigOperator added in v0.4.1 

func (UnimplementedContextBoxServiceServer) SaveConfigOperator(context.Context, *SaveConfigRequest) (*SaveConfigResponse, error)

func (UnimplementedContextBoxServiceServer) SaveConfigScheduler 

func (UnimplementedContextBoxServiceServer) SaveConfigScheduler(context.Context, *SaveConfigRequest) (*SaveConfigResponse, error)

func (UnimplementedContextBoxServiceServer) SaveWorkflowState added in v0.2.2 

func (UnimplementedContextBoxServiceServer) SaveWorkflowState(context.Context, *SaveWorkflowStateRequest) (*SaveWorkflowStateResponse, error)

func (UnimplementedContextBoxServiceServer) UpdateNodepool added in v0.2.2 

func (UnimplementedContextBoxServiceServer) UpdateNodepool(context.Context, *UpdateNodepoolRequest) (*UpdateNodepoolResponse, error)

type UnimplementedKubeElevenServiceServer 

type UnimplementedKubeElevenServiceServer struct {
}

UnimplementedKubeElevenServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedKubeElevenServiceServer) BuildCluster 

func (UnimplementedKubeElevenServiceServer) BuildCluster(context.Context, *BuildClusterRequest) (*BuildClusterResponse, error)

func (UnimplementedKubeElevenServiceServer) DestroyCluster added in v0.6.2 

func (UnimplementedKubeElevenServiceServer) DestroyCluster(context.Context, *DestroyClusterRequest) (*DestroyClusterResponse, error)

type UnimplementedKuberServiceServer 

type UnimplementedKuberServiceServer struct {
}

UnimplementedKuberServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedKuberServiceServer) CiliumRolloutRestart added in v0.5.0 

func (UnimplementedKuberServiceServer) CiliumRolloutRestart(context.Context, *CiliumRolloutRestartRequest) (*CiliumRolloutRestartResponse, error)

func (UnimplementedKuberServiceServer) DeleteClusterMetadata 

func (UnimplementedKuberServiceServer) DeleteClusterMetadata(context.Context, *DeleteClusterMetadataRequest) (*DeleteClusterMetadataResponse, error)

func (UnimplementedKuberServiceServer) DeleteKubeconfig 

func (UnimplementedKuberServiceServer) DeleteKubeconfig(context.Context, *DeleteKubeconfigRequest) (*DeleteKubeconfigResponse, error)

func (UnimplementedKuberServiceServer) DeleteNodes 

func (UnimplementedKuberServiceServer) DeleteNodes(context.Context, *DeleteNodesRequest) (*DeleteNodesResponse, error)

func (UnimplementedKuberServiceServer) DestroyClusterAutoscaler added in v0.2.2 

func (UnimplementedKuberServiceServer) DestroyClusterAutoscaler(context.Context, *DestroyClusterAutoscalerRequest) (*DestroyClusterAutoscalerResponse, error)

func (UnimplementedKuberServiceServer) PatchClusterInfoConfigMap added in v0.3.1 

func (UnimplementedKuberServiceServer) PatchClusterInfoConfigMap(context.Context, *PatchClusterInfoConfigMapRequest) (*PatchClusterInfoConfigMapResponse, error)

func (UnimplementedKuberServiceServer) PatchNodes added in v0.2.2 

func (UnimplementedKuberServiceServer) PatchNodes(context.Context, *PatchNodesRequest) (*PatchNodesResponse, error)

func (UnimplementedKuberServiceServer) RemoveLBScrapeConfig added in v0.4.2 

func (UnimplementedKuberServiceServer) RemoveLBScrapeConfig(context.Context, *RemoveLBScrapeConfigRequest) (*RemoveLBScrapeConfigResponse, error)

func (UnimplementedKuberServiceServer) SetUpClusterAutoscaler added in v0.2.2 

func (UnimplementedKuberServiceServer) SetUpClusterAutoscaler(context.Context, *SetUpClusterAutoscalerRequest) (*SetUpClusterAutoscalerResponse, error)

func (UnimplementedKuberServiceServer) SetUpStorage 

func (UnimplementedKuberServiceServer) SetUpStorage(context.Context, *SetUpStorageRequest) (*SetUpStorageResponse, error)

func (UnimplementedKuberServiceServer) StoreClusterMetadata 

func (UnimplementedKuberServiceServer) StoreClusterMetadata(context.Context, *StoreClusterMetadataRequest) (*StoreClusterMetadataResponse, error)

func (UnimplementedKuberServiceServer) StoreKubeconfig 

func (UnimplementedKuberServiceServer) StoreKubeconfig(context.Context, *StoreKubeconfigRequest) (*StoreKubeconfigResponse, error)

func (UnimplementedKuberServiceServer) StoreLBScrapeConfig added in v0.4.2 

func (UnimplementedKuberServiceServer) StoreLBScrapeConfig(context.Context, *StoreLBScrapeConfigRequest) (*StoreLBScrapeConfigResponse, error)

type UnimplementedOperatorServiceServer added in v0.4.1 

type UnimplementedOperatorServiceServer struct {
}

UnimplementedOperatorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOperatorServiceServer) SendAutoscalerEvent added in v0.4.1 

func (UnimplementedOperatorServiceServer) SendAutoscalerEvent(context.Context, *SendAutoscalerEventRequest) (*SendAutoscalerEventResponse, error)

type UnimplementedTerraformerServiceServer 

type UnimplementedTerraformerServiceServer struct {
}

UnimplementedTerraformerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTerraformerServiceServer) BuildInfrastructure 

func (UnimplementedTerraformerServiceServer) BuildInfrastructure(context.Context, *BuildInfrastructureRequest) (*BuildInfrastructureResponse, error)

func (UnimplementedTerraformerServiceServer) DestroyInfrastructure 

func (UnimplementedTerraformerServiceServer) DestroyInfrastructure(context.Context, *DestroyInfrastructureRequest) (*DestroyInfrastructureResponse, error)

type UnsafeAnsiblerServiceServer 

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

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

type UnsafeContextBoxServiceServer 

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

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

type UnsafeKubeElevenServiceServer 

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

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

type UnsafeKuberServiceServer 

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

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

type UnsafeOperatorServiceServer added in v0.4.1 

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

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

type UnsafeTerraformerServiceServer 

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

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

type UpdateAPIEndpointRequest added in v0.3.1 

type UpdateAPIEndpointRequest struct {
	Current     *K8Scluster `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	Desired     *K8Scluster `protobuf:"bytes,2,opt,name=desired,proto3" json:"desired,omitempty"`
	ProjectName string      `protobuf:"bytes,3,opt,name=projectName,proto3" json:"projectName,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAPIEndpointRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use UpdateAPIEndpointRequest.ProtoReflect.Descriptor instead.

func (*UpdateAPIEndpointRequest) GetCurrent added in v0.3.1 

func (x *UpdateAPIEndpointRequest) GetCurrent() *K8Scluster

func (*UpdateAPIEndpointRequest) GetDesired added in v0.3.1 

func (x *UpdateAPIEndpointRequest) GetDesired() *K8Scluster

func (*UpdateAPIEndpointRequest) GetProjectName added in v0.3.1 

func (x *UpdateAPIEndpointRequest) GetProjectName() string

func (*UpdateAPIEndpointRequest) ProtoMessage added in v0.3.1 

func (*UpdateAPIEndpointRequest) ProtoMessage()

func (*UpdateAPIEndpointRequest) ProtoReflect added in v0.3.1 

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

func (*UpdateAPIEndpointRequest) Reset added in v0.3.1 

func (x *UpdateAPIEndpointRequest) Reset()

func (*UpdateAPIEndpointRequest) String added in v0.3.1 

func (x *UpdateAPIEndpointRequest) String() string

type UpdateAPIEndpointResponse added in v0.3.1 

type UpdateAPIEndpointResponse struct {
	Current *K8Scluster `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	Desired *K8Scluster `protobuf:"bytes,2,opt,name=desired,proto3" json:"desired,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAPIEndpointResponse) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use UpdateAPIEndpointResponse.ProtoReflect.Descriptor instead.

func (*UpdateAPIEndpointResponse) GetCurrent added in v0.3.1 

func (x *UpdateAPIEndpointResponse) GetCurrent() *K8Scluster

func (*UpdateAPIEndpointResponse) GetDesired added in v0.3.1 

func (x *UpdateAPIEndpointResponse) GetDesired() *K8Scluster

func (*UpdateAPIEndpointResponse) ProtoMessage added in v0.3.1 

func (*UpdateAPIEndpointResponse) ProtoMessage()

func (*UpdateAPIEndpointResponse) ProtoReflect added in v0.3.1 

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

func (*UpdateAPIEndpointResponse) Reset added in v0.3.1 

func (x *UpdateAPIEndpointResponse) Reset()

func (*UpdateAPIEndpointResponse) String added in v0.3.1 

func (x *UpdateAPIEndpointResponse) String() string

type UpdateNodepoolRequest added in v0.2.2 

type UpdateNodepoolRequest struct {
	ProjectName string    `protobuf:"bytes,1,opt,name=projectName,proto3" json:"projectName,omitempty"`
	ClusterName string    `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Nodepool    *NodePool `protobuf:"bytes,3,opt,name=nodepool,proto3" json:"nodepool,omitempty"`
	// contains filtered or unexported fields
}

Update

func (*UpdateNodepoolRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use UpdateNodepoolRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodepoolRequest) GetClusterName added in v0.2.2 

func (x *UpdateNodepoolRequest) GetClusterName() string

func (*UpdateNodepoolRequest) GetNodepool added in v0.2.2 

func (x *UpdateNodepoolRequest) GetNodepool() *NodePool

func (*UpdateNodepoolRequest) GetProjectName added in v0.2.2 

func (x *UpdateNodepoolRequest) GetProjectName() string

func (*UpdateNodepoolRequest) ProtoMessage added in v0.2.2 

func (*UpdateNodepoolRequest) ProtoMessage()

func (*UpdateNodepoolRequest) ProtoReflect added in v0.2.2 

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

func (*UpdateNodepoolRequest) Reset added in v0.2.2 

func (x *UpdateNodepoolRequest) Reset()

func (*UpdateNodepoolRequest) String added in v0.2.2 

func (x *UpdateNodepoolRequest) String() string

type UpdateNodepoolResponse added in v0.2.2 

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

func (*UpdateNodepoolResponse) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use UpdateNodepoolResponse.ProtoReflect.Descriptor instead.

func (*UpdateNodepoolResponse) ProtoMessage added in v0.2.2 

func (*UpdateNodepoolResponse) ProtoMessage()

func (*UpdateNodepoolResponse) ProtoReflect added in v0.2.2 

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

func (*UpdateNodepoolResponse) Reset added in v0.2.2 

func (x *UpdateNodepoolResponse) Reset()

func (*UpdateNodepoolResponse) String added in v0.2.2 

func (x *UpdateNodepoolResponse) String() string

type Workflow added in v0.2.2 

type Workflow struct {
	Stage  Workflow_Stage  `protobuf:"varint,1,opt,name=stage,proto3,enum=claudie.Workflow_Stage" json:"stage,omitempty"`
	Status Workflow_Status `protobuf:"varint,2,opt,name=status,proto3,enum=claudie.Workflow_Status" json:"status,omitempty"`
	// additional information describing the state and status.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetDescription added in v0.2.2 

func (x *Workflow) GetDescription() string

func (*Workflow) GetStage added in v0.2.2 

func (x *Workflow) GetStage() Workflow_Stage

func (*Workflow) GetStatus added in v0.2.2 

func (x *Workflow) GetStatus() Workflow_Status

func (*Workflow) ProtoMessage added in v0.2.2 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect added in v0.2.2 

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

func (*Workflow) Reset added in v0.2.2 

func (x *Workflow) Reset()

func (*Workflow) String added in v0.2.2 

func (x *Workflow) String() string

type Workflow_Stage added in v0.2.2 

type Workflow_Stage int32
const (
	// NONE indicates that no stage is currently executing.
	Workflow_NONE Workflow_Stage = 0
	// TERRAFORMER indicates that the cluster is currently being build in terraformer.
	Workflow_TERRAFORMER Workflow_Stage = 1
	// ANSIBLER indicates that the cluster is currently being build in ansibler.
	Workflow_ANSIBLER Workflow_Stage = 2
	// KUBE_ELEVEN indicates that the cluster is currently being build in kube eleven.
	Workflow_KUBE_ELEVEN Workflow_Stage = 3
	// KUBER indicates that the cluster is currently being build in kuber.
	Workflow_KUBER Workflow_Stage = 4
	// SCHEDULER indicates that the config is being processed by the scheduler.
	Workflow_SCHEDULER Workflow_Stage = 5
	// DESTROY_TERRAFORMER indicates that infra for a cluster is being deleted.
	Workflow_DESTROY_TERRAFORMER Workflow_Stage = 7
	// DESTROY_KUBER indicates that data for a cluster is being deleted.
	Workflow_DESTROY_KUBER Workflow_Stage = 8
	// DELETE_NODES indicates the nodes are being deleted for the cluster.
	Workflow_DELETE_NODES Workflow_Stage = 9
)

func (Workflow_Stage) Descriptor added in v0.2.2 

func (Workflow_Stage) Descriptor() protoreflect.EnumDescriptor

func (Workflow_Stage) Enum added in v0.2.2 

func (x Workflow_Stage) Enum() *Workflow_Stage

func (Workflow_Stage) EnumDescriptor deprecated added in v0.2.2 

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

Deprecated: Use Workflow_Stage.Descriptor instead.

func (Workflow_Stage) Number added in v0.2.2 

func (x Workflow_Stage) Number() protoreflect.EnumNumber

func (Workflow_Stage) String added in v0.2.2 

func (x Workflow_Stage) String() string

func (Workflow_Stage) Type added in v0.2.2 

func (Workflow_Stage) Type() protoreflect.EnumType

type Workflow_Status added in v0.2.2 

type Workflow_Status int32
const (
	// DONE indicates that the workflow has finished.
	Workflow_DONE Workflow_Status = 0
	// ERROR indicates that an error occurred while building the cluster.
	Workflow_ERROR Workflow_Status = 1
	// IN_PROGRESS indicates that the cluster is currently being build.
	Workflow_IN_PROGRESS Workflow_Status = 2
)

func (Workflow_Status) Descriptor added in v0.2.2 

func (Workflow_Status) Descriptor() protoreflect.EnumDescriptor

func (Workflow_Status) Enum added in v0.2.2 

func (x Workflow_Status) Enum() *Workflow_Status

func (Workflow_Status) EnumDescriptor deprecated added in v0.2.2 

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

Deprecated: Use Workflow_Status.Descriptor instead.

func (Workflow_Status) Number added in v0.2.2 

func (x Workflow_Status) Number() protoreflect.EnumNumber

func (Workflow_Status) String added in v0.2.2 

func (x Workflow_Status) String() string

func (Workflow_Status) Type added in v0.2.2 

func (Workflow_Status) Type() protoreflect.EnumType

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.