kube

package
v0.0.0-...-09e6e34 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 34 Imported by: 2

Documentation

Index

Constants

View Source 
const Mib = 1048576

Variables

This section is empty.

Functions

func BasicAuthNameFromAPIGatewayName 

func BasicAuthNameFromAPIGatewayName(apiGatewayName string) string

func ConfigMapNameFromFunctionName 

func ConfigMapNameFromFunctionName(functionName string) string

func CronJobName 

func CronJobName() string

func DeploymentNameFromFunctionName 

func DeploymentNameFromFunctionName(functionName string) string

func HPANameFromFunctionName 

func HPANameFromFunctionName(functionName string) string

func IngressNameFromAPIGatewayName 

func IngressNameFromAPIGatewayName(apiGatewayName string, canary bool) string

func IngressNameFromFunctionName 

func IngressNameFromFunctionName(functionName string) string

func NewProjectsClient 

func NewProjectsClient(platform *Platform, platformConfiguration *platformconfig.Config) (project.Client, error)

func PodNameFromFunctionName 

func PodNameFromFunctionName(functionName string) string

func ServiceNameFromFunctionName 

func ServiceNameFromFunctionName(functionName string) string

func ValidateAPIGatewaySpec 

func ValidateAPIGatewaySpec(apiGatewaySpec *platform.APIGatewaySpec) error

Types

type DeployOptions 

type DeployOptions struct {
}

type Platform 

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

func NewPlatform 

func NewPlatform(ctx context.Context,
	parentLogger logger.Logger,
	platformConfiguration *platformconfig.Config,
	defaultNamespace string) (*Platform, error)

NewPlatform instantiates a new kubernetes platform

func (*Platform) CreateAPIGateway 

func (p *Platform) CreateAPIGateway(ctx context.Context,
	createAPIGatewayOptions *platform.CreateAPIGatewayOptions) error

CreateAPIGateway creates and deploys a new api gateway

func (*Platform) CreateFunction 

func (p *Platform) CreateFunction(ctx context.Context, createFunctionOptions *platform.CreateFunctionOptions) (
	*platform.CreateFunctionResult, error)

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

func (*Platform) CreateFunctionEvent 

func (p *Platform) CreateFunctionEvent(ctx context.Context, createFunctionEventOptions *platform.CreateFunctionEventOptions) error

CreateFunctionEvent will create a new function event that can later be used as a template from which to invoke functions

func (*Platform) CreateProject 

func (p *Platform) CreateProject(ctx context.Context, createProjectOptions *platform.CreateProjectOptions) error

CreateProject creates a new project

func (*Platform) DeleteAPIGateway 

func (p *Platform) DeleteAPIGateway(ctx context.Context, deleteAPIGatewayOptions *platform.DeleteAPIGatewayOptions) error

DeleteAPIGateway will delete a previously existing api gateway

func (*Platform) DeleteFunction 

func (p *Platform) DeleteFunction(ctx context.Context, deleteFunctionOptions *platform.DeleteFunctionOptions) error

DeleteFunction will delete a previously deployed function

func (*Platform) DeleteFunctionEvent 

func (p *Platform) DeleteFunctionEvent(ctx context.Context, deleteFunctionEventOptions *platform.DeleteFunctionEventOptions) error

DeleteFunctionEvent will delete a previously existing function event

func (*Platform) DeleteProject 

func (p *Platform) DeleteProject(ctx context.Context, deleteProjectOptions *platform.DeleteProjectOptions) error

DeleteProject will delete a previously existing project

func (*Platform) EnrichFunctionConfig 

func (p *Platform) EnrichFunctionConfig(ctx context.Context, functionConfig *functionconfig.Config) error

func (*Platform) GetAPIGateways 

func (p *Platform) GetAPIGateways(ctx context.Context, getAPIGatewaysOptions *platform.GetAPIGatewaysOptions) ([]platform.APIGateway, error)

GetAPIGateways will list existing api gateways

func (*Platform) GetAllowedAuthenticationModes 

func (p *Platform) GetAllowedAuthenticationModes() []string

func (*Platform) GetDefaultInvokeIPAddresses 

func (p *Platform) GetDefaultInvokeIPAddresses() ([]string, error)

func (*Platform) GetExternalIPAddresses 

func (p *Platform) GetExternalIPAddresses() ([]string, error)

GetExternalIPAddresses returns the external IP addresses invocations will use. These addresses are either set through SetExternalIPAddresses or automatically discovered

func (*Platform) GetFunctionEvents 

func (p *Platform) GetFunctionEvents(ctx context.Context, getFunctionEventsOptions *platform.GetFunctionEventsOptions) ([]platform.FunctionEvent, error)

GetFunctionEvents will list existing function events

