workflow

Documentation

Index

• type Repo
  • func NewRepo(ac versioned.Interface, al listerv1alpha1.WorkflowLister, ...) *Repo
  • func (r *Repo) Delete(key string) error
  • func (r *Repo) Get(key string) (runtime.Object, error)
  • func (r *Repo) Logs(ctx context.Context, key string) (<-chan svc.Log, error)
  • func (r *Repo) Search(namespace, pattern string) []runtime.Object
• type Workflows
  • func (w Workflows) Len() int
  • func (w Workflows) Less(i, j int) bool
  • func (w Workflows) Swap(i, j int)

Types

type Repo

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

Repo is the workflow repository it always syncronizes the workflows as the storage at background.

func NewRepo

func NewRepo(ac versioned.Interface, al listerv1alpha1.WorkflowLister, kc kubernetes.Interface) *Repo

NewRepo create a new workflow repository.

func (*Repo) Delete

func (r *Repo) Delete(key string) error

Delete delete the workflow by the key.

func (*Repo) Get

func (r *Repo) Get(key string) (runtime.Object, error)

Get get the workflow by the key, the format is "namespace/key", and if doesn't exist it return nil.

func (*Repo) Logs

func (r *Repo) Logs(ctx context.Context, key string) (<-chan svc.Log, error)

Logs get the channel to recieve Logs from a Argo workflow.

func (*Repo) Search

func (r *Repo) Search(namespace, pattern string) []runtime.Object

Search get workflows which are matched with pattern.

type Workflows

type Workflows []*wf.Workflow

Workflows is the list sorted by start time and finished time.

func (Workflows) Len

func (w Workflows) Len() int

func (Workflows) Less

func (w Workflows) Less(i, j int) bool

func (Workflows) Swap

func (w Workflows) Swap(i, j int)