clusterruntime

Documentation

Index

• Constants
• func NewClusterRuntimeApp(conf *conf.Bootstrap, logger log.Logger) biz.AppRuntime
• func NewClusterRuntimeCluster(conf *conf.Bootstrap, logger log.Logger) biz.ClusterRuntime
• func NewClusterRuntimeProject(conf *conf.Bootstrap, logger log.Logger) biz.ProjectRuntime
• func NewClusterRuntimeService(conf *conf.Bootstrap, logger log.Logger) biz.WorkflowRuntime
• func NewClusterRuntimeUser(conf *conf.Bootstrap, logger log.Logger) biz.Thirdparty
• type ClusterRuntimeApp
  • func (c *ClusterRuntimeApp) AddAppRepo(ctx context.Context, appRepo *biz.AppRepo) error
  • func (c *ClusterRuntimeApp) AppRelease(ctx context.Context, app *biz.App, appVersion *biz.AppVersion, ...) error
  • func (c *ClusterRuntimeApp) CheckCluster(ctx context.Context) bool
  • func (c *ClusterRuntimeApp) DeleteApp(ctx context.Context, app *biz.App) error
  • func (c *ClusterRuntimeApp) DeleteAppRelease(ctx context.Context, appRelease *biz.AppRelease) error
  • func (c *ClusterRuntimeApp) DeleteAppVersion(ctx context.Context, app *biz.App, appVersion *biz.AppVersion) error
  • func (c *ClusterRuntimeApp) GetAppAndVersionInfo(ctx context.Context, app *biz.App, appVersion *biz.AppVersion) error
  • func (c *ClusterRuntimeApp) GetAppDetailByRepo(ctx context.Context, apprepo *biz.AppRepo, appName, version string) (*biz.App, error)
  • func (c *ClusterRuntimeApp) GetAppsByRepo(ctx context.Context, appRepo *biz.AppRepo) ([]*biz.App, error)
  • func (c *ClusterRuntimeApp) GetClusterResources(ctx context.Context, appRelease *biz.AppRelease) ([]*biz.AppReleaseResource, error)
  • func (c *ClusterRuntimeApp) Init(ctx context.Context) ([]*biz.App, []*biz.AppRelease, error)
• type ClusterRuntimeCluster
  • func (c *ClusterRuntimeCluster) CurrentCluster(ctx context.Context, cluster *biz.Cluster) error
  • func (c *ClusterRuntimeCluster) HandlerNodes(ctx context.Context, cluster *biz.Cluster) error
  • func (c *ClusterRuntimeCluster) MigrateToCluster(ctx context.Context, cluster *biz.Cluster) error
• type ClusterRuntimeProject
  • func (c *ClusterRuntimeProject) CreateNamespace(ctx context.Context, namespace string) error
  • func (c *ClusterRuntimeProject) GetNamespaces(ctx context.Context) (namespaces []string, err error)
• type ClusterRuntimeService
  • func (s *ClusterRuntimeService) Create(ctx context.Context, namespace string, workflow *biz.Workflow) error
  • func (s *ClusterRuntimeService) GenerateCIWorkflow(ctx context.Context, service *biz.Service) (ciWf *biz.Workflow, cdwf *biz.Workflow, err error)
• type ClusterRuntimeUser
  • func (u *ClusterRuntimeUser) GetUserEmail(ctx context.Context, token string) (string, error)

Constants

const (
	ServiceNameClusterRuntime = "cluster-runtime"
)

Functions

func NewClusterRuntimeApp

func NewClusterRuntimeApp(conf *conf.Bootstrap, logger log.Logger) biz.AppRuntime

func NewClusterRuntimeCluster

func NewClusterRuntimeCluster(conf *conf.Bootstrap, logger log.Logger) biz.ClusterRuntime

func NewClusterRuntimeProject

func NewClusterRuntimeProject(conf *conf.Bootstrap, logger log.Logger) biz.ProjectRuntime

func NewClusterRuntimeService

func NewClusterRuntimeService(conf *conf.Bootstrap, logger log.Logger) biz.WorkflowRuntime

func NewClusterRuntimeUser

func NewClusterRuntimeUser(conf *conf.Bootstrap, logger log.Logger) biz.Thirdparty

