handlers

Documentation

Index

• Constants
• func ListFunctions(client *containerd.Client) (map[string]Function, error)
• func MakeDeleteHandler(client *containerd.Client, cni gocni.CNI) func(w http.ResponseWriter, r *http.Request)
• func MakeDeployHandler(client *containerd.Client, cni gocni.CNI, secretMountPath string, ...) func(w http.ResponseWriter, r *http.Request)
• func MakeInfoHandler(version, sha string) http.HandlerFunc
• func MakeReadHandler(client *containerd.Client) func(w http.ResponseWriter, r *http.Request)
• func MakeReplicaReaderHandler(client *containerd.Client) func(w http.ResponseWriter, r *http.Request)
• func MakeReplicaUpdateHandler(client *containerd.Client, cni gocni.CNI) func(w http.ResponseWriter, r *http.Request)
• func MakeSecretHandler(c *containerd.Client, mountPath string) func(w http.ResponseWriter, r *http.Request)
• func MakeUpdateHandler(client *containerd.Client, cni gocni.CNI, secretMountPath string, ...) func(w http.ResponseWriter, r *http.Request)
• type Function
  • func GetFunction(client *containerd.Client, name string) (Function, error)
• type InvokeResolver
  • func NewInvokeResolver(client *containerd.Client) *InvokeResolver
  • func (i *InvokeResolver) Resolve(functionName string) (url.URL, error)

Constants

const (
	// OrchestrationIdentifier identifier string for provider orchestration
	OrchestrationIdentifier = "containerd"

	// ProviderName name of the provider
	ProviderName = "faasd"
)

Functions

func ListFunctions

func ListFunctions(client *containerd.Client) (map[string]Function, error)

ListFunctions returns a map of all functions with running tasks on namespace

func MakeDeleteHandler

func MakeDeleteHandler(client *containerd.Client, cni gocni.CNI) func(w http.ResponseWriter, r *http.Request)

func MakeDeployHandler

func MakeDeployHandler(client *containerd.Client, cni gocni.CNI, secretMountPath string, alwaysPull bool) func(w http.ResponseWriter, r *http.Request)

func MakeInfoHandler

func MakeInfoHandler(version, sha string) http.HandlerFunc

MakeInfoHandler creates handler for /system/info endpoint

func MakeReadHandler

func MakeReadHandler(client *containerd.Client) func(w http.ResponseWriter, r *http.Request)

func MakeReplicaReaderHandler

func MakeReplicaReaderHandler(client *containerd.Client) func(w http.ResponseWriter, r *http.Request)

func MakeReplicaUpdateHandler

func MakeReplicaUpdateHandler(client *containerd.Client, cni gocni.CNI) func(w http.ResponseWriter, r *http.Request)

func MakeSecretHandler

func MakeSecretHandler(c *containerd.Client, mountPath string) func(w http.ResponseWriter, r *http.Request)

func MakeUpdateHandler

func MakeUpdateHandler(client *containerd.Client, cni gocni.CNI, secretMountPath string, alwaysPull bool) func(w http.ResponseWriter, r *http.Request)

Types

type Function

type Function struct {
	IP string
	// contains filtered or unexported fields
}

func GetFunction

func GetFunction(client *containerd.Client, name string) (Function, error)

GetFunction returns a function that matches name

type InvokeResolver

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

func NewInvokeResolver

func NewInvokeResolver(client *containerd.Client) *InvokeResolver

func (*InvokeResolver) Resolve

func (i *InvokeResolver) Resolve(functionName string) (url.URL, error)