controller

Documentation

Index

• func NewControllerMiddleware(kubeStore store.StoreInterface, buildClient build.BuildInterface) middleware.Interface
• type ControllerMiddleware
  • func (c *ControllerMiddleware) AbortRelease(ctx context.Context, blockName, releaseId, envId string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) CheckCertificateReadiness(ctx context.Context, blockName, envId string) bool
  • func (c *ControllerMiddleware) CreateBlock(ctx context.Context, envId, name string, buildConfig *types.BuildConfig, ...) (string, string, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) CreateCustomDomainName(ctx context.Context, blockName, envId, domainName string, ...) *utilsGoServer.Error
  • func (c *ControllerMiddleware) CreateEnvironment(ctx context.Context, name string) (*types.Environment, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) DeleteBlock(ctx context.Context, name, envId string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) DeleteCustomDomainName(ctx context.Context, blockName, envId, domainName string, ...) *utilsGoServer.Error
  • func (c *ControllerMiddleware) DeleteEnvironment(ctx context.Context, id string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) DeployBlockUpdate(ctx context.Context, name, envId, baseReleaseId string, ...) (string, string, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) DisableExternalURL(ctx context.Context, name, envId string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) EnableExternalURL(ctx context.Context, name, envId, releaseId string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) GenReleaseConfigFromKintoFile(ctx context.Context, org, repo, branch, envId, githubUserToken string, ...) (*types.ReleaseConfig, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) GetBlock(ctx context.Context, name, envId string) (*types.Block, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) GetBlocks(ctx context.Context, envId string) (*types.Blocks, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) GetBlocksHealthStatus(ctx context.Context, envId string) (*types.BlockStatuses, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) GetBlocksMetrics(ctx context.Context, name, envId string) (*types.BlocksMetrics, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) GetEnvironment(ctx context.Context, id string) (*types.Environment, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) GetEnvironments(ctx context.Context) (*types.Environments, *utilsGoServer.Error)
  • func (ControllerMiddleware) GetKintoConfiguration(ctx context.Context) (*types.KintoConfiguration, error)
  • func (c *ControllerMiddleware) KillBlockInstance(ctx context.Context, id, envId string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) PromoteRelease(ctx context.Context, tag, releaseId, blockName, envId, targetEnvId string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) RollbackBlock(ctx context.Context, name, envId, releaseId string) (string, string, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) StartTeleport(ctx context.Context, envId, blockNameToTeleport string) (*types.TeleportServiceData, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) StopTeleport(ctx context.Context, envId, blockNameTeleported string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) SuspendBlock(ctx context.Context, name, envId string) (string, string, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) TagRelease(ctx context.Context, tag, blockName, envId, releaseId string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) TriggerDeploy(ctx context.Context, name, envId string) (string, string, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) UpdateBuildCommitSha(ctx context.Context, releaseId, blockName, envId, commitSha string) *utilsGoServer.Error
  • func (c *ControllerMiddleware) UpdateBuildStatus(ctx context.Context, releaseId, blockName, envId string, ...) (*types.Release, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) UpdateEnvironment(ctx context.Context, id, name string) (*types.Environment, *utilsGoServer.Error)
  • func (c *ControllerMiddleware) WatchBuildLogs(ctx context.Context, releaseId, blockName, envId string, ...) *utilsGoServer.Error
  • func (c *ControllerMiddleware) WatchConsoleLogs(ctx context.Context, blockName, envId string, logsChan chan *types.ConsoleLog) *utilsGoServer.Error
  • func (c *ControllerMiddleware) WatchJobsStatus(ctx context.Context, blockName, envId string, ...) *utilsGoServer.Error
  • func (c *ControllerMiddleware) WatchReleasesStatus(ctx context.Context, blockName, envId string, ...) *utilsGoServer.Error

Functions

func NewControllerMiddleware

func NewControllerMiddleware(
	kubeStore store.StoreInterface, buildClient build.BuildInterface) middleware.Interface

Types

type ControllerMiddleware

type ControllerMiddleware struct {
	middleware.Middleware
	// contains filtered or unexported fields
}

func (*ControllerMiddleware) AbortRelease

func (c *ControllerMiddleware) AbortRelease(ctx context.Context, blockName, releaseId, envId string) *utilsGoServer.Error

func (*ControllerMiddleware) CheckCertificateReadiness

func (c *ControllerMiddleware) CheckCertificateReadiness(ctx context.Context, blockName, envId string) bool

func (*ControllerMiddleware) CreateBlock

func (c *ControllerMiddleware) CreateBlock(
	ctx context.Context,
	envId, name string,
	buildConfig *types.BuildConfig,
	runConfig *types.RunConfig) (string, string, *utilsGoServer.Error)

func (*ControllerMiddleware) CreateCustomDomainName

func (c *ControllerMiddleware) CreateCustomDomainName(
	ctx context.Context, blockName, envId, domainName string, protocol types.RunConfig_Protocol) *utilsGoServer.Error

func (*ControllerMiddleware) CreateEnvironment

func (c *ControllerMiddleware) CreateEnvironment(ctx context.Context, name string) (*types.Environment, *utilsGoServer.Error)

func (*ControllerMiddleware) DeleteBlock

func (c *ControllerMiddleware) DeleteBlock(ctx context.Context, name, envId string) *utilsGoServer.Error

func (*ControllerMiddleware) DeleteCustomDomainName

func (c *ControllerMiddleware) DeleteCustomDomainName(
	ctx context.Context, blockName, envId, domainName string, protocol types.RunConfig_Protocol) *utilsGoServer.Error

func (*ControllerMiddleware) DeleteEnvironment

func (c *ControllerMiddleware) DeleteEnvironment(ctx context.Context, id string) *utilsGoServer.Error

