Versions in this module Expand all Collapse all v1 v1.23.6 Mar 2, 2023 v1.23.5 Feb 24, 2023 v1.23.4 Feb 9, 2023 v1.23.3 Feb 8, 2023 v1.23.2 Feb 7, 2023 v1.23.1 Feb 1, 2023 v1.23.0 Jan 30, 2023 Changes in this version + const AnnotationIsTemporaryConnect + const AnnotationKeyAPIserverAddress + const AnnotationKeyDeviceID + const AnnotationKeyEdgeAgentAddress + const AnnotationKeyEdgeAgentKeepaliveInterval + const AnnotationKeyEdgeAgentRegisterAddress + const AnnotationKeyEdgeHubAddress + const AnnotationKeyEdgeHubCA + const AnnotationKeyEdgeHubCert + const AnnotationKeyEdgeHubKey + const AnnotationKeyKubernetesVersion + const AnnotationKeyNodesCount + const DefaultAgentAddress + const DefaultEdgeAgentImage + const DurationYear + const LabelKeIsyEdgeHub + func CreateOrUpdateWithStatus(ctx context.Context, cli client.Client, obj T, fun func(obj T) error) error + func EncodeToX509Pair(in tls.Certificate) ([]byte, []byte) + func RenderManifets(uid string, image string, edgehubaddress string, certs v1beta1.Certs) []client.Object + func SignCertificate(caPEMBlock, certPEMBlock, keyPEMBlock []byte, options CertOptions) ([]byte, []byte, error) + type CertOptions struct + CommonName string + ExpireAt *time.Time + Hosts []string + type CreateClusterRequest struct + type CreateClusterResponse struct + ManifestAddress string + UID string + type EdgeClusterAPI struct + Cluster *EdgeManager + Tunnel *tunnel.TunnelServer + func (a *EdgeClusterAPI) GetEdgeCluster(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) GetEdgeHub(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) InstallAgentTemplate(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) ListEdgeClusters(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) ListEdgeHubs(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) PreCreateEdgeCluster(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) Proxy(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) RegisterRoute(r *route.Group) + func (a *EdgeClusterAPI) RemoveEdgeCluster(req *restful.Request, resp *restful.Response) + func (a *EdgeClusterAPI) UpdateEdgeCluster(req *restful.Request, resp *restful.Response) + type EdgeClusterK8sStore struct + func (s EdgeClusterK8sStore) Delete(ctx context.Context, name string) (*v1beta1.EdgeCluster, error) + func (s EdgeClusterK8sStore) Get(ctx context.Context, name string) (*v1beta1.EdgeCluster, error) + func (s EdgeClusterK8sStore) List(ctx context.Context, options ListOptions) (int, []v1beta1.EdgeCluster, error) + func (s EdgeClusterK8sStore) Update(ctx context.Context, name string, fun func(cluster *v1beta1.EdgeCluster) error) (*v1beta1.EdgeCluster, error) + type EdgeClusterStore interface + Delete func(ctx context.Context, name string) (*v1beta1.EdgeCluster, error) + Get func(ctx context.Context, name string) (*v1beta1.EdgeCluster, error) + List func(ctx context.Context, options ListOptions) (int, []v1beta1.EdgeCluster, error) + Update func(ctx context.Context, name string, fun func(cluster *v1beta1.EdgeCluster) error) (*v1beta1.EdgeCluster, error) + type EdgeHubItem struct + Address string + Connected bool + Name string + type EdgeHubK8sStore struct + func (s EdgeHubK8sStore) Delete(ctx context.Context, name string) (*v1beta1.EdgeHub, error) + func (s EdgeHubK8sStore) Get(ctx context.Context, name string) (*v1beta1.EdgeHub, error) + func (s EdgeHubK8sStore) List(ctx context.Context, options ListOptions) (int, []v1beta1.EdgeHub, error) + func (s EdgeHubK8sStore) Update(ctx context.Context, name string, fun func(cluster *v1beta1.EdgeHub) error) (*v1beta1.EdgeHub, error) + type EdgeHubStore interface + Delete func(ctx context.Context, name string) (*v1beta1.EdgeHub, error) + Get func(ctx context.Context, name string) (*v1beta1.EdgeHub, error) + List func(ctx context.Context, options ListOptions) (int, []v1beta1.EdgeHub, error) + Update func(ctx context.Context, name string, fun func(cluster *v1beta1.EdgeHub) error) (*v1beta1.EdgeHub, error) + type EdgeManager struct + ClusterStore EdgeClusterStore + HubStore EdgeHubStore + SelfAddress string + func NewClusterManager(ctx context.Context, namespace string, selfhost string) (*EdgeManager, error) + func (m *EdgeManager) ListPage(ctx context.Context, page, size int, search string, ...) (response.TypedPage[v1beta1.EdgeCluster], error) + func (m *EdgeManager) OnTunnelConnectedStatusChange(ctx context.Context, connected bool, isrefresh bool, fromname string, ...) error + func (m *EdgeManager) PreCreate(ctx context.Context, example *v1beta1.EdgeCluster) (*v1beta1.EdgeCluster, error) + func (m *EdgeManager) RenderInstallManifests(ctx context.Context, uid, token string) ([]byte, error) + func (s *EdgeManager) SyncTunnelStatusFrom(ctx context.Context, server *tunnel.TunnelServer) error + type InstallerTemplateValues struct + AgentImage string + EdgeAddress string + TLSCA []byte + TLSCert []byte + TLSKey []byte + type ListOptions struct + Manufacture labels.Selector + Page int + Search string + Selector labels.Selector + Size int + type PrecreateOptions struct + AgentImage string + Annotations map[string]string + CertExpireAt *time.Time + CreateCert bool + HubName string + Labels map[string]string + UID string v1.23.0-rc.1 Jan 30, 2023 v1.23.0-rc.0 Jan 29, 2023 v1.23.0-alpha.3 Jan 11, 2023 v1.23.0-alpha.2 Dec 16, 2022 v1.23.0-alpha.0 Dec 1, 2022