pipelines

Documentation

Index

• type ClientPipelineRunner
  • func NewRunner(c client.Client) *ClientPipelineRunner
  • func (c *ClientPipelineRunner) Run(ctx context.Context, pipelineName, ns, serviceAccountName string, ...) (*pipelinev1.PipelineRun, error)
• type MockRunner
  • func NewMockRunner(t *testing.T) *MockRunner
  • func (m *MockRunner) AssertNoPipelineRuns()
  • func (m *MockRunner) AssertPipelineRun(pipelineName, ns string, serviceAccountName string, ...)
  • func (m *MockRunner) FailWithError(err error)
  • func (m *MockRunner) Run(ctx context.Context, pipelineName, ns, serviceAccountName string, ...) (*pipelinev1.PipelineRun, error)
• type PipelineRunner

Types

type ClientPipelineRunner

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

ClientPipelineRunner uses a split client to run pipelines.

func NewRunner

func NewRunner(c client.Client) *ClientPipelineRunner

NewRunner creates a new PipelineRunner that creates PipelineRuns with the provided client.

func (*ClientPipelineRunner) Run

func (c *ClientPipelineRunner) Run(ctx context.Context, pipelineName, ns, serviceAccountName string, params []pipelinev1.Param, res []pipelinev1.PipelineResourceBinding, ws []pipelinev1.WorkspaceBinding) (*pipelinev1.PipelineRun, error)

Run is an implementation of the PipelineRunner interface. TODO: This should replaced by TriggerTemplates/TriggerBindings.

type MockRunner

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

MockRunner is a mock pipeline runner that returns fixed responses to runs.

func NewMockRunner

func NewMockRunner(t *testing.T) *MockRunner

NewMockRunner creates and returns a new mock PipelineRunner.

func (*MockRunner) AssertNoPipelineRuns

func (m *MockRunner) AssertNoPipelineRuns()

AssertNoPipelineRuns fails if there were any pipelines executed.

func (*MockRunner) AssertPipelineRun

func (m *MockRunner) AssertPipelineRun(pipelineName, ns string, serviceAccountName string, wantParams []pipelinev1.Param, wantResources []pipelinev1.PipelineResourceBinding, wantWorkspaces []pipelinev1.WorkspaceBinding)

AssertPipelineRun ensures that the pipeline run was triggered.

func (*MockRunner) FailWithError

func (m *MockRunner) FailWithError(err error)

FailWithError configures the poller to return errors.

func (*MockRunner) Run

func (m *MockRunner) Run(ctx context.Context, pipelineName, ns, serviceAccountName string, params []pipelinev1.Param, res []pipelinev1.PipelineResourceBinding, ws []pipelinev1.WorkspaceBinding) (*pipelinev1.PipelineRun, error)

Run is an implementation of the PipelineRunner interface.

type PipelineRunner

type PipelineRunner interface {
	Run(ctx context.Context, pipelineName, ns, serviceAccountName string, params []pipelinev1.Param, res []pipelinev1.PipelineResourceBinding, ws []pipelinev1.WorkspaceBinding) (*pipelinev1.PipelineRun, error)
}

PipelineRunner executes a pipeline by name, creating a PipelineRun with the correct params and resource bindings.