container

Documentation

Index

• Constants
• Variables
• type Manager
  • func NewManager(nm *node.Manager, db *db.SQLDB, notify *pubsub.PubSub) *Manager
  • func (m *Manager) AddDeploymentDomain(ctx context.Context, id types.DeploymentID, cert *types.Certificate) error
  • func (m *Manager) AddNewProvider(ctx context.Context, provider *types.Provider) error
  • func (m *Manager) CloseDeployment(ctx context.Context, deployment *types.Deployment, force bool) error
  • func (m *Manager) CreateDeployment(ctx context.Context, deployment *types.Deployment) error
  • func (m *Manager) DeleteDeploymentDomain(ctx context.Context, id types.DeploymentID, domain string) error
  • func (m *Manager) GenerateTokenForLeaseShell(commonAPI api.Common, deploy *types.Deployment) (string, error)
  • func (m *Manager) GetDeploymentDomains(ctx context.Context, id types.DeploymentID) ([]*types.DeploymentDomain, error)
  • func (m *Manager) GetDeploymentList(ctx context.Context, opt *types.GetDeploymentOption) (*types.GetDeploymentListResp, error)
  • func (m *Manager) GetDeploymentProviderIP(ctx context.Context, id types.DeploymentID) (string, error)
  • func (m *Manager) GetEvents(ctx context.Context, deployment *types.Deployment) ([]*types.ServiceEvent, error)
  • func (m *Manager) GetIngress(ctx context.Context, id types.DeploymentID) (*types.Ingress, error)
  • func (m *Manager) GetLeaseShellEndpoint(ctx context.Context, id types.DeploymentID) (*types.LeaseEndpoint, error)
  • func (m *Manager) GetLogs(ctx context.Context, deployment *types.Deployment) ([]*types.ServiceLog, error)
  • func (m *Manager) GetProviderList(ctx context.Context, opt *types.GetProviderOption) ([]*types.Provider, error)
  • func (m *Manager) GetRemoteAddress(ctx context.Context) (string, error)
  • func (m *Manager) GetStatistics(ctx context.Context, id string) (*types.ResourcesStatistics, error)
  • func (m *Manager) ListenNodeState(ctx context.Context)
  • func (m *Manager) SetProperties(ctx context.Context, properties *types.Properties) error
  • func (m *Manager) UpdateDeployment(ctx context.Context, deployment *types.Deployment) error
  • func (m *Manager) UpdateIngress(ctx context.Context, id types.DeploymentID, annotations map[string]string) error

Constants

const (
	StateInvalid = "Invalid"
	StateOk      = "OK"
)

Variables

var (
	ErrOfflineNode          = errors.New("node offline")
	ErrDeploymentNotFound   = errors.New("deployment not found")
	ErrDomainAlreadyExist   = errors.New("domain already exist")
	ErrPermissionNotAllowed = errors.New("permission not allowed")
	ErrInvalidDomain        = errors.New("invalid domain")
	ErrInvalidAnnotations   = errors.New("invalid annotations")
)

Types

type Manager

type Manager struct {
	DB *db.SQLDB
	// contains filtered or unexported fields
}

Manager represents a manager service in a cloud computing system.

func NewManager

func NewManager(nm *node.Manager, db *db.SQLDB, notify *pubsub.PubSub) *Manager

func (*Manager) AddDeploymentDomain

func (m *Manager) AddDeploymentDomain(ctx context.Context, id types.DeploymentID, cert *types.Certificate) error

func (*Manager) AddNewProvider

func (m *Manager) AddNewProvider(ctx context.Context, provider *types.Provider) error

func (*Manager) CloseDeployment

func (m *Manager) CloseDeployment(ctx context.Context, deployment *types.Deployment, force bool) error

func (*Manager) CreateDeployment

func (m *Manager) CreateDeployment(ctx context.Context, deployment *types.Deployment) error

func (*Manager) DeleteDeploymentDomain

func (m *Manager) DeleteDeploymentDomain(ctx context.Context, id types.DeploymentID, domain string) error

func (*Manager) GenerateTokenForLeaseShell

func (m *Manager) GenerateTokenForLeaseShell(commonAPI api.Common, deploy *types.Deployment) (string, error)

func (*Manager) GetDeploymentDomains

func (m *Manager) GetDeploymentDomains(ctx context.Context, id types.DeploymentID) ([]*types.DeploymentDomain, error)

func (*Manager) GetDeploymentList

func (m *Manager) GetDeploymentList(ctx context.Context, opt *types.GetDeploymentOption) (*types.GetDeploymentListResp, error)

func (*Manager) GetDeploymentProviderIP

func (m *Manager) GetDeploymentProviderIP(ctx context.Context, id types.DeploymentID) (string, error)

func (*Manager) GetEvents

func (m *Manager) GetEvents(ctx context.Context, deployment *types.Deployment) ([]*types.ServiceEvent, error)

func (*Manager) GetIngress

func (m *Manager) GetIngress(ctx context.Context, id types.DeploymentID) (*types.Ingress, error)

func (*Manager) GetLeaseShellEndpoint

func (m *Manager) GetLeaseShellEndpoint(ctx context.Context, id types.DeploymentID) (*types.LeaseEndpoint, error)

func (*Manager) GetLogs

func (m *Manager) GetLogs(ctx context.Context, deployment *types.Deployment) ([]*types.ServiceLog, error)

func (*Manager) GetProviderList

func (m *Manager) GetProviderList(ctx context.Context, opt *types.GetProviderOption) ([]*types.Provider, error)

func (*Manager) GetRemoteAddress

func (m *Manager) GetRemoteAddress(ctx context.Context) (string, error)

func (*Manager) GetStatistics

func (m *Manager) GetStatistics(ctx context.Context, id string) (*types.ResourcesStatistics, error)

func (*Manager) ListenNodeState

func (m *Manager) ListenNodeState(ctx context.Context)

func (*Manager) SetProperties

func (m *Manager) SetProperties(ctx context.Context, properties *types.Properties) error

func (*Manager) UpdateDeployment

func (m *Manager) UpdateDeployment(ctx context.Context, deployment *types.Deployment) error

func (*Manager) UpdateIngress

func (m *Manager) UpdateIngress(ctx context.Context, id types.DeploymentID, annotations map[string]string) error