core

Documentation

Overview

package core contains a high level client for interacting with knative primitives used to realise, amongst other things, riff functions. The client typically returns structs for kubernetes resources, as they would have been written "by hand" to be applied by kubectl. It is not the role of the client to deal with printing, formatting or command line parsing.

Index

• func ParseEnvVar(envVars []string) ([]v1.EnvVar, error)
• func ParseEnvVarSource(envVarsFrom []string) ([]v1.EnvVar, error)
• type Client
  • func NewClient(clientConfig clientcmd.ClientConfig, kubeClient kubernetes.Interface, ...) Client
• type CreateChannelOptions
• type CreateFunctionOptions
• type CreateServiceOptions
• type CreateSubscriptionOptions
• type DeleteChannelOptions
• type DeleteServiceOptions
• type KubectlClient
  • func NewKubectlClient(kubeClient kubernetes.Interface) KubectlClient
• type ListChannelOptions
• type ListServiceOptions
• type NamespaceInitOptions
• type Namespaced
• type ServiceInvokeOptions
• type ServiceStatusOptions
• type SystemInstallOptions
• type SystemUninstallOptions

Functions

func ParseEnvVar

func ParseEnvVar(envVars []string) ([]v1.EnvVar, error)

func ParseEnvVarSource

func ParseEnvVarSource(envVarsFrom []string) ([]v1.EnvVar, error)

Types

type Client

type Client interface {
	CreateFunction(options CreateFunctionOptions) (*serving.Service, error)

	CreateSubscription(options CreateSubscriptionOptions) (*eventing.Subscription, error)

	ListChannels(options ListChannelOptions) (*eventing.ChannelList, error)
	CreateChannel(options CreateChannelOptions) (*eventing.Channel, error)
	DeleteChannel(options DeleteChannelOptions) error

	ListServices(options ListServiceOptions) (*serving.ServiceList, error)
	CreateService(options CreateServiceOptions) (*serving.Service, error)
	DeleteService(options DeleteServiceOptions) error
	ServiceStatus(options ServiceStatusOptions) (*v1alpha1.ServiceCondition, error)
	ServiceCoordinates(options ServiceInvokeOptions) (ingressIP string, hostName string, err error)
}

func NewClient

func NewClient(clientConfig clientcmd.ClientConfig, kubeClient kubernetes.Interface, eventing eventing_cs.Interface, serving serving_cs.Interface) Client

type CreateChannelOptions

type CreateChannelOptions struct {
	Namespaced
	Name       string
	Bus        string
	ClusterBus string
	DryRun     bool
}

type CreateFunctionOptions

type CreateFunctionOptions struct {
	CreateServiceOptions

	GitRepo     string
	GitRevision string

	InvokerURL string
	Handler    string
	Artifact   string
}

type CreateServiceOptions

type CreateServiceOptions struct {
	Namespaced
	Name string

	Image string

	Env     []string
	EnvFrom []string

	DryRun bool
}

type CreateSubscriptionOptions

type CreateSubscriptionOptions struct {
	Namespaced
	Name       string
	Channel    string
	Subscriber string
	DryRun     bool
}

type DeleteChannelOptions

type DeleteChannelOptions struct {
	Namespaced
	Name string
}

type DeleteServiceOptions

type DeleteServiceOptions struct {
	Namespaced
	Name string
}

type KubectlClient

type KubectlClient interface {
	SystemInstall(options SystemInstallOptions) (bool, error)
	SystemUninstall(options SystemUninstallOptions) (bool, error)
	NamespaceInit(options NamespaceInitOptions) error
}

func NewKubectlClient

func NewKubectlClient(kubeClient kubernetes.Interface) KubectlClient

type ListChannelOptions

type ListChannelOptions struct {
	Namespaced
}

type ListServiceOptions

type ListServiceOptions struct {
	Namespaced
}

type NamespaceInitOptions

type NamespaceInitOptions struct {
	NamespaceName string
	SecretName    string
}

type Namespaced

type Namespaced struct {
	Namespace string
}

type ServiceInvokeOptions

type ServiceInvokeOptions struct {
	Namespaced
	Name string
}

type ServiceStatusOptions

type ServiceStatusOptions struct {
	Namespaced
	Name string
}

type SystemInstallOptions

type SystemInstallOptions struct {
	NodePort bool
	Force    bool
}

type SystemUninstallOptions

type SystemUninstallOptions struct {
	Istio bool
	Force bool
}