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(platformProvider, 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(platformProvider string) (cloudrun.Getter, bool)
	ECSRunGetter(platformProvider string) (ecs.Getter, bool)
	KubernetesGetter(platformProvider string) (kubernetes.Getter, bool)
	LambdaGetter(platformProvider string) (lambda.Getter, bool)
	TerraformGetter(platformProvider string) (terraform.Getter, bool)
}

type LiveResourceLister

type LiveResourceLister struct {
	Getter
}

func (LiveResourceLister) ListKubernetesAppLiveResources

func (g LiveResourceLister) ListKubernetesAppLiveResources(platformProvider, 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