components

Documentation

Index

• type ComponentHandler
• type ComponentLoader
• type KubernetesComponents
  • func NewKubernetesComponents(configuration config.KubernetesConfig, ...) *KubernetesComponents
  • func (k *KubernetesComponents) LoadComponents() ([]components_v1alpha1.Component, error)
• type StandaloneComponents
  • func NewStandaloneComponents(configuration config.StandaloneConfig) *StandaloneComponents
  • func (s *StandaloneComponents) LoadComponents() ([]components_v1alpha1.Component, error)

Types

type ComponentHandler

type ComponentHandler interface {
	OnComponentUpdated(component components_v1alpha1.Component)
}

ComponentHandler is an interface for reacting on component changes

type ComponentLoader

type ComponentLoader interface {
	LoadComponents() ([]components_v1alpha1.Component, error)
}

ComponentLoader is an interface for returning Dapr components

type KubernetesComponents

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

KubernetesComponents loads components in a kubernetes environment

func NewKubernetesComponents

func NewKubernetesComponents(configuration config.KubernetesConfig, operatorClient operatorv1pb.OperatorClient) *KubernetesComponents

NewKubernetesComponents returns a new kubernetes loader

func (*KubernetesComponents) LoadComponents

func (k *KubernetesComponents) LoadComponents() ([]components_v1alpha1.Component, error)

LoadComponents returns components from a given control plane address

type StandaloneComponents

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

StandaloneComponents loads components in a standalone mode environment

func NewStandaloneComponents

func NewStandaloneComponents(configuration config.StandaloneConfig) *StandaloneComponents

NewStandaloneComponents returns a new standalone loader

func (*StandaloneComponents) LoadComponents

func (s *StandaloneComponents) LoadComponents() ([]components_v1alpha1.Component, error)

LoadComponents loads dapr components from a given directory