Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetStatusCodeFromMetadata ¶
GetStatusCodeFromMetadata extracts the http status code from the metadata if it exists
Types ¶
type API ¶
type API interface {
APIEndpoints() []Endpoint
MarkStatusAsReady()
SetAppChannel(appChannel channel.AppChannel)
SetDirectMessaging(directMessaging messaging.DirectMessaging)
SetActorRuntime(actor actors.Actors)
}
API returns a list of HTTP endpoints for Dapr
func NewAPI ¶
func NewAPI( appID string, appChannel channel.AppChannel, directMessaging messaging.DirectMessaging, getComponentsFn func() []components_v1alpha1.Component, stateStores map[string]state.Store, secretStores map[string]secretstores.SecretStore, secretsConfiguration map[string]config.SecretsScope, pubsubAdapter runtime_pubsub.Adapter, actor actors.Actors, sendToOutputBindingFn func(name string, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error), tracingSpec config.TracingSpec, shutdown func()) API
NewAPI returns a new API
type BulkGetRequest ¶
type BulkGetRequest struct {
Metadata map[string]string `json:"metadata"`
Keys []string `json:"keys"`
Parallelism int `json:"parallelism"`
}
BulkGetRequest is the request object to get a list of values for multiple keys from a state store
type BulkGetResponse ¶
type BulkGetResponse struct {
Key string `json:"key"`
Data jsoniter.RawMessage `json:"data,omitempty"`
ETag *string `json:"etag,omitempty"`
Error string `json:"error,omitempty"`
}
BulkGetResponse is the response object for a state bulk get operation
type Endpoint ¶
type Endpoint struct {
Methods []string
Route string
Version string
Handler fasthttp.RequestHandler
}
Endpoint is a collection of route information for an Dapr API
type ErrorResponse ¶
ErrorResponse is an HTTP response message sent back to calling clients by the Dapr Runtime HTTP API
func NewErrorResponse ¶
func NewErrorResponse(errorCode, message string) ErrorResponse
NewErrorResponse returns a new ErrorResponse
type OutputBindingRequest ¶
type OutputBindingRequest struct {
Metadata map[string]string `json:"metadata"`
Data interface{} `json:"data"`
Operation string `json:"operation"`
}
OutputBindingRequest is the request object to invoke an output binding
type Server ¶
type Server interface {
StartNonBlocking()
}
Server is an interface for the Dapr HTTP server
func NewServer ¶
func NewServer(api API, config ServerConfig, tracingSpec config.TracingSpec, metricSpec config.MetricSpec, pipeline http_middleware.Pipeline) Server
NewServer returns a new HTTP server
type ServerConfig ¶
type ServerConfig struct {
AllowedOrigins string
AppID string
HostAddress string
Port int
ProfilePort int
EnableProfiling bool
MaxRequestBodySize int
}
ServerConfig holds config values for an HTTP server
func NewServerConfig ¶
func NewServerConfig(appID string, hostAddress string, port int, profilePort int, allowedOrigins string, enableProfiling bool, maxRequestBodySize int) ServerConfig
NewServerConfig returns a new HTTP server config
Source Files