components

Documentation

Index

• Constants
• func IsInitialVersion(version string) bool
• 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)

Constants

const (
	// Unstable version (v0)
	UnstableVersion = "v0"

	// First stable version (v1)
	FirstStableVersion = "v1"
)

Functions

func IsInitialVersion

func IsInitialVersion(version string) bool

IsInitialVersion returns true when a version is considered an unstable version (v0) or first stable version (v1). For backward compatibility, empty strings are also included.

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