http

Apr 3, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Apr 3, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Mar 9, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Mar 6, 2024 GO-2024-2879

  GO-2024-2879: Dapr API Token Exposure in github.com/dapr/dapr

Changes in this version

+ func APITokenAuthMiddleware(token string) func(next http.Handler) http.Handler

+ func CleanPathMiddleware(next http.Handler) http.Handler

+ func ConvertEventToBytes(event interface{}, contentType string) ([]byte, error)

+ func GetStatusCodeFromMetadata(metadata map[string]string) int

+ func MaxBodySizeMiddleware(maxSize int64) func(next http.Handler) http.Handler

+ func StripSlashesMiddleware(next http.Handler) http.Handler

+ func UniversalHTTPHandler[T proto.Message, U proto.Message](handler func(ctx context.Context, in T) (U, error), ...) http.HandlerFunc

+ type API interface

+ APIEndpoints func() []endpoints.Endpoint

+ MarkStatusAsOutboundReady func()

+ MarkStatusAsReady func()

+ PublicEndpoints func() []endpoints.Endpoint

+ func NewAPI(opts APIOpts) API

+ type APIOpts struct

+ Channels *channels.Channels

+ DirectMessaging invokev1.DirectMessaging

+ MaxRequestBodySize int64

+ PubsubAdapter runtimePubsub.Adapter

+ SendToOutputBindingFn func(ctx context.Context, name string, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

+ TracingSpec config.TracingSpec

+ Universal *universal.Universal

+ type BulkGetRequest struct

+ Keys []string

+ Metadata map[string]string

+ Parallelism int

+ type BulkGetResponse struct

+ Data json.RawMessage

+ ETag *string

+ Error string

+ Key string

+ Metadata map[string]string

+ type BulkPublishResponse struct

+ ErrorCode string

+ FailedEntries []BulkPublishResponseFailedEntry

+ type BulkPublishResponseFailedEntry struct

+ EntryId string

+ Error string

+ type ErrorResponse struct

+ ErrorCode string

+ Message string

+ func NewErrorResponse(errorCode, message string) ErrorResponse

+ func (e ErrorResponse) JSONErrorValue() []byte

+ type NewServerOpts struct

+ API API

+ APISpec config.APISpec

+ Config ServerConfig

+ MetricSpec config.MetricSpec

+ Middleware middleware.HTTP

+ TracingSpec config.TracingSpec

+ type OutputBindingRequest struct

+ Data interface{}

+ Metadata map[string]string

+ Operation string

+ type QueryItem struct

+ Data json.RawMessage

+ ETag *string

+ Error string

+ Key string

+ type QueryResponse struct

+ Metadata map[string]string

+ Results []QueryItem

+ Token string

+ type Server interface

+ StartNonBlocking func() error

+ func NewServer(opts NewServerOpts) Server

+ type ServerConfig struct

+ APIListenAddresses []string

+ APILogHealthChecks bool

+ APILoggingObfuscateURLs bool

+ AllowedOrigins string

+ AppID string

+ EnableAPILogging bool

+ EnableProfiling bool

+ HostAddress string

+ MaxRequestBodySizeMB int

+ Port int

+ ProfilePort int

+ PublicPort *int

+ ReadBufferSizeKB int

+ UnixDomainSocket string

+ type UniversalHTTPHandlerOpts struct

+ InModifier func(r *http.Request, in T) (T, error)

+ OutModifier func(out U) (any, error)

+ ProtoResponseEmitUnpopulated bool

+ SkipInputBody bool

+ SuccessStatusCode int

+ type UniversalHTTPRawResponse struct

+ Body []byte

+ ContentType string

+ StatusCode int

+ type UnsubscribeConfigurationResponse struct

+ Message string

+ Ok bool