Types

type ClusterRuntimeApp

type ClusterRuntimeApp struct {
	// contains filtered or unexported fields
}

func (*ClusterRuntimeApp) AddAppRepo

func (c *ClusterRuntimeApp) AddAppRepo(ctx context.Context, appRepo *biz.AppRepo) error

func (*ClusterRuntimeApp) AppRelease

func (c *ClusterRuntimeApp) AppRelease(ctx context.Context, app *biz.App, appVersion *biz.AppVersion, appRelease *biz.AppRelease, appRepo *biz.AppRepo) error

func (*ClusterRuntimeApp) CheckCluster

func (c *ClusterRuntimeApp) CheckCluster(ctx context.Context) bool

func (*ClusterRuntimeApp) DeleteApp

func (c *ClusterRuntimeApp) DeleteApp(ctx context.Context, app *biz.App) error

func (*ClusterRuntimeApp) DeleteAppRelease

func (c *ClusterRuntimeApp) DeleteAppRelease(ctx context.Context, appRelease *biz.AppRelease) error

func (*ClusterRuntimeApp) DeleteAppVersion

func (c *ClusterRuntimeApp) DeleteAppVersion(ctx context.Context, app *biz.App, appVersion *biz.AppVersion) error

func (*ClusterRuntimeApp) GetAppAndVersionInfo

func (c *ClusterRuntimeApp) GetAppAndVersionInfo(ctx context.Context, app *biz.App, appVersion *biz.AppVersion) error

func (*ClusterRuntimeApp) GetAppDetailByRepo

func (c *ClusterRuntimeApp) GetAppDetailByRepo(ctx context.Context, apprepo *biz.AppRepo, appName, version string) (*biz.App, error)

func (*ClusterRuntimeApp) GetAppsByRepo

func (c *ClusterRuntimeApp) GetAppsByRepo(ctx context.Context, appRepo *biz.AppRepo) ([]*biz.App, error)

func (*ClusterRuntimeApp) GetClusterResources

func (c *ClusterRuntimeApp) GetClusterResources(ctx context.Context, appRelease *biz.AppRelease) ([]*biz.AppReleaseResource, error)

func (*ClusterRuntimeApp) Init

func (c *ClusterRuntimeApp) Init(ctx context.Context) ([]*biz.App, []*biz.AppRelease, error)

type ClusterRuntimeCluster

type ClusterRuntimeCluster struct {
	// contains filtered or unexported fields
}

func (*ClusterRuntimeCluster) CurrentCluster

func (c *ClusterRuntimeCluster) CurrentCluster(ctx context.Context, cluster *biz.Cluster) error

func (*ClusterRuntimeCluster) HandlerNodes

func (c *ClusterRuntimeCluster) HandlerNodes(ctx context.Context, cluster *biz.Cluster) error

func (*ClusterRuntimeCluster) MigrateToCluster

func (c *ClusterRuntimeCluster) MigrateToCluster(ctx context.Context, cluster *biz.Cluster) error

type ClusterRuntimeProject

type ClusterRuntimeProject struct {
	// contains filtered or unexported fields
}

func (*ClusterRuntimeProject) CreateNamespace

func (c *ClusterRuntimeProject) CreateNamespace(ctx context.Context, namespace string) error

func (*ClusterRuntimeProject) GetNamespaces

func (c *ClusterRuntimeProject) GetNamespaces(ctx context.Context) (namespaces []string, err error)

type ClusterRuntimeService

type ClusterRuntimeService struct {
	// contains filtered or unexported fields
}

func (*ClusterRuntimeService) Create

func (s *ClusterRuntimeService) Create(ctx context.Context, namespace string, workflow *biz.Workflow) error

func (*ClusterRuntimeService) GenerateCIWorkflow

func (s *ClusterRuntimeService) GenerateCIWorkflow(ctx context.Context, service *biz.Service) (ciWf *biz.Workflow, cdwf *biz.Workflow, err error)

type ClusterRuntimeUser

type ClusterRuntimeUser struct {
	// contains filtered or unexported fields
}

func (*ClusterRuntimeUser) GetUserEmail

func (u *ClusterRuntimeUser) GetUserEmail(ctx context.Context, token string) (string, error)