http

Documentation

Index

• Constants
• func CreateLocalChannel(port, maxConcurrency int, pipeline httpMiddleware.Pipeline, ...) (channel.AppChannel, error)
• type Channel
  • func (h *Channel) GetAppConfig() (*config.ApplicationConfig, error)
  • func (h *Channel) GetBaseAddress() string
  • func (h *Channel) HealthProbe(ctx context.Context) (bool, error)
  • func (h *Channel) InvokeMethod(ctx context.Context, req *invokev1.InvokeMethodRequest) (rsp *invokev1.InvokeMethodResponse, err error)
  • func (h *Channel) SetAppHealth(ah *apphealth.AppHealth)
  • func (h *Channel) SetAppHealthCheckPath(path string)

Constants

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

Functions

func CreateLocalChannel

func CreateLocalChannel(port, maxConcurrency int, pipeline httpMiddleware.Pipeline, spec config.TracingSpec, sslEnabled bool, maxRequestBodySizeMB, readBufferSizeKB int) (channel.AppChannel, error)

CreateLocalChannel 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

func (h *Channel) GetAppConfig() (*config.ApplicationConfig, error)

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

func (*Channel) GetBaseAddress

func (h *Channel) GetBaseAddress() string

GetBaseAddress returns the application base address.

func (*Channel) HealthProbe

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

HealthProbe performs a health probe.

func (*Channel) InvokeMethod

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

InvokeMethod invokes user code via HTTP.

func (*Channel) SetAppHealth

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

SetAppHealth sets the apphealth.AppHealth object.

func (*Channel) SetAppHealthCheckPath

func (h *Channel) SetAppHealthCheckPath(path string)

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