argo

Documentation

Index

• func FormatPodName(node *v1alpha1.NodeStatus) string
• func NewMiniCache() (*redis.Client, *miniredis.Miniredis, error)
• type Archive
  • func (a Archive) GetBucketName() string
  • func (a Archive) GetFileLocation() string
  • func (a Archive) GetTimestamp() int64
• type Client
  • func NewInClusterArgoClient() (Client, error)
  • func NewLocalArgoClient() (Client, error)
  • func (c Client) CreateWorkflow(namespace string, workflow *v1alpha1.Workflow) (*v1alpha1.Workflow, error)
  • func (c Client) DeleteWorkflow(namespace, name string) error
  • func (c Client) GetNode(workflow *v1alpha1.Workflow, name string) (*v1alpha1.NodeStatus, error)
  • func (c Client) GetWorkflow(namespace, name string) (*v1alpha1.Workflow, error)
  • func (c Client) ListWorkflows(ctx context.Context, namespace string) ([]v1alpha1.Workflow, error)
• type Log
• type LogsStreamer
  • func NewLogsStreamer(config StreamerConfig) (*LogsStreamer, error)
  • func (s *LogsStreamer) GetArchivedLogsForTemplate(c context.Context, templateName string) (io.ReadCloser, error)
  • func (s *LogsStreamer) IsDone() bool
  • func (s *LogsStreamer) NumDone() int
  • func (s *LogsStreamer) NumNodes() int
  • func (s *LogsStreamer) Start(ctx context.Context) (chan Log, error)
• type StreamerConfig

Functions

func FormatPodName

func FormatPodName(node *v1alpha1.NodeStatus) string

func NewMiniCache

func NewMiniCache() (*redis.Client, *miniredis.Miniredis, error)

Types

type Archive

type Archive struct {
	BucketName   string
	WorkflowName string `json:"workflowName"`
	PodName      string `json:"podName"`
}

func (Archive) GetBucketName

func (a Archive) GetBucketName() string

func (Archive) GetFileLocation

func (a Archive) GetFileLocation() string

func (Archive) GetTimestamp

func (a Archive) GetTimestamp() int64

type Client

type Client struct {
	*versioned.Clientset
}

func NewInClusterArgoClient

func NewInClusterArgoClient() (Client, error)

func NewLocalArgoClient

func NewLocalArgoClient() (Client, error)

func (Client) CreateWorkflow

func (c Client) CreateWorkflow(namespace string, workflow *v1alpha1.Workflow) (*v1alpha1.Workflow, error)

func (Client) DeleteWorkflow

func (c Client) DeleteWorkflow(namespace, name string) error

func (Client) GetNode

func (c Client) GetNode(workflow *v1alpha1.Workflow, name string) (*v1alpha1.NodeStatus, error)

func (Client) GetWorkflow

func (c Client) GetWorkflow(namespace, name string) (*v1alpha1.Workflow, error)

func (Client) ListWorkflows

func (c Client) ListWorkflows(ctx context.Context, namespace string) ([]v1alpha1.Workflow, error)

type Log

type Log struct {
	Step  string `json:"step"`
	Lines string `json:"lines"`
}

type LogsStreamer

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

func NewLogsStreamer

func NewLogsStreamer(config StreamerConfig) (*LogsStreamer, error)

func (*LogsStreamer) GetArchivedLogsForTemplate

func (s *LogsStreamer) GetArchivedLogsForTemplate(c context.Context, templateName string) (io.ReadCloser, error)

func (*LogsStreamer) IsDone

func (s *LogsStreamer) IsDone() bool

func (*LogsStreamer) NumDone

func (s *LogsStreamer) NumDone() int

func (*LogsStreamer) NumNodes

func (s *LogsStreamer) NumNodes() int

func (*LogsStreamer) Start

func (s *LogsStreamer) Start(ctx context.Context) (chan Log, error)

type StreamerConfig

type StreamerConfig struct {
	K8sClient     *base.Client
	ArgoClient    *Client
	StorageClient client.StorageClient
	LogsCache     *redis.Client
	Namespace     string
	WorkflowName  string
}