Documentation
¶
Index ¶
- Constants
- type ComponentCategory
- type Config
- type DaprRuntime
- type Option
- func WithHTTPMiddleware(httpMiddleware ...http.Middleware) Option
- func WithInputBindings(inputBindings ...bindings.InputBinding) Option
- func WithNameResolutions(nameResolutions ...nameresolution.NameResolution) Option
- func WithOutputBindings(outputBindings ...bindings.OutputBinding) Option
- func WithPubSubs(pubsubs ...pubsub.PubSub) Option
- func WithSecretStores(secretStores ...secretstores.SecretStore) Option
- func WithStates(states ...state.State) Option
- type Protocol
- type Route
- type TopicRoute
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 // DefaultMaxRequestBodySize is the default option for the maximum body size in MB for Dapr HTTP servers DefaultMaxRequestBodySize = 4 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ComponentCategory ¶
type ComponentCategory string
type Config ¶
type Config struct {
ID string
HTTPPort int
ProfilePort int
EnableProfiling bool
APIGRPCPort int
InternalGRPCPort int
ApplicationPort int
ApplicationProtocol Protocol
Mode modes.DaprMode
PlacementAddresses []string
GlobalConfig string
AllowedOrigins string
Standalone config.StandaloneConfig
Kubernetes config.KubernetesConfig
MaxConcurrency int
SentryServiceAddress string
CertChain *credentials.CertChain
AppSSL bool
MaxRequestBodySize int
// contains filtered or unexported fields
}
Config holds the Dapr Runtime configuration
func NewRuntimeConfig ¶
func NewRuntimeConfig( id string, placementAddresses []string, controlPlaneAddress, allowedOrigins, globalConfig, componentsPath, appProtocol, mode string, httpPort, internalGRPCPort, apiGRPCPort, appPort, profilePort int, enableProfiling bool, maxConcurrency int, mtlsEnabled bool, sentryAddress string, appSSL bool, maxRequestBodySize int) *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, accessControlList *config.AccessControlList) *DaprRuntime
NewDaprRuntime returns a new runtime with the given runtime config and global config
func (*DaprRuntime) GetPubSub ¶
func (a *DaprRuntime) GetPubSub(pubsubName string) pubsub.PubSub
GetPubSub is an adapter method to find a pubsub by name
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) ShutdownWithWait ¶
func (a *DaprRuntime) ShutdownWithWait()
ShutdownWithWait will gracefully stop runtime and wait outstanding operations
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 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 WithNameResolutions ¶
func WithNameResolutions(nameResolutions ...nameresolution.NameResolution) Option
WithNameResolutions adds name resolution components to the runtime.
func WithOutputBindings ¶
func WithOutputBindings(outputBindings ...bindings.OutputBinding) Option
WithOutputBindings adds output binding components to the runtime.
func WithPubSubs ¶
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 WithStates ¶
WithStates adds state store components to the runtime.
type TopicRoute ¶
type TopicRoute struct {
// contains filtered or unexported fields
}
Source Files
Directories