http

package

v1.16.21 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/dapr

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CreateHTTPChannel(config ChannelConfiguration) (channel.AppChannel, error)
type Channel
type ChannelConfiguration
type RWRecorder

Constants ¶

View Source

const (
	// HTTPStatusCode is an dapr http channel status code.
	HTTPStatusCode = "http.status_code"
)

Variables ¶

This section is empty.

Functions ¶

func CreateHTTPChannel ¶ added in v1.12.0

func CreateHTTPChannel(config ChannelConfiguration) (channel.AppChannel, error)

CreateHTTPChannel creates an HTTP AppChannel.

Types ¶

type Channel ¶

type Channel struct {
	// contains filtered or unexported fields
}

Channel is an HTTP implementation of an AppChannel.

func (*Channel) GetAppConfig ¶ added in v1.2.0

func (h *Channel) GetAppConfig(ctx context.Context, appID string) (*config.ApplicationConfig, error)

GetAppConfig gets application config from user application GET http://localhost:<app_port>/dapr/config

func (*Channel) HealthProbe ¶ added in v1.9.0

func (h *Channel) HealthProbe(ctx context.Context) (*apphealth.Status, error)

HealthProbe performs a health probe.

func (*Channel) InvokeMethod ¶

func (h *Channel) InvokeMethod(ctx context.Context, req *invokev1.InvokeMethodRequest, appID string) (*invokev1.InvokeMethodResponse, error)

InvokeMethod invokes user code via HTTP.

func (*Channel) SetAppHealth ¶ added in v1.9.0

func (h *Channel) SetAppHealth(ah *apphealth.AppHealth)

SetAppHealth sets the apphealth.AppHealth object.

func (*Channel) SetAppHealthCheckPath ¶ added in v1.9.0

func (h *Channel) SetAppHealthCheckPath(path string)

SetAppHealthCheckPath sets the path where to send requests for health probes.

func (*Channel) TriggerJob ¶ added in v1.14.0

func (h *Channel) TriggerJob(ctx context.Context, name string, data *anypb.Any) (*invokev1.InvokeMethodResponse, error)

TriggerJob sends the triggered job back to the app via HTTP.

type ChannelConfiguration ¶ added in v1.10.5

type ChannelConfiguration struct {
	Client             *http.Client
	CompStore          *compstore.ComponentStore
	Endpoint           string
	MaxConcurrency     int
	Middleware         middleware.HTTP
	TracingSpec        *config.TracingSpec
	MaxRequestBodySize int
	TLSClientCert      string
	TLSClientKey       string
	TLSRootCA          string
	TLSRenegotiation   string
	AppAPIToken        string
}

ChannelConfiguration is the configuration used to create an HTTP AppChannel.

type RWRecorder ¶ added in v1.11.0

type RWRecorder struct {
	W io.ReadWriter
	// contains filtered or unexported fields
}

func (w *RWRecorder) Header() http.Header

func (*RWRecorder) Result ¶ added in v1.11.0

func (w *RWRecorder) Result() *http.Response

func (*RWRecorder) StatusCode ¶ added in v1.11.0

func (w *RWRecorder) StatusCode() int

func (*RWRecorder) Write ¶ added in v1.11.0

func (w *RWRecorder) Write(p []byte) (int, error)

func (*RWRecorder) WriteHeader ¶ added in v1.11.0

func (w *RWRecorder) WriteHeader(code int)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL