Documentation ¶
Index ¶
- func FilterProject(x result.ProjectKey, filter *result.ProjectKey) bool
- type GetCommandResultOptions
- type GetValidateResultOptions
- type ListResultSummariesOptions
- type ResultStore
- type ResultStoreSecrets
- func (s *ResultStoreSecrets) DeleteCommandResult(rsId string) error
- func (s *ResultStoreSecrets) GetCommandResult(options GetCommandResultOptions) (*result.CommandResult, error)
- func (s *ResultStoreSecrets) GetKluctlDeployment(clusterId string, name string, namespace string) (*kluctlv1.KluctlDeployment, error)
- func (s *ResultStoreSecrets) GetValidateResult(options GetValidateResultOptions) (*result.ValidateResult, error)
- func (s *ResultStoreSecrets) ListCommandResultSummaries(options ListResultSummariesOptions) ([]result.CommandResultSummary, error)
- func (s *ResultStoreSecrets) ListKluctlDeployments() ([]WatchKluctlDeploymentEvent, error)
- func (s *ResultStoreSecrets) ListValidateResultSummaries(options ListResultSummariesOptions) ([]result.ValidateResultSummary, error)
- func (s *ResultStoreSecrets) StartCleanupOrphans() error
- func (s *ResultStoreSecrets) WatchCommandResultSummaries(options ListResultSummariesOptions) (<-chan WatchCommandResultSummaryEvent, context.CancelFunc, error)
- func (s *ResultStoreSecrets) WatchKluctlDeployments() (<-chan WatchKluctlDeploymentEvent, context.CancelFunc, error)
- func (s *ResultStoreSecrets) WatchValidateResultSummaries(options ListResultSummariesOptions) (<-chan WatchValidateResultSummaryEvent, context.CancelFunc, error)
- func (s *ResultStoreSecrets) WriteCommandResult(cr *result.CommandResult) error
- func (s *ResultStoreSecrets) WriteValidateResult(vr *result.ValidateResult) error
- type ResultsCollector
- func (rc *ResultsCollector) DeleteCommandResult(rsId string) error
- func (rc *ResultsCollector) GetCommandResult(options GetCommandResultOptions) (*result.CommandResult, error)
- func (rc *ResultsCollector) GetKluctlDeployment(clusterId string, name string, namespace string) (*kluctlv1.KluctlDeployment, error)
- func (rc *ResultsCollector) GetValidateResult(options GetValidateResultOptions) (*result.ValidateResult, error)
- func (rc *ResultsCollector) ListCommandResultSummaries(options ListResultSummariesOptions) ([]result.CommandResultSummary, error)
- func (rc *ResultsCollector) ListKluctlDeployments() ([]WatchKluctlDeploymentEvent, error)
- func (rc *ResultsCollector) ListValidateResultSummaries(options ListResultSummariesOptions) ([]result.ValidateResultSummary, error)
- func (rc *ResultsCollector) Start()
- func (rc *ResultsCollector) WaitForResults(idleTimeout time.Duration, totalTimeout time.Duration) error
- func (rc *ResultsCollector) WatchCommandResultSummaries(options ListResultSummariesOptions) (<-chan WatchCommandResultSummaryEvent, context.CancelFunc, error)
- func (rc *ResultsCollector) WatchKluctlDeployments() (<-chan WatchKluctlDeploymentEvent, context.CancelFunc, error)
- func (rc *ResultsCollector) WatchValidateResultSummaries(options ListResultSummariesOptions) (<-chan WatchValidateResultSummaryEvent, context.CancelFunc, error)
- func (rc *ResultsCollector) WriteCommandResult(cr *result.CommandResult) error
- func (rc *ResultsCollector) WriteValidateResult(vr *result.ValidateResult) error
- type WatchCommandResultSummaryEvent
- type WatchKluctlDeploymentEvent
- type WatchValidateResultSummaryEvent
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 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 (*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 (*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"` }
Click to show internal directories.
Click to hide internal directories.