function

Documentation

Index

• func ApplyFunction(ctx context.Context, links string, config *rest.Config, ...) error
• func CheckHealthStatus(status []condition.Condition) bool
• func DeleteFunction(ctx context.Context, urls string, dynamicClient *dynamic.DynamicClient, ...) error
• func GetFunction(ctx context.Context, logger *zap.SugaredLogger, ...) ([]unstructured.Unstructured, error)
• func GetFunctions(ctx context.Context, dynamicClient dynamic.Interface) []crossv1.Function
• func HealthCheck(ctx context.Context, dc dynamic.Interface, links string, wait bool, ...) error
• func ResourceId() schema.GroupVersionResource
• func Serve(ctx context.Context, dc *dynamic.DynamicClient, config *rest.Config, ...) error
• type Function
  • func New(name string) *Function
  • func (c *Function) Apply(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger) error
  • func (c *Function) LoadDirectory(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, ...) error
  • func (c *Function) LoadStdinArchive(stream *bufio.Reader) error
  • func (c *Function) UpgradeFunction(ctx context.Context, config *rest.Config, dc *dynamic.DynamicClient) error

Functions

func ApplyFunction

func ApplyFunction(ctx context.Context, links string, config *rest.Config, logger *zap.SugaredLogger) error

func CheckHealthStatus

func CheckHealthStatus(status []condition.Condition) bool

func DeleteFunction

func DeleteFunction(ctx context.Context, urls string, dynamicClient *dynamic.DynamicClient, logger *zap.SugaredLogger) error

func GetFunction

func GetFunction(ctx context.Context, logger *zap.SugaredLogger, sourceDynamicClient dynamic.Interface, paramsFunction kube.ResourceParams) ([]unstructured.Unstructured, error)

func GetFunctions

func GetFunctions(ctx context.Context, dynamicClient dynamic.Interface) []crossv1.Function

func HealthCheck

func HealthCheck(ctx context.Context, dc dynamic.Interface, links string, wait bool, timeoutChan <-chan time.Time, logger *zap.SugaredLogger) error

RunFunctionHealthCheck performs a health check on functions defined by the links string.

func ResourceId

func ResourceId() schema.GroupVersionResource

func Serve

func Serve(ctx context.Context, dc *dynamic.DynamicClient, config *rest.Config, logger *zap.SugaredLogger, path string) error

Types

type Function

type Function struct {
	Name  string
	Image image.Image
	packages.Package
}

func New

func New(name string) *Function

func (*Function) Apply

func (c *Function) Apply(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger) error

func (*Function) LoadDirectory

func (c *Function) LoadDirectory(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, path string) error

Load function package from directory

func (*Function) LoadStdinArchive

func (c *Function) LoadStdinArchive(stream *bufio.Reader) error

Load function package from STDIN

func (*Function) UpgradeFunction

func (c *Function) UpgradeFunction(ctx context.Context, config *rest.Config, dc *dynamic.DynamicClient) error