func (*Platform) GetFunctionReplicaContainers 

func (p *Platform) GetFunctionReplicaContainers(ctx context.Context, functionConfig *functionconfig.Config, replicaName string) ([]string, error)

func (*Platform) GetFunctionReplicaLogsStream 

func (p *Platform) GetFunctionReplicaLogsStream(ctx context.Context,
	options *platform.GetFunctionReplicaLogsStreamOptions) (io.ReadCloser, error)

func (*Platform) GetFunctionReplicaNames 

func (p *Platform) GetFunctionReplicaNames(ctx context.Context,
	functionConfig *functionconfig.Config) ([]string, error)

func (*Platform) GetFunctionSecretData 

func (p *Platform) GetFunctionSecretData(ctx context.Context, functionName, functionNamespace string) (map[string][]byte, error)

GetFunctionSecretData returns the function's secret data

func (*Platform) GetFunctionSecrets 

func (p *Platform) GetFunctionSecrets(ctx context.Context, functionName, functionNamespace string) ([]platform.FunctionSecret, error)

GetFunctionSecrets returns all the function's secrets

func (*Platform) GetFunctions 

func (p *Platform) GetFunctions(ctx context.Context, getFunctionsOptions *platform.GetFunctionsOptions) ([]platform.Function, error)

GetFunctions will return deployed functions

func (*Platform) GetName 

func (p *Platform) GetName() string

GetName returns the platform name

func (*Platform) GetNamespaces 

func (p *Platform) GetNamespaces(ctx context.Context) ([]string, error)

GetNamespaces returns all the namespaces in the platform

func (*Platform) GetProjects 

func (p *Platform) GetProjects(ctx context.Context,
	getProjectsOptions *platform.GetProjectsOptions) ([]platform.Project, error)

GetProjects will list existing projects

func (*Platform) GetScaleToZeroConfiguration 

func (p *Platform) GetScaleToZeroConfiguration() *platformconfig.ScaleToZero

func (*Platform) Initialize 

func (p *Platform) Initialize(ctx context.Context) error

func (*Platform) InitializeContainerBuilder 

func (p *Platform) InitializeContainerBuilder() error

InitializeContainerBuilder initializes the container builder, if not already initialized

func (*Platform) RedeployFunction 

func (p *Platform) RedeployFunction(ctx context.Context, redeployFunctionOptions *platform.RedeployFunctionOptions) error

RedeployFunction will redeploy a previously deployed function

func (*Platform) SaveFunctionDeployLogs 

func (p *Platform) SaveFunctionDeployLogs(ctx context.Context, functionName, namespace string) error

func (*Platform) UpdateAPIGateway 

func (p *Platform) UpdateAPIGateway(ctx context.Context, updateAPIGatewayOptions *platform.UpdateAPIGatewayOptions) error

UpdateAPIGateway will update a previously existing api gateway

func (*Platform) UpdateFunction 

func (p *Platform) UpdateFunction(ctx context.Context, updateFunctionOptions *platform.UpdateFunctionOptions) error

UpdateFunction will update a previously deployed function

func (*Platform) UpdateFunctionEvent 

func (p *Platform) UpdateFunctionEvent(ctx context.Context, updateFunctionEventOptions *platform.UpdateFunctionEventOptions) error

UpdateFunctionEvent will update a previously existing function event

func (*Platform) UpdateProject 

func (p *Platform) UpdateProject(ctx context.Context, updateProjectOptions *platform.UpdateProjectOptions) error

UpdateProject updates an existing project

func (*Platform) ValidateFunctionConfig 

func (p *Platform) ValidateFunctionConfig(ctx context.Context, functionConfig *functionconfig.Config) error

Source Files

View all Source files

Directories

Path Synopsis
apis
nuclio.io
nuclio.io/v1beta1
Package v1beta1 is the v1beta1 version of the API.
 Package v1beta1 is the v1beta1 version of the API.
clientset/mocks
clientset/versioned
This package has the automatically generated clientset.
 This package has the automatically generated clientset.
clientset/versioned/fake
This package has the automatically generated fake clientset.
 This package has the automatically generated fake clientset.
clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
 This package contains the scheme of the automatically generated clientset.
clientset/versioned/typed/nuclio.io/v1beta1
This package has the automatically generated typed clients.
 This package has the automatically generated typed clients.
clientset/versioned/typed/nuclio.io/v1beta1/fake
Package fake has the automatically generated clients.
 Package fake has the automatically generated clients.
informers/externalversions
informers/externalversions/internalinterfaces
informers/externalversions/nuclio.io
informers/externalversions/nuclio.io/v1beta1
listers/nuclio.io/v1beta1
test
kubectlclient

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.