pipeline

package

v0.0.1 Latest Latest Go to latest Published: Nov 1, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kaasops/vector-operator

Links

Open Source Insights

Documentation ¶

Index ¶

type Controller
- func NewController(ctx context.Context, c client.Client, p Pipeline) *Controller
type Pipeline

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Controller ¶

type Controller struct {
	Pipeline Pipeline
	Ctx      context.Context
	Client   client.Client
}

func NewController ¶

func NewController(ctx context.Context, c client.Client, p Pipeline) *Controller

func (*Controller) CheckHash ¶

func (ctrl *Controller) CheckHash() (bool, error)

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

func (*Controller) GetSinks ¶

func (ctrl *Controller) GetSinks() ([]*vector.Sink, error)

func (*Controller) GetSources ¶

func (ctrl *Controller) GetSources(filter []string) ([]*vector.Source, error)

func (*Controller) GetSpecHash ¶

func (ctrl *Controller) GetSpecHash() (*uint32, error)

func (*Controller) GetTransforms ¶

func (ctrl *Controller) GetTransforms() ([]*vector.Transform, error)

func (*Controller) SelectClusterVectorPipelineSucceesed ¶

func (ctrl *Controller) SelectClusterVectorPipelineSucceesed() ([]*clustervectorpipeline.Controller, error)

func (*Controller) SelectSucceesed ¶

func (ctrl *Controller) SelectSucceesed() ([]Controller, error)

func (*Controller) SelectVectorPipelineSucceesed ¶

func (ctrl *Controller) SelectVectorPipelineSucceesed() ([]*vectorpipeline.Controller, error)

func (*Controller) SetFailedStatus ¶

func (ctrl *Controller) SetFailedStatus(err error) error

func (*Controller) SetLastAppliedPipelineStatus ¶

func (ctrl *Controller) SetLastAppliedPipelineStatus() error

func (*Controller) SetSucceesStatus ¶

func (ctrl *Controller) SetSucceesStatus() error

type Pipeline ¶

type Pipeline interface {
	Spec() vectorv1alpha1.VectorPipelineSpec
	Name() string
	Namespace() string
	Type() string
	SetConfigCheck(bool)
	SetReason(*string)
	GetLastAppliedPipeline() *uint32
	SetLastAppliedPipeline(*uint32)
	UpdateStatus(context.Context, client.Client) error
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
clustervectorpipeline
vectorpipeline

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