kubernetes

Documentation

Index

• func Client() (*k8s.Clientset, error)
• func DaprClient() (scheme.Interface, error)
• func GetDefaultConfiguration() v1alpha1.Configuration
• func Init(version string) error
• func IsMTLSEnabled() (bool, error)
• func ListPods(client *k8s.Clientset, namespace string, labelSelector map[string]string) (*core_v1.PodList, error)
• func Logs(appID, podName, namespace string) error
• func Uninstall() error
• type ComponentsOutput
  • func Components() ([]ComponentsOutput, error)
• type ConfigurtionsOutput
  • func Configurations() ([]ConfigurtionsOutput, error)
• type ListOutput
  • func List() ([]ListOutput, error)
• type RunConfig
• type RunOutput
  • func Run(config *RunConfig) (*RunOutput, error)
• type StatusOutput
  • func Status() ([]StatusOutput, error)

Functions

func Client

func Client() (*k8s.Clientset, error)

Client returns a new Kubernetes client.

func DaprClient

func DaprClient() (scheme.Interface, error)

DaprClient returns a new Kubernetes Dapr client

func GetDefaultConfiguration

func GetDefaultConfiguration() v1alpha1.Configuration

func Init

func Init(version string) error

Init deploys the Dapr operator using the supplied runtime version.

func IsMTLSEnabled

func IsMTLSEnabled() (bool, error)

func ListPods

func ListPods(client *k8s.Clientset, namespace string, labelSelector map[string]string) (*core_v1.PodList, error)

func Logs

func Logs(appID, podName, namespace string) error

Logs fetches Dapr sidecar logs from Kubernetes.

func Uninstall

func Uninstall() error

Uninstall removes Dapr

Types

type ComponentsOutput

type ComponentsOutput struct {
	Name    string `csv:"Name"`
	Type    string `csv:"Type"`
	Age     string `csv:"AGE"`
	Created string `csv:"CREATED"`
}

ComponentsOutput represent a Dapr component.

func Components

func Components() ([]ComponentsOutput, error)

List outputs all Dapr components.

type ConfigurtionsOutput

type ConfigurtionsOutput struct {
	Name            string `csv:"Name"`
	TracingEnabled  bool   `csv:"TRACING-ENABLED"`
	MTLSEnabled     bool   `csv:"MTLS-ENABLED"`
	WorkloadCertTTL string `csv:"MTLS-WORKLOAD-TTL"`
	ClockSkew       string `csv:"MTLS-CLOCK-SKEW"`
	Age             string `csv:"AGE"`
	Created         string `csv:"CREATED"`
}

ComponentsOutput represent a Dapr component.

func Configurations

func Configurations() ([]ConfigurtionsOutput, error)

List outputs all Dapr configurations.

type ListOutput

type ListOutput struct {
	AppID   string `csv:"APP ID"`
	AppPort string `csv:"APP PORT"`
	Age     string `csv:"AGE"`
	Created string `csv:"CREATED"`
}

ListOutput represents the application ID, application port and creation time.

func List

func List() ([]ListOutput, error)

List outputs all the applications.

type RunConfig

type RunConfig struct {
	AppID         string
	AppPort       int
	HTTPPort      int
	GRPCPort      int
	CodeDirectory string
	Arguments     []string
	Image         string
}

RunConfig represents the application configuration parameters.

type RunOutput

type RunOutput struct {
	Message string
}

RunOutput represents the run output.

func Run

func Run(config *RunConfig) (*RunOutput, error)

Run executes the application based on the run configuration.

type StatusOutput

type StatusOutput struct {
	Name      string `csv:"NAME"`
	Namespace string `csv:"NAMESPACE"`
	Healthy   string `csv:"HEALTHY"`
	Status    string `csv:"STATUS"`
	Version   string `csv:"VERSION"`
	Age       string `csv:"AGE"`
	Created   string `csv:"CREATED"`
}

StatusOutput represents the status of a named Dapr resource.

func Status

func Status() ([]StatusOutput, error)

List status for Dapr resources.