livestatestore

Documentation

Overview

Package livestatestore provides a piped component that watches the live state of applications in the cluster to construct it cache data that will be used to provide data to another components quickly.

Index

• type Getter
• type LiveResourceLister
  • func (g LiveResourceLister) ListKubernetesAppLiveResources(cloudProvider, appID string) ([]provider.Manifest, bool)
• type Store
  • func NewStore(ctx context.Context, cfg *config.PipedSpec, appLister applicationLister, ...) Store

Types

type Getter

type Getter interface {
	CloudRunGetter(cloudProvider string) (cloudrun.Getter, bool)
	ECSRunGetter(cloudProvider string) (ecs.Getter, bool)
	KubernetesGetter(cloudProvider string) (kubernetes.Getter, bool)
	LambdaGetter(cloudProvider string) (lambda.Getter, bool)
	TerraformGetter(cloudProvider string) (terraform.Getter, bool)
}

type LiveResourceLister

type LiveResourceLister struct {
	Getter
}

func (LiveResourceLister) ListKubernetesAppLiveResources

func (g LiveResourceLister) ListKubernetesAppLiveResources(cloudProvider, appID string) ([]provider.Manifest, bool)

type Store

type Store interface {
	Run(ctx context.Context) error
	Getter() Getter
}

func NewStore

func NewStore(ctx context.Context, cfg *config.PipedSpec, appLister applicationLister, gracePeriod time.Duration, logger *zap.Logger) Store