hadoop

package
v0.0.0-...-fc21188 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 6, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
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

Directories

Path Synopsis
"github.com/rook/rook/pkg/operator/k8sutil"
"github.com/rook/rook/pkg/operator/k8sutil"

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL