Documentation
¶
Index ¶
- func CheckHash(pipeline Pipeline) (bool, error)
- func GetClusterVectorPipelines(ctx context.Context, client client.Client) ([]vectorv1alpha1.ClusterVectorPipeline, error)
- func GetSpecHash(pipeline Pipeline) (*uint32, error)
- func GetVectorPipelines(ctx context.Context, client client.Client) ([]vectorv1alpha1.VectorPipeline, error)
- func SetFailedStatus(ctx context.Context, client client.Client, p Pipeline, err error) error
- func SetLastAppliedPipelineStatus(ctx context.Context, client client.Client, p Pipeline) error
- func SetSuccessStatus(ctx context.Context, client client.Client, p Pipeline) error
- type Pipeline
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckHash ¶ added in v0.0.2
CheckHash returns true, if hash in .status.lastAppliedPipelineHash matches with spec Hash
func GetClusterVectorPipelines ¶ added in v0.0.2
func GetClusterVectorPipelines(ctx context.Context, client client.Client) ([]vectorv1alpha1.ClusterVectorPipeline, error)
func GetSpecHash ¶ added in v0.0.2
func GetVectorPipelines ¶ added in v0.0.2
func GetVectorPipelines(ctx context.Context, client client.Client) ([]vectorv1alpha1.VectorPipeline, error)
func SetFailedStatus ¶ added in v0.0.2
func SetLastAppliedPipelineStatus ¶ added in v0.0.2
Types ¶
type Pipeline ¶
type Pipeline interface {
GetSpec() vectorv1alpha1.VectorPipelineSpec
GetName() string
GetNamespace() string
Type() string
SetConfigCheck(bool)
SetReason(*string)
GetLastAppliedPipeline() *uint32
SetLastAppliedPipeline(*uint32)
IsValid() bool
IsDeleted() bool
UpdateStatus(context.Context, client.Client) error
}
Source Files
Click to show internal directories.
Click to hide internal directories.