kube

Documentation

Index

• Variables
• type Client
  • func NewClient(config Config) *Client
  • func (c Client) RunJob(ctx context.Context, namespace, name string, image string, cmd []string, ...) error
  • func (c Client) StreamLogs(ctx context.Context, namespace string, filter map[string]string) (<-chan LogChunk, error)
• type Config
  • func DefaultClientConfig() Config
  • func (conf Config) RESTConfig() *rest.Config
  • func (conf Config) StreamingConfig() *rest.Config
• type LogChunk

Variables

var (
	ErrJobExecutionFailed = errors.ErrInternal.WithMsgf("job execution failed")
	ErrJobCreationFailed  = errors.ErrInternal.WithMsgf("job creation failed")
	ErrJobNotFound        = errors.ErrNotFound.WithMsgf("job not found")
)

Types

type Client

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

func NewClient

func NewClient(config Config) *Client

func (Client) RunJob

func (c Client) RunJob(ctx context.Context, namespace, name string, image string, cmd []string, retries int32) error

func (Client) StreamLogs

func (c Client) StreamLogs(ctx context.Context, namespace string, filter map[string]string) (<-chan LogChunk, error)

type Config

type Config struct {
	// Host - The hostname (in form of URI) of Kubernetes master.
	Host string `json:"host"`

	Timeout time.Duration `json:"timeout" default:"100ms"`

	// Token - Token to authenticate a service account
	Token string `json:"token"`

	// Insecure - Whether server should be accessed without verifying the TLS certificate.
	Insecure bool `json:"insecure" default:"false"`

	// ClientKey - PEM-encoded client key for TLS authentication.
	ClientKey string `json:"client_key"`

	// ClientCertificate - PEM-encoded client certificate for TLS authentication.
	ClientCertificate string `json:"client_certificate"`

	// ClusterCACertificate - PEM-encoded root certificates bundle for TLS authentication.
	ClusterCACertificate string `json:"cluster_ca_certificate"`
}

func DefaultClientConfig

func DefaultClientConfig() Config

func (Config) RESTConfig

func (conf Config) RESTConfig() *rest.Config

func (Config) StreamingConfig

func (conf Config) StreamingConfig() *rest.Config

type LogChunk

type LogChunk struct {
	Data   []byte
	Labels map[string]string
}