client

package

v0.0.0-...-b4f4e10 Latest Latest Go to latest Published: May 1, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/nuclio/nuclio

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetDomainNameInvokeURL(serviceName, namespace string) (string, int)
func NuclioioToFunctionConfig(nuclioioFunction *nuclioio.NuclioFunction) *functionconfig.Config
type Consumer
- func NewConsumer(ctx context.Context, logger logger.Logger, kubeconfigPath string) (*Consumer, error)
type Deleter
- func NewDeleter(parentLogger logger.Logger, platform platform.Platform) (*Deleter, error)
- func (d *Deleter) Delete(ctx context.Context, consumer *Consumer, ...) error
type Deployer
- func NewDeployer(parentLogger logger.Logger, consumer *Consumer, platform platform.Platform) (*Deployer, error)
- func (d *Deployer) CreateOrUpdateFunction(ctx context.Context, functionInstance *nuclioio.NuclioFunction, ...) (*nuclioio.NuclioFunction, error)
- func (d *Deployer) Deploy(ctx context.Context, functionInstance *nuclioio.NuclioFunction, ...) (*platform.CreateFunctionResult, *nuclioio.NuclioFunction, string, error)
type Function
- func NewFunction(parentLogger logger.Logger, parentPlatform platform.Platform, ...) (*Function, error)
- func (f *Function) GetConfig() *functionconfig.Config
- func (f *Function) GetReplicas() (int, int)
- func (f *Function) Initialize(ctx context.Context, str []string) error
type Getter
- func NewGetter(parentLogger logger.Logger, platform platform.Platform) (*Getter, error)
- func (g *Getter) Get(ctx context.Context, consumer *Consumer, ...) ([]platform.Function, error)
type Updater
- func NewUpdater(parentLogger logger.Logger, consumer *Consumer, platform platform.Platform) (*Updater, error)
- func (u *Updater) Update(ctx context.Context, updateFunctionOptions *platform.UpdateFunctionOptions) error
- func (u *Updater) UpdateState(ctx context.Context, functionName, namespace string, ...) error

Constants ¶

View Source

const FunctionContainerName = "nuclio"

View Source

const MaxLogLines = 100

Variables ¶

This section is empty.

Functions ¶

func GetDomainNameInvokeURL ¶

func GetDomainNameInvokeURL(serviceName, namespace string) (string, int)

func NuclioioToFunctionConfig ¶

func NuclioioToFunctionConfig(nuclioioFunction *nuclioio.NuclioFunction) *functionconfig.Config

Types ¶

type Consumer ¶

type Consumer struct {
	NuclioClientSet nuclioioclient.Interface
	KubeClientSet   kubernetes.Interface
	KubeHost        string
	// contains filtered or unexported fields
}

func NewConsumer ¶

func NewConsumer(ctx context.Context, logger logger.Logger, kubeconfigPath string) (*Consumer, error)

type Deleter ¶

type Deleter struct {
	// contains filtered or unexported fields
}

func NewDeleter ¶

func NewDeleter(parentLogger logger.Logger, platform platform.Platform) (*Deleter, error)

func (*Deleter) Delete ¶

func (d *Deleter) Delete(ctx context.Context, consumer *Consumer, deleteFunctionOptions *platform.DeleteFunctionOptions) error

type Deployer ¶

type Deployer struct {
	// contains filtered or unexported fields
}

func NewDeployer ¶

func NewDeployer(parentLogger logger.Logger, consumer *Consumer, platform platform.Platform) (*Deployer, error)

func (*Deployer) CreateOrUpdateFunction ¶

func (d *Deployer) CreateOrUpdateFunction(ctx context.Context,
	functionInstance *nuclioio.NuclioFunction,
	createFunctionOptions *platform.CreateFunctionOptions,
	functionStatus *functionconfig.Status) (*nuclioio.NuclioFunction, error)

func (*Deployer) Deploy ¶

func (d *Deployer) Deploy(ctx context.Context,
	functionInstance *nuclioio.NuclioFunction,
	createFunctionOptions *platform.CreateFunctionOptions) (*platform.CreateFunctionResult, *nuclioio.NuclioFunction, string, error)

type Function ¶

type Function struct {
	platform.AbstractFunction
	// contains filtered or unexported fields
}

func NewFunction ¶

func NewFunction(parentLogger logger.Logger,
	parentPlatform platform.Platform,
	nuclioioFunction *nuclioio.NuclioFunction,
	consumer *Consumer) (*Function, error)

func (*Function) GetConfig ¶

func (f *Function) GetConfig() *functionconfig.Config

func (*Function) GetReplicas ¶

func (f *Function) GetReplicas() (int, int)

GetReplicas returns the current # of replicas and the configured # of replicas

func (*Function) Initialize ¶

func (f *Function) Initialize(ctx context.Context, str []string) error

Initialize loads sub-resources so we can populate our configuration

type Getter ¶

type Getter struct {
	// contains filtered or unexported fields
}

func NewGetter ¶

func NewGetter(parentLogger logger.Logger, platform platform.Platform) (*Getter, error)

func (*Getter) Get ¶

func (g *Getter) Get(ctx context.Context,
	consumer *Consumer,
	getFunctionsOptions *platform.GetFunctionsOptions) ([]platform.Function, error)

type Updater ¶

type Updater struct {
	// contains filtered or unexported fields
}

func NewUpdater ¶

func NewUpdater(parentLogger logger.Logger, consumer *Consumer, platform platform.Platform) (*Updater, error)

func (*Updater) Update ¶

func (u *Updater) Update(ctx context.Context, updateFunctionOptions *platform.UpdateFunctionOptions) error

func (*Updater) UpdateState ¶

func (u *Updater) UpdateState(ctx context.Context, functionName, namespace string, authConfig *platform.AuthConfig, state functionconfig.FunctionState) error

UpdateState will update a function CRD state we don't require permissions for this operation because it's used internally by the platform

Source Files ¶

View all Source files

Directories ¶

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

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