driver

Documentation

Index

• Constants
• type Driver
  • func (driver *Driver) Log(ctx context.Context, res module.ExpandedResource, filter map[string]string) (<-chan module.LogChunk, error)
  • func (driver *Driver) Output(ctx context.Context, exr module.ExpandedResource) (json.RawMessage, error)
  • func (driver *Driver) Plan(_ context.Context, res module.ExpandedResource, act module.ActionRequest) (*resource.Resource, error)
  • func (driver *Driver) Sync(ctx context.Context, exr module.ExpandedResource) (*resource.State, error)
• type IgnoreError
• type Output
  • func ReadOutputData(exr module.ExpandedResource) (*Output, error)
• type PendingStep
• type TransientData
  • func ReadTransientData(exr module.ExpandedResource) (*TransientData, error)

Constants

const (
	KeyKubeDependency = "kube_cluster"
	SuspendAction     = "suspend"
	StartAction       = "start"
)

Types

type Driver

type Driver struct {
	Conf       config.DriverConf
	CreateJob  func(ctx context.Context, conf kube.Config, j *job.Job) error
	SuspendJob func(ctx context.Context, conf kube.Config, j *job.Job) error
	DeleteJob  func(ctx context.Context, conf kube.Config, j *job.Job) error
	StartJob   func(ctx context.Context, conf kube.Config, j *job.Job) error
	GetJobPods func(ctx context.Context, conf kube.Config, j *job.Job, labels map[string]string) ([]kube.Pod, error)
	StreamLogs func(ctx context.Context, kubeConf kube.Config, j *job.Job, filter map[string]string) (<-chan module.LogChunk, error)
}

func (*Driver) Log

func (driver *Driver) Log(ctx context.Context, res module.ExpandedResource, filter map[string]string) (<-chan module.LogChunk, error)

func (*Driver) Output

func (driver *Driver) Output(ctx context.Context, exr module.ExpandedResource) (json.RawMessage, error)

func (*Driver) Plan

func (driver *Driver) Plan(_ context.Context, res module.ExpandedResource, act module.ActionRequest) (*resource.Resource, error)

func (*Driver) Sync

func (driver *Driver) Sync(ctx context.Context, exr module.ExpandedResource) (*resource.State, error)

type IgnoreError

type IgnoreError bool

type Output

type Output struct {
	Namespace string     `json:"namespace"`
	JobName   string     `json:"jobName"`
	Pods      []kube.Pod `json:"pods"`
}

func ReadOutputData

func ReadOutputData(exr module.ExpandedResource) (*Output, error)

type PendingStep

type PendingStep string

const (
	Create  PendingStep = "create"
	Suspend PendingStep = "suspend"
	Delete  PendingStep = "delete"
	Start   PendingStep = "start"
)

type TransientData

type TransientData struct {
	PendingSteps []PendingStep `json:"pending_steps"`
}

func ReadTransientData

func ReadTransientData(exr module.ExpandedResource) (*TransientData, error)