components

Documentation

Index

• Constants
• func IsInitialVersion(version string) bool
• type Category
• type ComponentHandler
• type ComponentLoader
• type DiskManifestLoader
  • func NewDiskManifestLoader[T kubernetesManifest](path string, zeroValue func() T) DiskManifestLoader[T]
  • func (m DiskManifestLoader[T]) Load() ([]T, error)
• type KubernetesComponents
  • func NewKubernetesComponents(configuration config.KubernetesConfig, namespace string, ...) *KubernetesComponents
  • func (k *KubernetesComponents) LoadComponents() ([]componentsV1alpha1.Component, error)
• type ManifestLoader
• type StandaloneComponents
  • func NewStandaloneComponents(configuration config.StandaloneConfig) *StandaloneComponents
  • func (s *StandaloneComponents) LoadComponents() ([]componentsV1alpha1.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 Category

type Category string

const (
	CategoryBindings       Category = "bindings"
	CategoryPubSub         Category = "pubsub"
	CategorySecretStore    Category = "secretstores"
	CategoryStateStore     Category = "state"
	CategoryMiddleware     Category = "middleware"
	CategoryConfiguration  Category = "configuration"
	CategoryLock           Category = "lock"
	CategoryNameResolution Category = "nameresolution"
)

supported components category

type ComponentHandler

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

ComponentHandler is an interface for reacting on component changes.

type ComponentLoader

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

ComponentLoader is an interface for returning Dapr components.

type DiskManifestLoader

type DiskManifestLoader[T kubernetesManifest] struct {
	// contains filtered or unexported fields
}

manifestLoader loads a specific manifest kind from a folder.

func NewDiskManifestLoader

func NewDiskManifestLoader[T kubernetesManifest](path string, zeroValue func() T) DiskManifestLoader[T]

NewDiskManifestLoader creates a new manifest loader for the given path and kind.

func (DiskManifestLoader[T]) Load

func (m DiskManifestLoader[T]) Load() ([]T, error)

load loads manifests for the given directory.

type KubernetesComponents

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

KubernetesComponents loads components in a kubernetes environment.

func NewKubernetesComponents

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

NewKubernetesComponents returns a new kubernetes loader.

func (*KubernetesComponents) LoadComponents

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

LoadComponents returns components from a given control plane address.

type ManifestLoader

type ManifestLoader[T kubernetesManifest] interface {
	// Load loads all manifests.
	Load() ([]T, error)
}

ManifestLoader loads manifest-like files.

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() ([]componentsV1alpha1.Component, error)

LoadComponents loads dapr components from a given directory.