kubernetes

Documentation

Index

• type AppState
• type EventIterator
  • func (it EventIterator) Next(maxNum int) []model.KubernetesResourceStateEvent
• type Getter
• type Store
  • func NewStore(cfg *config.PlatformProviderKubernetesConfig, pipedConfig *config.PipedSpec, ...) *Store
  • func (s *Store) GetAppLiveManifests(appID string) []provider.Manifest
  • func (s *Store) GetKubernetesAppLiveState(appID string) (AppState, bool)
  • func (s *Store) GetWatchingResourceKinds() []provider.APIVersionKind
  • func (s *Store) NewEventIterator() EventIterator
  • func (s *Store) Run(ctx context.Context) error
  • func (s *Store) WaitForReady(ctx context.Context, timeout time.Duration) error

Types

type AppState

type AppState struct {
	Resources []*model.KubernetesResourceState
	Version   model.ApplicationLiveStateVersion
}

type EventIterator

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

func (EventIterator) Next

func (it EventIterator) Next(maxNum int) []model.KubernetesResourceStateEvent

type Getter

type Getter interface {
	GetKubernetesAppLiveState(appID string) (AppState, bool)
	NewEventIterator() EventIterator

	GetWatchingResourceKinds() []provider.APIVersionKind
	GetAppLiveManifests(appID string) []provider.Manifest

	WaitForReady(ctx context.Context, timeout time.Duration) error
}

type Store

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

func NewStore

func NewStore(cfg *config.PlatformProviderKubernetesConfig, pipedConfig *config.PipedSpec, cloudProvider string, logger *zap.Logger) *Store

func (*Store) GetAppLiveManifests

func (s *Store) GetAppLiveManifests(appID string) []provider.Manifest

func (*Store) GetKubernetesAppLiveState

func (s *Store) GetKubernetesAppLiveState(appID string) (AppState, bool)

func (*Store) GetWatchingResourceKinds

func (s *Store) GetWatchingResourceKinds() []provider.APIVersionKind

func (*Store) NewEventIterator

func (s *Store) NewEventIterator() EventIterator

func (*Store) Run

func (s *Store) Run(ctx context.Context) error

func (*Store) WaitForReady

func (s *Store) WaitForReady(ctx context.Context, timeout time.Duration) error