components

Documentation

Index

• Constants
• func IsInitialVersion(version string) bool
• type Category
• type ComponentHandler
• type ComponentLoader
• type DiskManifestLoader
  • func NewDiskManifestLoader[T kubernetesManifest](paths ...string) DiskManifestLoader[T]
  • func (m DiskManifestLoader[T]) Load() ([]T, error)
  • func (m *DiskManifestLoader[T]) SetZeroValueFn(zvFn func() T)
• type KubernetesComponents
  • func NewKubernetesComponents(configuration config.KubernetesConfig, namespace string, ...) *KubernetesComponents
  • func (k *KubernetesComponents) LoadComponents() ([]componentsV1alpha1.Component, error)
• type LocalComponents
  • func NewLocalComponents(resourcesPaths ...string) *LocalComponents
  • func (s *LocalComponents) LoadComponents() ([]componentsV1alpha1.Component, error)
• type ManifestLoader

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"
	CategoryWorkflow       Category = "workflow"
	CategoryMiddleware     Category = "middleware"
	CategoryConfiguration  Category = "configuration"
	CategoryCryptoProvider Category = "crypto"
	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](paths ...string) DiskManifestLoader[T]

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

func (DiskManifestLoader[T]) Load

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

load loads manifests for the given directory.

func (*DiskManifestLoader[T]) SetZeroValueFn

func (m *DiskManifestLoader[T]) SetZeroValueFn(zvFn func() T)

SetZeroValueFn sets the function that returns the "zero" object of the given type. This can be used to set default values before unmarshalling.

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 LocalComponents

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

LocalComponents loads components from a given directory.

func NewLocalComponents

func NewLocalComponents(resourcesPaths ...string) *LocalComponents

NewLocalComponents returns a new LocalComponents.

func (*LocalComponents) LoadComponents

func (s *LocalComponents) LoadComponents() ([]componentsV1alpha1.Component, error)

LoadComponents loads dapr components from a given directory.

type ManifestLoader

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

ManifestLoader loads manifest-like files.