cmd

Documentation

Index

• Variables
• func CheckEndpointReady(endpoint *v1.Endpoints) error
• func CheckService(c *kubernetes.Clientset, ns string, serviceName string) error
• func Retry(attempts int, callback func() error) (err error)
• func RetryAfter(attempts int, callback func() error, d time.Duration) (err error)
• func RunCompletion(out io.Writer, cmd *cobra.Command, args []string) error
• type MultiError
  • func (m *MultiError) Collect(err error)
  • func (m MultiError) ToError() error

Variables

var RootCmd = &cobra.Command{
	Use:   "funktion",
	Short: "funktion is a Function as a Service (Lambda) style programming model for Kubernetes",
	Long: `Funktion lets you develop complex applications using Functions and then use Flows to bind those functions to any event source (over 200 event sources and connectors supported) and run and scale your functions on top of kubernetes.

For more documentation please see: https://funktion.fabric8.io/`,
	Run: func(cmd *cobra.Command, args []string) {
		if len(args) == 0 {
			cmd.Help()
		}
	},
}

Functions

func CheckEndpointReady

func CheckEndpointReady(endpoint *v1.Endpoints) error

CheckEndpointReady checks that the kubernetes endpoint is ready Credits: https://github.com/kubernetes/minikube/blob/v0.9.0/cmd/minikube/cmd/service.go#L101

func CheckService

func CheckService(c *kubernetes.Clientset, ns string, serviceName string) error

CheckService waits for the specified service to be ready by returning an error until the service is up The check is done by polling the endpoint associated with the service and when the endpoint exists, returning no error->service-online Credits: https://github.com/kubernetes/minikube/blob/v0.9.0/cmd/minikube/cmd/service.go#L89

func Retry

func Retry(attempts int, callback func() error) (err error)

func RetryAfter

func RetryAfter(attempts int, callback func() error, d time.Duration) (err error)

func RunCompletion

func RunCompletion(out io.Writer, cmd *cobra.Command, args []string) error

Types

type MultiError

type MultiError struct {
	Errors []error
}

func (*MultiError) Collect

func (m *MultiError) Collect(err error)

func (MultiError) ToError

func (m MultiError) ToError() error