runtime

Documentation

Index

• Constants
• type Config
  • func NewRuntimeConfig(...) *Config
• type DaprRuntime
  • func FromFlags() (*DaprRuntime, error)
  • func NewDaprRuntime(runtimeConfig *Config, globalConfig *config.Configuration) *DaprRuntime
  • func (a *DaprRuntime) Publish(req *pubsub.PublishRequest) error
  • func (a *DaprRuntime) Run(opts ...Option) error
  • func (a *DaprRuntime) Stop()
• type Option
  • func WithExporters(exporters ...exporters.Exporter) Option
  • func WithHTTPMiddleware(httpMiddleware ...http.Middleware) Option
  • func WithInputBindings(inputBindings ...bindings.InputBinding) Option
  • func WithOutputBindings(outputBindings ...bindings.OutputBinding) Option
  • func WithPubSubs(pubsubs ...pubsub.PubSub) Option
  • func WithSecretStores(secretStores ...secretstores.SecretStore) Option
  • func WithServiceDiscovery(serviceDiscoveries ...servicediscovery.ServiceDiscovery) Option
  • func WithStates(states ...state.State) Option
• type Protocol

Constants

const (
	// GRPCProtocol is a gRPC communication protocol
	GRPCProtocol Protocol = "grpc"
	// HTTPProtocol is a HTTP communication protocol
	HTTPProtocol Protocol = "http"
	// DefaultDaprHTTPPort is the default http port for Dapr
	DefaultDaprHTTPPort = 3500
	// DefaultDaprAPIGRPCPort is the default API gRPC port for Dapr
	DefaultDaprAPIGRPCPort = 50001
	// DefaultProfilePort is the default port for profiling endpoints
	DefaultProfilePort = 7777
	// DefaultMetricsPort is the default port for metrics endpoints
	DefaultMetricsPort = 9090
	// DefaultAllowedOrigins is the default origins allowed for the Dapr HTTP servers
	DefaultAllowedOrigins = "*"
)

Types

type Config

type Config struct {
	ID                      string
	HTTPPort                int
	ProfilePort             int
	EnableProfiling         bool
	APIGRPCPort             int
	InternalGRPCPort        int
	ApplicationPort         int
	ApplicationProtocol     Protocol
	Mode                    modes.DaprMode
	PlacementServiceAddress string
	GlobalConfig            string
	AllowedOrigins          string
	Standalone              config.StandaloneConfig
	Kubernetes              config.KubernetesConfig
	MaxConcurrency          int

	SentryServiceAddress string
	CertChain            *credentials.CertChain
	// contains filtered or unexported fields
}

Config holds the Dapr Runtime configuration

func NewRuntimeConfig

func NewRuntimeConfig(id, placementServiceAddress, controlPlaneAddress, allowedOrigins, globalConfig, componentsPath, appProtocol, mode string, httpPort, internalGRPCPort, apiGRPCPort, appPort, profilePort int, enableProfiling bool, maxConcurrency int, mtlsEnabled bool, sentryAddress string) *Config

NewRuntimeConfig returns a new runtime config

type DaprRuntime

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

DaprRuntime holds all the core components of the runtime

func FromFlags

func FromFlags() (*DaprRuntime, error)

FromFlags parses command flags and returns DaprRuntime instance

func NewDaprRuntime

func NewDaprRuntime(runtimeConfig *Config, globalConfig *config.Configuration) *DaprRuntime

NewDaprRuntime returns a new runtime with the given runtime config and global config

func (*DaprRuntime) Publish

func (a *DaprRuntime) Publish(req *pubsub.PublishRequest) error

Publish is an adapter method for the runtime to pre-validate publish requests And then forward them to the Pub/Sub component. This method is used by the HTTP and gRPC APIs.

func (*DaprRuntime) Run

func (a *DaprRuntime) Run(opts ...Option) error

Run performs initialization of the runtime with the runtime and global configurations

func (*DaprRuntime) Stop

func (a *DaprRuntime) Stop()

Stop allows for a graceful shutdown of all runtime internal operations or components

type Option

type Option func(o *runtimeOpts)

Option is a function that customizes the runtime.

func WithExporters

func WithExporters(exporters ...exporters.Exporter) Option

WithExporters adds exporter components to the runtime.

func WithHTTPMiddleware

func WithHTTPMiddleware(httpMiddleware ...http.Middleware) Option

WithHTTPMiddleware adds HTTP middleware components to the runtime.

func WithInputBindings

func WithInputBindings(inputBindings ...bindings.InputBinding) Option

WithInputBindings adds input binding components to the runtime.

func WithOutputBindings

func WithOutputBindings(outputBindings ...bindings.OutputBinding) Option

WithOutputBindings adds output binding components to the runtime.

func WithPubSubs

func WithPubSubs(pubsubs ...pubsub.PubSub) Option

WithPubSubs adds pubsub store components to the runtime.

func WithSecretStores

func WithSecretStores(secretStores ...secretstores.SecretStore) Option

WithSecretStores adds secret store components to the runtime.

func WithServiceDiscovery

func WithServiceDiscovery(serviceDiscoveries ...servicediscovery.ServiceDiscovery) Option

WithServiceDiscovery adds service discovery components to the runtime.

func WithStates

func WithStates(states ...state.State) Option

WithStates adds state store components to the runtime.

type Protocol

type Protocol string

Protocol is a communications protocol