httpendpoint

Documentation

Index

• func LoadLocalEndpoint(log logger.Logger, runtimeID string, paths ...string) []*httpEndpointV1alpha1.HTTPEndpoint
• type EndpointsLoader
• type HTTPEndpointHandler
• type KubernetesHTTPEndpoints
  • func NewKubernetesHTTPEndpoints(configuration config.KubernetesConfig, namespace string, ...) *KubernetesHTTPEndpoints
  • func (k *KubernetesHTTPEndpoints) LoadHTTPEndpoints() ([]httpEndpointsV1alpha1.HTTPEndpoint, error)
• type LocalHTTPEndpoints
  • func NewLocalHTTPEndpoints(resourcesPaths ...string) *LocalHTTPEndpoints
  • func (s *LocalHTTPEndpoints) LoadHTTPEndpoints() ([]httpEndpointsV1alpha1.HTTPEndpoint, error)
• type ManifestLoader

Functions

func LoadLocalEndpoint

func LoadLocalEndpoint(log logger.Logger, runtimeID string, paths ...string) []*httpEndpointV1alpha1.HTTPEndpoint

LoadLocalEndpoint loads endpoint configurations from local folders.

Types

type EndpointsLoader

type EndpointsLoader interface {
	LoadHTTPEndpoints() ([]httpEndpointsV1alpha1.HTTPEndpoint, error)
}

EndpointsLoader is an interface for returning Dapr HTTP endpoints.

type HTTPEndpointHandler

type HTTPEndpointHandler interface {
	OnHTTPEndpointUpdated(endpoint httpEndpointsV1alpha1.HTTPEndpoint)
}

HTTPEndpointHandler is an interface for reacting on HTTP endpoint changes.

type KubernetesHTTPEndpoints

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

KubernetesHTTPEndpoints loads http endpoints in a kubernetes environment.

func NewKubernetesHTTPEndpoints

func NewKubernetesHTTPEndpoints(configuration config.KubernetesConfig, namespace string, operatorClient operatorv1pb.OperatorClient, podName string) *KubernetesHTTPEndpoints

NewKubernetesHTTPEndpoints returns a new kubernetes loader.

func (*KubernetesHTTPEndpoints) LoadHTTPEndpoints

func (k *KubernetesHTTPEndpoints) LoadHTTPEndpoints() ([]httpEndpointsV1alpha1.HTTPEndpoint, error)

LoadHTTPEndpoints returns HTTP endpoints from a given control plane address.

type LocalHTTPEndpoints

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

LocalHTTPEndpoints loads http endpoints from a given directory.

func NewLocalHTTPEndpoints

func NewLocalHTTPEndpoints(resourcesPaths ...string) *LocalHTTPEndpoints

NewLocalHTTPEndpoints returns a new LocalHTTPEndpoint.

func (*LocalHTTPEndpoints) LoadHTTPEndpoints

func (s *LocalHTTPEndpoints) LoadHTTPEndpoints() ([]httpEndpointsV1alpha1.HTTPEndpoint, error)

LocalHTTPEndpoints loads dapr http endpoints from a given directory.

type ManifestLoader

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

ManifestLoader loads manifest-like files.