kube

Documentation

Index

• func GetKubeconfigPath(platformConfiguration interface{}) string
• func IsInCluster() bool
• func UpdateFunctioncrWithOptions(deployOptions *platform.DeployOptions, functioncrInstance *functioncr.Function) error
• type Configuration
• type DeployOptions
• type Platform
  • func NewPlatform(parentLogger nuclio.Logger, kubeconfigPath string) (*Platform, error)
  • func (p *Platform) DeleteFunction(deleteOptions *platform.DeleteOptions) error
  • func (p *Platform) DeployFunction(deployOptions *platform.DeployOptions) (*platform.DeployResult, error)
  • func (p *Platform) GetFunctions(getOptions *platform.GetOptions) ([]platform.Function, error)
  • func (p *Platform) GetName() string
  • func (p *Platform) UpdateFunction(updateOptions *platform.UpdateOptions) error

Functions

func GetKubeconfigPath

func GetKubeconfigPath(platformConfiguration interface{}) string

func IsInCluster

func IsInCluster() bool

func UpdateFunctioncrWithOptions

func UpdateFunctioncrWithOptions(deployOptions *platform.DeployOptions,
	functioncrInstance *functioncr.Function) error

Types

type Configuration

type Configuration struct {
	KubeconfigPath string
}

type DeployOptions

type DeployOptions struct {
}

type Platform

type Platform struct {
	*platform.AbstractPlatform
	// contains filtered or unexported fields
}

func NewPlatform

func NewPlatform(parentLogger nuclio.Logger, kubeconfigPath string) (*Platform, error)

NewPlatform instantiates a new kubernetes platform

func (*Platform) DeleteFunction

func (p *Platform) DeleteFunction(deleteOptions *platform.DeleteOptions) error

DeleteFunction will delete a previously deployed function

func (*Platform) DeployFunction

func (p *Platform) DeployFunction(deployOptions *platform.DeployOptions) (*platform.DeployResult, error)

Deploy will deploy a processor image to the platform (optionally building it, if source is provided)

func (*Platform) GetFunctions

func (p *Platform) GetFunctions(getOptions *platform.GetOptions) ([]platform.Function, error)

GetFunctions will return deployed functions

func (*Platform) GetName

func (p *Platform) GetName() string

GetName returns the platform name

func (*Platform) UpdateFunction

func (p *Platform) UpdateFunction(updateOptions *platform.UpdateOptions) error

UpdateFunction will update a previously deployed function