kube

func (*KubeStore) CheckCertificateReadiness ¶

func (k *KubeStore) CheckCertificateReadiness(blockName, envId string) (bool, *utilsGoServer.Error)

func (*KubeStore) CreateEnvironment ¶

func (k *KubeStore) CreateEnvironment(env *types.Environment) *utilsGoServer.Error

func (*KubeStore) DeleteBlock ¶

func (k *KubeStore) DeleteBlock(name, envId string) *utilsGoServer.Error

func (*KubeStore) DeleteCustomDomainNames ¶

func (k *KubeStore) DeleteCustomDomainNames(envId, blockName, kintoHost string) *utilsGoServer.Error

Delete the resources created for custom domain name - Ingress and Certificate - Don't delete the issuer since it can be used later - Update the proxless annotation on the kubernetes service to only contains the `kintoHost` - `kintoHost` must be empty if the kintohub service is deleted

func (*KubeStore) DeleteEnvironment ¶

func (k *KubeStore) DeleteEnvironment(id string) *utilsGoServer.Error

func (*KubeStore) DisablePublicURL ¶

func (k *KubeStore) DisablePublicURL(envId, blockName string) *utilsGoServer.Error

func (*KubeStore) DoesCustomDomainExistInStore ¶

func (k *KubeStore) DoesCustomDomainExistInStore(host string) (bool, *utilsGoServer.Error)

func (*KubeStore) EnablePublicURL ¶

func (k *KubeStore) EnablePublicURL(
	envId, blockName string, protocol pkgTypes.RunConfig_Protocol, hosts ...string) *utilsGoServer.Error

func (*KubeStore) ExecCommandInContainerWithFullOutput ¶

func (k *KubeStore) ExecCommandInContainerWithFullOutput(
	namespace, podName, containerName string, cmd ...string) (string, string, error)

func (*KubeStore) ExecWithOptions ¶

func (k *KubeStore) ExecWithOptions(options ExecOptions) (string, string, error)

func (*KubeStore) GetBlock ¶

func (k *KubeStore) GetBlock(name, envId string) (*pkgtypes.Block, *utilsGoServer.Error)

func (*KubeStore) GetBlockHeathState ¶

func (k *KubeStore) GetBlockHeathState(
	blockName, envId string, latestSuccessfulRelease *pkgTypes.Release) (pkgTypes.BlockStatus_State, error)

func (*KubeStore) GetBlocks ¶

func (k *KubeStore) GetBlocks(envId string) ([]*pkgtypes.Block, *utilsGoServer.Error)

func (*KubeStore) GetBlocksMetrics ¶

func (k *KubeStore) GetBlocksMetrics(name, envId string) (*types.BlocksMetrics, *utilsGoServer.Error)

Collects resource requests, usage and storage information for all blocks in an environment or if provide optional blockName, the specific metrics of that block only.

func (*KubeStore) GetEnvironment ¶

func (k *KubeStore) GetEnvironment(envId string) (*types.Environment, *utilsGoServer.Error)

func (*KubeStore) GetEnvironments ¶

func (k *KubeStore) GetEnvironments() (*types.Environments, *utilsGoServer.Error)

func (*KubeStore) KillBlockInstance ¶

func (k *KubeStore) KillBlockInstance(id, envId string) *utilsGoServer.Error

func (*KubeStore) StartChiselService ¶

func (k *KubeStore) StartChiselService(
	ctx context.Context, envId, blockNameToTeleport string) (*types.TeleportServiceData, *utilsGoServer.Error)

Start chisel and configure it for `access` (proxy from local to remote) or `teleport` (proxy from remote to local) blockNameToTeleport - if empty, does not `teleport` anything the k8s service `blockNameToTeleport` will be modified to target chisel TODO handle the teleport differently, this is super confusing

func (*KubeStore) StopChiselService ¶

func (k *KubeStore) StopChiselService(envId, blockNameTeleported string) *utilsGoServer.Error

Stop chisel blockNameTeleported - if empty, does not do anything the k8s service `blockNameTeleported` will be modified to target the user app (it was targetting chisel) TODO handle the teleport differently, this is super confusing

func (*KubeStore) UpdateEnvironment ¶

func (k *KubeStore) UpdateEnvironment(env *types.Environment) *utilsGoServer.Error

func (*KubeStore) UpsertBlock ¶

func (k *KubeStore) UpsertBlock(block *pkgtypes.Block) *utilsGoServer.Error

func (*KubeStore) UpsertCustomDomainNames ¶

func (k *KubeStore) UpsertCustomDomainNames(
	envId, blockName string,
	protocol pkgTypes.RunConfig_Protocol,
	kintoHost string, domainNames ...string) *utilsGoServer.Error

func (*KubeStore) WatchBlockReleaseStatus ¶

func (k *KubeStore) WatchBlockReleaseStatus(blockName, envId string, ctx context.Context,
	statusChan chan *types.ReleasesStatus) *utilsGoServer.Error

func (*KubeStore) WatchConsoleLogs ¶

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

Listens to console logs to ALL instances of a specific block name in an environment Even if there are no blocks, new blocks or removed blocks - it will continue to observe and aggregate logs from each pod related to the blockName. This allows the client to listen pre-post deployment and wait for desired messages

func (*KubeStore) WatchJobsStatus ¶

func (k *KubeStore) WatchJobsStatus(
	blockName, envId string,
	ctx context.Context,
	sendClientLogs func(jobStatus *pkgTypes.JobStatus) error) *utilsGoServer.Error