server

Apr 21, 2023

Changes in this version

+ const DefaultEdgeAgentImage

+ func CreateOrUpdateWithStatus(ctx context.Context, cli client.Client, obj T, fun func(obj T) error) error

+ func RenderManifets(uid string, image string, edgehubaddress string, certs v1beta1.Certs) []client.Object

+ 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, opts request.ListOptions, ...) (response.Page[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 Options struct

+ Database database.Options

+ Host string

+ Listen string

+ ListenGrpc string

+ ServerID string

+ TLS *system.TLS

+ func NewDefaultOptions() *Options

+ type PrecreateOptions struct

+ AgentImage string

+ Annotations map[string]string

+ CertExpireAt *time.Time

+ CreateCert bool

+ HubName string

+ Labels map[string]string

+ UID string

Jan 30, 2023

Changes in this version

+ func Run(ctx context.Context, options *options.ServerOptions) error

+ type EdgeServer struct

+ func NewEdgeServer(ctx context.Context, options *options.ServerOptions) (*EdgeServer, error)

+ func (s *EdgeServer) HTTPAPI() http.Handler

+ func (s *EdgeServer) Run(ctx context.Context) error