http

Documentation

Index

• func GetStatusCodeFromMetadata(metadata map[string]string) int
• type API
  • func NewAPI(appID string, appChannel channel.AppChannel, ...) API
• type BulkGetRequest
• type BulkGetResponse
• type Endpoint
• type ErrorResponse
  • func NewErrorResponse(errorCode, message string) ErrorResponse
• type OutputBindingRequest
• type Server
  • func NewServer(api API, config ServerConfig, tracingSpec config.TracingSpec, ...) Server
• type ServerConfig
  • func NewServerConfig(appID string, hostAddress string, port int, profilePort int, ...) ServerConfig

Functions

func GetStatusCodeFromMetadata

func GetStatusCodeFromMetadata(metadata map[string]string) int

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

type ErrorResponse struct {
	ErrorCode string `json:"errorCode"`
	Message   string `json:"message"`
}

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