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.