kubernetes

Documentation

Index

• func PersistentVolume(node, namespace, name string) *v1.PersistentVolume
• func PersistentVolumeClaim(namespace, name string) *v1.PersistentVolumeClaim
• func Pod(namespace string, step *engine.Step) (*v1.Pod, error)
• func Service(namespace, name, podName string, ports []int) *v1.Service
• type Engine
  • func New(opts ...Option) (*Engine, error)
  • func NewEnv() (*Engine, error)
  • func (e *Engine) Create(ctx context.Context, step *engine.Step) error
  • func (e *Engine) Destroy(ctx context.Context, conf *engine.Config) error
  • func (e *Engine) Download(ctx context.Context, step *engine.Step, path string) (io.ReadCloser, *engine.FileInfo, error)
  • func (e *Engine) Setup(ctx context.Context, conf *engine.Config) error
  • func (e *Engine) Start(ctx context.Context, step *engine.Step) error
  • func (e *Engine) Tail(ctx context.Context, step *engine.Step) (io.ReadCloser, error)
  • func (e *Engine) Upload(ctx context.Context, step *engine.Step, path string, r io.Reader) error
  • func (e *Engine) Wait(ctx context.Context, step *engine.Step) (*engine.State, error)
• type Option
  • func WithConfig(masterURL, kubeconfigPath string) Option
  • func WithNamespace(ns string) Option

Functions

func PersistentVolume

func PersistentVolume(node, namespace, name string) *v1.PersistentVolume

func PersistentVolumeClaim

func PersistentVolumeClaim(namespace, name string) *v1.PersistentVolumeClaim

func Pod

func Pod(namespace string, step *engine.Step) (*v1.Pod, error)

func Service

func Service(namespace, name, podName string, ports []int) *v1.Service

Types

type Engine

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

func New

func New(opts ...Option) (*Engine, error)

New returns a new Kubernetes Engine.

func NewEnv

func NewEnv() (*Engine, error)

func (*Engine) Create

func (e *Engine) Create(ctx context.Context, step *engine.Step) error

func (*Engine) Destroy

func (e *Engine) Destroy(ctx context.Context, conf *engine.Config) error

func (*Engine) Download

func (e *Engine) Download(ctx context.Context, step *engine.Step, path string) (io.ReadCloser, *engine.FileInfo, error)

func (*Engine) Setup

func (e *Engine) Setup(ctx context.Context, conf *engine.Config) error

Setup creates a PersistentVolumeClaim which will be shared across all pods/containers in the pipeline

func (*Engine) Start

func (e *Engine) Start(ctx context.Context, step *engine.Step) error

func (*Engine) Tail

func (e *Engine) Tail(ctx context.Context, step *engine.Step) (io.ReadCloser, error)

func (*Engine) Upload

func (e *Engine) Upload(ctx context.Context, step *engine.Step, path string, r io.Reader) error

func (*Engine) Wait

func (e *Engine) Wait(ctx context.Context, step *engine.Step) (*engine.State, error)

type Option

type Option func(e *Engine) error

func WithConfig

func WithConfig(masterURL, kubeconfigPath string) Option

func WithNamespace

func WithNamespace(ns string) Option