func (*ControllerMiddleware) DeployBlockUpdate

func (c *ControllerMiddleware) DeployBlockUpdate(
	ctx context.Context,
	name, envId, baseReleaseId string,
	buildConfig *types.BuildConfig,
	runConfig *types.RunConfig) (string, string, *utilsGoServer.Error)

func (*ControllerMiddleware) DisableExternalURL

func (c *ControllerMiddleware) DisableExternalURL(ctx context.Context, name, envId string) *utilsGoServer.Error

func (*ControllerMiddleware) EnableExternalURL

func (c *ControllerMiddleware) EnableExternalURL(ctx context.Context, name, envId, releaseId string) *utilsGoServer.Error

func (*ControllerMiddleware) GenReleaseConfigFromKintoFile

func (c *ControllerMiddleware) GenReleaseConfigFromKintoFile(
	ctx context.Context, org, repo, branch, envId, githubUserToken string, blockType types.Block_Type) (*types.ReleaseConfig, *utilsGoServer.Error)

func (*ControllerMiddleware) GetBlock

func (c *ControllerMiddleware) GetBlock(ctx context.Context, name, envId string) (*types.Block, *utilsGoServer.Error)

func (*ControllerMiddleware) GetBlocks

func (c *ControllerMiddleware) GetBlocks(ctx context.Context, envId string) (*types.Blocks, *utilsGoServer.Error)

func (*ControllerMiddleware) GetBlocksHealthStatus

func (c *ControllerMiddleware) GetBlocksHealthStatus(ctx context.Context, envId string) (*types.BlockStatuses, *utilsGoServer.Error)

func (*ControllerMiddleware) GetBlocksMetrics

func (c *ControllerMiddleware) GetBlocksMetrics(
	ctx context.Context, name, envId string) (*types.BlocksMetrics, *utilsGoServer.Error)

func (*ControllerMiddleware) GetEnvironment

func (c *ControllerMiddleware) GetEnvironment(ctx context.Context, id string) (*types.Environment, *utilsGoServer.Error)

func (*ControllerMiddleware) GetEnvironments

func (c *ControllerMiddleware) GetEnvironments(ctx context.Context) (*types.Environments, *utilsGoServer.Error)

func (ControllerMiddleware) GetKintoConfiguration

func (ControllerMiddleware) GetKintoConfiguration(ctx context.Context) (*types.KintoConfiguration, error)

func (*ControllerMiddleware) KillBlockInstance

func (c *ControllerMiddleware) KillBlockInstance(ctx context.Context, id, envId string) *utilsGoServer.Error

func (*ControllerMiddleware) PromoteRelease

func (c *ControllerMiddleware) PromoteRelease(
	ctx context.Context, tag, releaseId, blockName, envId, targetEnvId string) *utilsGoServer.Error

func (*ControllerMiddleware) RollbackBlock

func (c *ControllerMiddleware) RollbackBlock(ctx context.Context, name, envId, releaseId string) (string, string, *utilsGoServer.Error)

func (*ControllerMiddleware) StartTeleport

func (c *ControllerMiddleware) StartTeleport(
	ctx context.Context, envId, blockNameToTeleport string) (*types.TeleportServiceData, *utilsGoServer.Error)

func (*ControllerMiddleware) StopTeleport

func (c *ControllerMiddleware) StopTeleport(ctx context.Context, envId, blockNameTeleported string) *utilsGoServer.Error

func (*ControllerMiddleware) SuspendBlock

func (c *ControllerMiddleware) SuspendBlock(ctx context.Context, name, envId string) (string, string, *utilsGoServer.Error)

func (*ControllerMiddleware) TagRelease

func (c *ControllerMiddleware) TagRelease(ctx context.Context, tag, blockName, envId, releaseId string) *utilsGoServer.Error

func (*ControllerMiddleware) TriggerDeploy

func (c *ControllerMiddleware) TriggerDeploy(
	ctx context.Context, name, envId string) (string, string, *utilsGoServer.Error)

func (*ControllerMiddleware) UpdateBuildCommitSha

func (c *ControllerMiddleware) UpdateBuildCommitSha(
	ctx context.Context, releaseId, blockName, envId, commitSha string) *utilsGoServer.Error

func (*ControllerMiddleware) UpdateBuildStatus

func (c *ControllerMiddleware) UpdateBuildStatus(
	ctx context.Context, releaseId, blockName, envId string, buildState types.BuildStatus_State) (*types.Release, *utilsGoServer.Error)

func (*ControllerMiddleware) UpdateEnvironment

func (c *ControllerMiddleware) UpdateEnvironment(ctx context.Context, id, name string) (*types.Environment, *utilsGoServer.Error)

func (*ControllerMiddleware) WatchBuildLogs

func (c *ControllerMiddleware) WatchBuildLogs(
	ctx context.Context, releaseId, blockName, envId string, logsChan chan *types.Logs) *utilsGoServer.Error

func (*ControllerMiddleware) WatchConsoleLogs

func (c *ControllerMiddleware) WatchConsoleLogs(
	ctx context.Context, blockName, envId string, logsChan chan *types.ConsoleLog) *utilsGoServer.Error

func (*ControllerMiddleware) WatchJobsStatus

func (c *ControllerMiddleware) WatchJobsStatus(
	ctx context.Context,
	blockName, envId string,
	sendClientLogs func(jobStatus *types.JobStatus) error) *utilsGoServer.Error

func (*ControllerMiddleware) WatchReleasesStatus

func (c *ControllerMiddleware) WatchReleasesStatus(
	ctx context.Context, blockName, envId string, logsChan chan *types.ReleasesStatus) *utilsGoServer.Error