hadoop

Documentation

Overview

Inspired by:
 https://github.com/helm/helm-classic/blob/master/kubectl/command.go

package kubectl

Inspired by:
 https://github.com/helm/helm-classic/blob/master/kubectl/get.go

package kubectl

Inspired by:
 https://github.com/helm/helm-classic/blob/master/kubectl/kubectl.go

package kubectl

Index

• Variables
• func InitMap(cfg *Config) error
• func PreBoot(cfg *Config)
• type Config
  • func (cfg *Config) InitMap(clientset kubernetes.Interface) (*corev1.ConfigMap, error)
• type ConfigMode
• type PrintRunner
• type RealRunner
  • func (r RealRunner) Format(hdfs, nodetype, clusterid string) error
• type Runner

Variables

var Path = "sh"

Path is the path of the kubectl binary

Functions

func InitMap

func InitMap(cfg *Config) error

func PreBoot

func PreBoot(cfg *Config)

Types

type Config

type Config struct {
	Kubeconfig         string
	Kind               string
	CustomResourceName string
	Name               string

	ServiceName string
	Namespace   string
	BaseDomain  string
	Port        int
	Dir         string
	ClusterID   string
	NodeType    string
	LogLevel    int
	// contains filtered or unexported fields
}

func (*Config) InitMap

func (cfg *Config) InitMap(clientset kubernetes.Interface) (*corev1.ConfigMap, error)

type ConfigMode

type ConfigMode string

const (
	ConfigMap     ConfigMode = "configMap"
	InitContainer ConfigMode = "initContainer"
)

type PrintRunner

type PrintRunner struct{}

PrintRunner implements Runner to return a []byte of the command to be executed

type RealRunner

type RealRunner struct{}

RealRunner implements Runner to execute kubectl commands

func (RealRunner) Format

func (r RealRunner) Format(hdfs, nodetype, clusterid string) error

type Runner

type Runner interface {
	//	// ClusterInfo returns Kubernetes cluster info
	//	ClusterInfo() ([]byte, error)
	//	// Create uploads a chart to Kubernetes
	//	Create([]byte, string) ([]byte, error)
	//	// Delete removes a chart from Kubernetes.
	//	Delete(string, string, string) ([]byte, error)
	//	// Get returns Kubernetes resources
	//	Get([]byte, string) ([]byte, error)
	Format(string, string, string) error
}

Runner is an interface to wrap kubectl convenience methods

var Client Runner = RealRunner{}

Client stores the instance of Runner