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
• type Function
  • func (c *Function) LoadStdinArchive(stream *bufio.Reader) 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

Types

type Function

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

func (*Function) LoadStdinArchive

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

Load function package from STDIN