Documentation
¶
Index ¶
- Constants
- Variables
- func Int8ArrToByteArr(data []uint8) []byte
- func Resource(resource string) schema.GroupResource
- type ClusterEndpoint
- type ClusterEndpointList
- type ClusterEndpointSpec
- type ClusterEndpointStatus
- type Condition
- type ConditionType
- type GRPCAction
- type HTTPGetAction
- type Handler
- type Phase
- type ServicePort
- type TCPSocketAction
- type UDPSocketAction
Constants ¶
const GroupName = "sealos.io"
GroupName specifies the group name used to register the objects.
Variables ¶
var ( // localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes. SchemeBuilder runtime.SchemeBuilder // Depreciated: use Install instead AddToScheme = localSchemeBuilder.AddToScheme Install = localSchemeBuilder.AddToScheme )
var GroupVersion = v1.GroupVersion{Group: GroupName, Version: "v1beta1"}
GroupVersion specifies the group and the version used to register the objects.
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1beta1"}
SchemeGroupVersion is group version used to register these objects Deprecated: use GroupVersion instead.
Functions ¶
func Int8ArrToByteArr ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type ClusterEndpoint ¶
type ClusterEndpoint struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Spec ClusterEndpointSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
Status ClusterEndpointStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
ClusterEndpoint is the Schema for the tests API
func (*ClusterEndpoint) DeepCopy ¶
func (in *ClusterEndpoint) DeepCopy() *ClusterEndpoint
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEndpoint.
func (*ClusterEndpoint) DeepCopyInto ¶
func (in *ClusterEndpoint) DeepCopyInto(out *ClusterEndpoint)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterEndpoint) DeepCopyObject ¶
func (in *ClusterEndpoint) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ClusterEndpointList ¶
type ClusterEndpointList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
Items []ClusterEndpoint `json:"items" protobuf:"bytes,2,opt,name=items"`
}
ClusterEndpointList contains a list of ClusterEndpoint
func (*ClusterEndpointList) DeepCopy ¶
func (in *ClusterEndpointList) DeepCopy() *ClusterEndpointList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEndpointList.
func (*ClusterEndpointList) DeepCopyInto ¶
func (in *ClusterEndpointList) DeepCopyInto(out *ClusterEndpointList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterEndpointList) DeepCopyObject ¶
func (in *ClusterEndpointList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ClusterEndpointSpec ¶
type ClusterEndpointSpec struct {
ClusterIP string `json:"clusterIP,omitempty" protobuf:"bytes,1,opt,name=clusterIP"`
Ports []ServicePort `json:"ports,omitempty" patchStrategy:"merge" patchMergeKey:"port" protobuf:"bytes,2,rep,name=ports"`
// How often (in seconds) to perform the probe.
// Default to 10 seconds. Minimum value is 1.
// +optional
PeriodSeconds int32 `json:"periodSeconds,omitempty" protobuf:"varint,4,opt,name=periodSeconds"`
}
ClusterEndpointSpec defines the desired state of ClusterEndpoint
func (*ClusterEndpointSpec) DeepCopy ¶
func (in *ClusterEndpointSpec) DeepCopy() *ClusterEndpointSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEndpointSpec.
func (*ClusterEndpointSpec) DeepCopyInto ¶
func (in *ClusterEndpointSpec) DeepCopyInto(out *ClusterEndpointSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterEndpointStatus ¶
type ClusterEndpointStatus struct {
// Phase is the recently observed lifecycle phase of the cluster endpoints.
Phase Phase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=Phase"`
// Conditions contains the different condition statuses for this workspace.
Conditions []Condition `json:"conditions" protobuf:"bytes,3,rep,name=conditions"`
}
ClusterEndpointStatus defines the observed state of ClusterEndpoint
func (*ClusterEndpointStatus) DeepCopy ¶
func (in *ClusterEndpointStatus) DeepCopy() *ClusterEndpointStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEndpointStatus.
func (*ClusterEndpointStatus) DeepCopyInto ¶
func (in *ClusterEndpointStatus) DeepCopyInto(out *ClusterEndpointStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Condition ¶
type Condition struct {
Type ConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=ConditionType"`
// Status is the status of the condition. One of True, False, Unknown.
Status v1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=ConditionStatus"`
// LastHeartbeatTime is the last time this condition was updated.
// +optional
LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty" protobuf:"bytes,3,opt,name=lastHeartbeatTime"`
// LastTransitionTime is the last time the condition changed from one status to another.
// +optional
LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,4,opt,name=lastTransitionTime"`
// Reason is a (brief) reason for the condition's last status change.
// +optional
Reason string `json:"reason,omitempty" protobuf:"bytes,5,opt,name=reason"`
// Message is a human-readable message indicating details about the last status change.
// +optional
Message string `json:"message,omitempty" protobuf:"bytes,6,opt,name=message"`
}
func (*Condition) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.
func (*Condition) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionType ¶
type ConditionType string
const ( SyncServiceReady ConditionType = "SyncServiceReady" SyncEndpointReady ConditionType = "SyncEndpointReady" Initialized ConditionType = "Initialized" Ready ConditionType = "Ready" )
type GRPCAction ¶
type GRPCAction struct {
Enable bool `json:"enable" protobuf:"bytes,1,opt,name=enable"`
// Service is the name of the service to place in the gRPC HealthCheckRequest
// (see https://github.com/grpc/grpc/blob/master/doc/health-checking.md).
//
// If this is not specified, the default behavior is defined by gRPC.
// +optional
// +default=""
Service *string `json:"service" protobuf:"bytes,2,opt,name=service"`
}
func (*GRPCAction) DeepCopy ¶
func (in *GRPCAction) DeepCopy() *GRPCAction
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GRPCAction.
func (*GRPCAction) DeepCopyInto ¶
func (in *GRPCAction) DeepCopyInto(out *GRPCAction)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HTTPGetAction ¶
type HTTPGetAction struct {
// Path to access on the HTTP server.
// +optional
Path string `json:"path,omitempty" protobuf:"bytes,1,opt,name=path"`
// Scheme to use for connecting to the host.
// Defaults to HTTP.
// +optional
Scheme v1.URIScheme `json:"scheme,omitempty" protobuf:"bytes,4,opt,name=scheme,casttype=URIScheme"`
// Custom headers to set in the request. HTTP allows repeated headers.
// +optional
HTTPHeaders []v1.HTTPHeader `json:"httpHeaders,omitempty" protobuf:"bytes,5,rep,name=httpHeaders"`
}
HTTPGetAction describes an action based on HTTP Get requests.
func (*HTTPGetAction) DeepCopy ¶
func (in *HTTPGetAction) DeepCopy() *HTTPGetAction
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPGetAction.
func (*HTTPGetAction) DeepCopyInto ¶
func (in *HTTPGetAction) DeepCopyInto(out *HTTPGetAction)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Handler ¶
type Handler struct {
// HTTPGet specifies the http request to perform.
// +optional
HTTPGet *HTTPGetAction `json:"httpGet,omitempty" protobuf:"bytes,2,opt,name=httpGet"`
// TCPSocket specifies an action involving a TCP port.
// TCP hooks not yet supported
// +optional
TCPSocket *TCPSocketAction `json:"tcpSocket,omitempty" protobuf:"bytes,3,opt,name=tcpSocket"`
// UDPSocketAction specifies an action involving a UDP port.
// UDP hooks not yet supported
// +optional
UDPSocket *UDPSocketAction `json:"udpSocket,omitempty" protobuf:"bytes,4,opt,name=udpSocket"`
// GRPC specifies an action involving a GRPC port.
// This is an alpha field and requires enabling GRPCContainerProbe feature gate.
// +optional
GRPC *GRPCAction `json:"grpc,omitempty" protobuf:"bytes,5,opt,name=grpc"`
}
Handler defines a specific action that should be taken
func (*Handler) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Handler.
func (*Handler) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServicePort ¶
type ServicePort struct {
Hosts []string `json:"hosts,omitempty" patchStrategy:"merge" patchMergeKey:"host" protobuf:"bytes,3,rep,name=hosts"`
// The action taken to determine the health of a container
Handler `json:",inline" protobuf:"bytes,1,opt,name=handler"`
// Number of seconds after which the probe times out.
// Defaults to 1 second. Minimum value is 1.
// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes
// +optional
TimeoutSeconds int32 `json:"timeoutSeconds,omitempty" protobuf:"varint,3,opt,name=timeoutSeconds"`
// Minimum consecutive successes for the probe to be considered successful after having failed.
// Defaults to 1. Must be 1 for liveness and startup. Minimum value is 1.
// +optional
SuccessThreshold int32 `json:"successThreshold,omitempty" protobuf:"varint,4,opt,name=successThreshold"`
// Minimum consecutive failures for the probe to be considered failed after having succeeded.
// Defaults to 3. Minimum value is 1.
// +optional
FailureThreshold int32 `json:"failureThreshold,omitempty" protobuf:"varint,5,opt,name=failureThreshold"`
// The name of this port within the service. This must be a DNS_LABEL.
// All ports within a ServiceSpec must have unique names. When considering
// the endpoints for a Service, this must match the 'name' field in the
// EndpointPort.
// Optional if only one ServicePort is defined on this service.
// +optional
Name string `json:"name,omitempty" protobuf:"bytes,6,opt,name=name"`
// The IP protocol for this port. Supports "TCP", "UDP", and "SCTP".
// Default is TCP.
// +optional
Protocol v1.Protocol `json:"protocol,omitempty" protobuf:"bytes,7,opt,name=protocol,casttype=Protocol"`
// The port that will be exposed by this service.
Port int32 `json:"port" protobuf:"varint,8,opt,name=port"`
// Number or name of the port to access on the pods targeted by the service.
// Number must be in the range 1 to 65535. Name must be an IANA_SVC_NAME.
// If this is a string, it will be looked up as a named port in the
// target Pod's container ports. If this is not specified, the value
// of the 'port' field is used (an identity map).
TargetPort int32 `json:"targetPort" protobuf:"varint,10,opt,name=targetPort"`
}
ServicePort contains information on service's port.
func (*ServicePort) DeepCopy ¶
func (in *ServicePort) DeepCopy() *ServicePort
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServicePort.
func (*ServicePort) DeepCopyInto ¶
func (in *ServicePort) DeepCopyInto(out *ServicePort)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServicePort) ToEndpointSubset ¶
func (sp *ServicePort) ToEndpointSubset(host string) v1.EndpointSubset
type TCPSocketAction ¶
type TCPSocketAction struct {
Enable bool `json:"enable" protobuf:"bytes,1,opt,name=enable"`
}
TCPSocketAction describes an action based on opening a socket
func (*TCPSocketAction) DeepCopy ¶
func (in *TCPSocketAction) DeepCopy() *TCPSocketAction
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TCPSocketAction.
func (*TCPSocketAction) DeepCopyInto ¶
func (in *TCPSocketAction) DeepCopyInto(out *TCPSocketAction)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UDPSocketAction ¶
type UDPSocketAction struct {
Enable bool `json:"enable" protobuf:"bytes,1,opt,name=enable"`
// UDP test data
// +optional
Data []uint8 `json:"data,omitempty" protobuf:"varint,2,rep,name=data"`
}
UDPSocketAction describes an action based on opening a socket
func (*UDPSocketAction) DeepCopy ¶
func (in *UDPSocketAction) DeepCopy() *UDPSocketAction
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UDPSocketAction.
func (*UDPSocketAction) DeepCopyInto ¶
func (in *UDPSocketAction) DeepCopyInto(out *UDPSocketAction)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.