kubernetes

Documentation

Index

• Constants
• Variables
• func CheckCarbonNamespace(ns string) (bool, error)
• func CreateGlobalCarbonNamespace() error
• func Delete(manifest, ns string) error
• func GetAllNamespaces() (*apicorev1.NamespaceList, error)
• func GetAllResources() ([]string, error)
• func GetConfigMapHandler(namespace string) (typedcorev1.ConfigMapInterface, error)
• func GetNamespaceHandler() (typedcorev1.NamespaceInterface, error)
• func GetSecretHandler(namespace string) (typedcorev1.SecretInterface, error)
• func KubeCmdFactory(ns string) (cmdutil.Factory, genericclioptions.IOStreams)
• func KubeConfig() (*restclient.Config, error)
• func ReadTemplates(cfg *pkgcfg.CarbonConfig) ([]byte, error)
• func SetNamespace(cliNS string) error
• type DepVars
• type DepVarsPkg
• type KubeInstall
  • func NewKubeInstall(meta *pkgmeta.PackageConfig, dname string, dtag string) (*KubeInstall, error)
  • func (self *KubeInstall) Apply(defPWL bool) error
  • func (self *KubeInstall) Build() error
  • func (self *KubeInstall) ProcessPatches(data []byte) error
  • func (self *KubeInstall) SetAppLabel() error
  • func (self *KubeInstall) UpdateVars(vars map[string]string)
  • func (self *KubeInstall) VerifyAll(path string) error
  • func (self *KubeInstall) VerifyTpl(path string) error
• type Patcher
  • func (self *Patcher) Apply(original []byte) ([]byte, error)
  • func (self *Patcher) MatchObj(data []byte) (bool, error)

Constants

const (
	GlobalCarbonNamespace = "carbon-data"
)

Variables

var CurrentNamespace string

Functions

func CheckCarbonNamespace

func CheckCarbonNamespace(ns string) (bool, error)

func CreateGlobalCarbonNamespace

func CreateGlobalCarbonNamespace() error

func Delete

func Delete(manifest, ns string) error

func GetAllNamespaces

func GetAllNamespaces() (*apicorev1.NamespaceList, error)

func GetAllResources

func GetAllResources() ([]string, error)

func GetConfigMapHandler

func GetConfigMapHandler(namespace string) (typedcorev1.ConfigMapInterface, error)

func GetNamespaceHandler

func GetNamespaceHandler() (typedcorev1.NamespaceInterface, error)

func GetSecretHandler

func GetSecretHandler(namespace string) (typedcorev1.SecretInterface, error)

func KubeCmdFactory

func KubeCmdFactory(ns string) (cmdutil.Factory, genericclioptions.IOStreams)

func KubeConfig

func KubeConfig() (*restclient.Config, error)

func ReadTemplates

func ReadTemplates(cfg *pkgcfg.CarbonConfig) ([]byte, error)

func SetNamespace

func SetNamespace(cliNS string) error

Types

type DepVars

type DepVars struct {
	Pkg DepVarsPkg
	Var map[string]string
}

type DepVarsPkg

type DepVarsPkg struct {
	DockerName string
	DockerTag  string
	Name       string
	Version    string
}

type KubeInstall

type KubeInstall struct {
	BuiltManifest []byte
	RawManifest   []byte
	Variables     DepVars
}

func NewKubeInstall

func NewKubeInstall(meta *pkgmeta.PackageConfig, dname string, dtag string) (*KubeInstall, error)

func (*KubeInstall) Apply

func (self *KubeInstall) Apply(defPWL bool) error

func (*KubeInstall) Build

func (self *KubeInstall) Build() error

func (*KubeInstall) ProcessPatches

func (self *KubeInstall) ProcessPatches(data []byte) error

func (*KubeInstall) SetAppLabel

func (self *KubeInstall) SetAppLabel() error

func (*KubeInstall) UpdateVars

func (self *KubeInstall) UpdateVars(vars map[string]string)

func (*KubeInstall) VerifyAll

func (self *KubeInstall) VerifyAll(path string) error

func (*KubeInstall) VerifyTpl

func (self *KubeInstall) VerifyTpl(path string) error

type Patcher

type Patcher struct {
	Filters map[string]string `json:"filters"`
	Type    string            `json:"type"`
	Patch   json.RawMessage   `json:"patch"`
}

func (*Patcher) Apply

func (self *Patcher) Apply(original []byte) ([]byte, error)

func (*Patcher) MatchObj

func (self *Patcher) MatchObj(data []byte) (bool, error)