results

package
v2.24.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 10, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FilterProject added in v2.21.0

func FilterProject(x result.ProjectKey, filter *result.ProjectKey) bool

Types

type GetCommandResultOptions

type GetCommandResultOptions struct {
	Id      string `json:"id"`
	Reduced bool   `json:"reduced,omitempty"`
}

type GetValidateResultOptions added in v2.21.0

type GetValidateResultOptions struct {
	Id string `json:"id"`
}

type ListResultSummariesOptions added in v2.21.0

type ListResultSummariesOptions struct {
	ProjectFilter *result.ProjectKey `json:"projectFilter,omitempty"`
}

type ResultStore

type ResultStore interface {
	WriteCommandResult(cr *result.CommandResult) error
	WriteValidateResult(vr *result.ValidateResult) error
	DeleteCommandResult(rsId string) error

	ListCommandResultSummaries(options ListResultSummariesOptions) ([]result.CommandResultSummary, error)
	WatchCommandResultSummaries(options ListResultSummariesOptions) (<-chan WatchCommandResultSummaryEvent, context.CancelFunc, error)
	GetCommandResult(options GetCommandResultOptions) (*result.CommandResult, error)

	ListValidateResultSummaries(options ListResultSummariesOptions) ([]result.ValidateResultSummary, error)
	WatchValidateResultSummaries(options ListResultSummariesOptions) (<-chan WatchValidateResultSummaryEvent, context.CancelFunc, error)
	GetValidateResult(options GetValidateResultOptions) (*result.ValidateResult, error)

	ListKluctlDeployments() ([]WatchKluctlDeploymentEvent, error)
	WatchKluctlDeployments() (<-chan WatchKluctlDeploymentEvent, context.CancelFunc, error)
	GetKluctlDeployment(clusterId string, name string, namespace string) (*kluctlv1.KluctlDeployment, error)
}

type ResultStoreSecrets

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

func NewResultStoreSecrets

func NewResultStoreSecrets(ctx context.Context, config *rest.Config, client_ client.Client, allowWrite bool, writeNamespace string, keepCommandResultsCount int, keepValidateResultsCount int) (*ResultStoreSecrets, error)

func (*ResultStoreSecrets) DeleteCommandResult added in v2.22.0

func (s *ResultStoreSecrets) DeleteCommandResult(rsId string) error

func (*ResultStoreSecrets) GetCommandResult

func (s *ResultStoreSecrets) GetCommandResult(options GetCommandResultOptions) (*result.CommandResult, error)

func (*ResultStoreSecrets) GetKluctlDeployment added in v2.21.0

func (s *ResultStoreSecrets) GetKluctlDeployment(clusterId string, name string, namespace string) (*kluctlv1.KluctlDeployment, error)

func (*ResultStoreSecrets) GetValidateResult added in v2.21.0

func (s *ResultStoreSecrets) GetValidateResult(options GetValidateResultOptions) (*result.ValidateResult, error)

func (*ResultStoreSecrets) ListCommandResultSummaries

func (s *ResultStoreSecrets) ListCommandResultSummaries(options ListResultSummariesOptions) ([]result.CommandResultSummary, error)

func (*ResultStoreSecrets) ListKluctlDeployments added in v2.21.0

func (s *ResultStoreSecrets) ListKluctlDeployments() ([]WatchKluctlDeploymentEvent, error)

func (*ResultStoreSecrets) ListValidateResultSummaries added in v2.21.0

func (s *ResultStoreSecrets) ListValidateResultSummaries(options ListResultSummariesOptions) ([]result.ValidateResultSummary, error)

func (*ResultStoreSecrets) StartCleanupOrphans added in v2.21.0

func (s *ResultStoreSecrets) StartCleanupOrphans() error

func (*ResultStoreSecrets) WatchCommandResultSummaries

func (s *ResultStoreSecrets) WatchCommandResultSummaries(options ListResultSummariesOptions) (<-chan WatchCommandResultSummaryEvent, context.CancelFunc, error)

func (*ResultStoreSecrets) WatchKluctlDeployments added in v2.21.0

func (s *ResultStoreSecrets) WatchKluctlDeployments() (<-chan WatchKluctlDeploymentEvent, context.CancelFunc, error)

func (*ResultStoreSecrets) WatchValidateResultSummaries added in v2.21.0

func (s *ResultStoreSecrets) WatchValidateResultSummaries(options ListResultSummariesOptions) (<-chan WatchValidateResultSummaryEvent, context.CancelFunc, error)

func (*ResultStoreSecrets) WriteCommandResult

func (s *ResultStoreSecrets) WriteCommandResult(cr *result.CommandResult) error

func (*ResultStoreSecrets) WriteValidateResult added in v2.21.0

func (s *ResultStoreSecrets) WriteValidateResult(vr *result.ValidateResult) error

type ResultsCollector

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

func NewResultsCollector

func NewResultsCollector(ctx context.Context, stores []ResultStore) *ResultsCollector

func (*ResultsCollector) DeleteCommandResult added in v2.22.0

func (rc *ResultsCollector) DeleteCommandResult(rsId string) error

func (*ResultsCollector) GetCommandResult

func (rc *ResultsCollector) GetCommandResult(options GetCommandResultOptions) (*result.CommandResult, error)

func (*ResultsCollector) GetKluctlDeployment added in v2.21.0

func (rc *ResultsCollector) GetKluctlDeployment(clusterId string, name string, namespace string) (*kluctlv1.KluctlDeployment, error)

func (*ResultsCollector) GetValidateResult added in v2.21.0

func (rc *ResultsCollector) GetValidateResult(options GetValidateResultOptions) (*result.ValidateResult, error)

func (*ResultsCollector) ListCommandResultSummaries

func (rc *ResultsCollector) ListCommandResultSummaries(options ListResultSummariesOptions) ([]result.CommandResultSummary, error)

func (*ResultsCollector) ListKluctlDeployments added in v2.21.0

func (rc *ResultsCollector) ListKluctlDeployments() ([]WatchKluctlDeploymentEvent, error)

func (*ResultsCollector) ListValidateResultSummaries added in v2.21.0

func (rc *ResultsCollector) ListValidateResultSummaries(options ListResultSummariesOptions) ([]result.ValidateResultSummary, error)

func (*ResultsCollector) Start

func (rc *ResultsCollector) Start()

func (*ResultsCollector) WaitForResults added in v2.21.0

func (rc *ResultsCollector) WaitForResults(idleTimeout time.Duration, totalTimeout time.Duration) error

func (*ResultsCollector) WatchCommandResultSummaries

func (rc *ResultsCollector) WatchCommandResultSummaries(options ListResultSummariesOptions) (<-chan WatchCommandResultSummaryEvent, context.CancelFunc, error)

func (*ResultsCollector) WatchKluctlDeployments added in v2.21.0

func (rc *ResultsCollector) WatchKluctlDeployments() (<-chan WatchKluctlDeploymentEvent, context.CancelFunc, error)

func (*ResultsCollector) WatchValidateResultSummaries added in v2.21.0

func (rc *ResultsCollector) WatchValidateResultSummaries(options ListResultSummariesOptions) (<-chan WatchValidateResultSummaryEvent, context.CancelFunc, error)

func (*ResultsCollector) WriteCommandResult

func (rc *ResultsCollector) WriteCommandResult(cr *result.CommandResult) error

func (*ResultsCollector) WriteValidateResult added in v2.21.0

func (rc *ResultsCollector) WriteValidateResult(vr *result.ValidateResult) error

type WatchCommandResultSummaryEvent added in v2.21.0

type WatchCommandResultSummaryEvent struct {
	Summary *result.CommandResultSummary `json:"summary"`
	Delete  bool                         `json:"delete"`
}

type WatchKluctlDeploymentEvent added in v2.21.0

type WatchKluctlDeploymentEvent struct {
	ClusterId  string                     `json:"clusterId"`
	Deployment *kluctlv1.KluctlDeployment `json:"deployment"`
	Delete     bool                       `json:"delete"`
}

type WatchValidateResultSummaryEvent added in v2.21.0

type WatchValidateResultSummaryEvent struct {
	Summary *result.ValidateResultSummary `json:"summary"`
	Delete  bool                          `json:"delete"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL