http

Documentation

Index

• func GetStatusCodeFromMetadata(metadata map[string]string) int
• type API
  • func NewAPI(daprID string, appChannel channel.AppChannel, ...) API
• 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(daprID 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
}

API returns a list of HTTP endpoints for Dapr

func NewAPI

func NewAPI(daprID string, appChannel channel.AppChannel, directMessaging messaging.DirectMessaging, stateStores map[string]state.Store, pubSub pubsub.PubSub, actor actors.Actors, sendToOutputBindingFn func(name string, req *bindings.WriteRequest) error) API

NewAPI returns a new API

type Endpoint

type Endpoint struct {
	Methods []string
	Route   string
	Version string
	Handler func(c *routing.Context) error
}

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"`
}

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, pipeline http_middleware.Pipeline) Server

NewServer returns a new HTTP server

type ServerConfig

type ServerConfig struct {
	AllowedOrigins  string
	DaprID          string
	HostAddress     string
	Port            int
	ProfilePort     int
	EnableProfiling bool
}

ServerConfig holds config values for an HTTP server

func NewServerConfig

func NewServerConfig(daprID string, hostAddress string, port int, profilePort int, allowedOrigins string, enableProfiling bool) ServerConfig

NewServerConfig returns a new HTTP server config