dynamic

Documentation

Index

• type ObjectClient
• type PipelineRunClient
  • func (c *PipelineRunClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, ...) error
• type Reconciler
  • func NewDynamicReconciler(rc pb.ResultsClient, lc pb.LogsClient, oc ObjectClient, cfg *reconciler.Config) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, o results.Object) error
• type TaskRunClient
  • func (c *TaskRunClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, ...) error

Types

type ObjectClient

type ObjectClient interface {
	Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
	Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) error
}

ObjectClient is a shim around generated k8s clients to handle objects in type agnostic ways. This might be able to be replaced with generics later?

type PipelineRunClient

type PipelineRunClient struct {
	v1beta1.PipelineRunInterface
}

PipelineRunClient implements the dynamic ObjectClient for TaskRuns.

func (*PipelineRunClient) Patch

func (c *PipelineRunClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) error

type Reconciler

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

Reconciler implements common reconciler behavior across different Tekton Run Object types.

func NewDynamicReconciler

func NewDynamicReconciler(rc pb.ResultsClient, lc pb.LogsClient, oc ObjectClient, cfg *reconciler.Config) *Reconciler

NewDynamicReconciler creates a new dynamic Reconciler.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, o results.Object) error

Reconcile handles result/record uploading for the given Run object. If enabled, the object may be deleted upon successful result upload.

type TaskRunClient

type TaskRunClient struct {
	v1beta1.TaskRunInterface
}

TaskRunClient implements the dynamic ObjectClient for TaskRuns.

func (*TaskRunClient) Patch

func (c *TaskRunClient) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) error