pipeline

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
  • func GetValidPipelines(ctx context.Context, client client.Client) ([]Pipeline, error)

Functions

func CheckHash

func CheckHash(pipeline Pipeline) (bool, error)

CheckHash returns true, if hash in .status.lastAppliedPipelineHash matches with spec Hash

func GetClusterVectorPipelines

func GetClusterVectorPipelines(ctx context.Context, client client.Client) ([]vectorv1alpha1.ClusterVectorPipeline, error)

func GetSpecHash

func GetSpecHash(pipeline Pipeline) (*uint32, error)

func GetVectorPipelines

func GetVectorPipelines(ctx context.Context, client client.Client) ([]vectorv1alpha1.VectorPipeline, error)

func SetFailedStatus

func SetFailedStatus(ctx context.Context, client client.Client, p Pipeline, err error) error

func SetLastAppliedPipelineStatus

func SetLastAppliedPipelineStatus(ctx context.Context, client client.Client, p Pipeline) error

func SetSuccessStatus

func SetSuccessStatus(ctx context.Context, client client.Client, p Pipeline) error

Types

type Pipeline

type Pipeline interface {
	GetSpec() vectorv1alpha1.VectorPipelineSpec
	GetName() string
	GetNamespace() string
	Type() string
	SetConfigCheck(bool)
	SetReason(*string)
	GetLastAppliedPipeline() *uint32
	SetLastAppliedPipeline(*uint32)
	GetConfigCheckResult() *bool
	IsValid() bool
	IsDeleted() bool
	UpdateStatus(context.Context, client.Client) error
}

func GetValidPipelines

func GetValidPipelines(ctx context.Context, client client.Client) ([]Pipeline, error)