Help us shape the future of Go! Take the 2026 Go Developer Survey

channels

package
v1.18.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 21, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Channels

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

func New

func New(opts Options) *Channels

func (*Channels) ActorCallbackStream added in v1.18.2

func (c *Channels) ActorCallbackStream() *callbackstream.Manager

ActorCallbackStream returns the runtime-owned actor callback stream manager. It is available even when no app channel exists (no app-port configured): apps hosting actors over SubscribeActorEventsAlpha1 dial daprd themselves and do not need to listen on any port.

func (*Channels) AppChannel

func (c *Channels) AppChannel() channel.AppChannel

func (*Channels) AppHTTPClient

func (c *Channels) AppHTTPClient() *http.Client

func (*Channels) AppHTTPEndpoint

func (c *Channels) AppHTTPEndpoint() string

AppHTTPEndpoint Returns the HTTP endpoint for the app.

func (*Channels) EndpointChannels

func (c *Channels) EndpointChannels() map[string]channel.HTTPEndpointAppChannel

func (*Channels) HTTPEndpointsAppChannel

func (c *Channels) HTTPEndpointsAppChannel() channel.HTTPEndpointAppChannel

func (*Channels) Refresh

func (c *Channels) Refresh() error

type Options

type Options struct {
	// Registry is the all-component registry.
	Registry *registry.Registry

	// ComponentStore is the component store.
	ComponentStore *compstore.ComponentStore

	// Metadata is the metadata helper.
	Meta *meta.Meta

	// AppConnectionConfig is the application connection configuration.
	AppConnectionConfig config.AppConnectionConfig

	// GlobalConfig is the global configuration.
	GlobalConfig *config.Configuration

	// AppMiddlware is the application middleware.
	AppMiddleware middleware.HTTP

	// MaxRequestBodySize is the maximum request body size, in bytes.
	MaxRequestBodySize int

	// ReadBufferSize is the read buffer size, in bytes
	ReadBufferSize int

	GRPC        *manager.Manager
	AppAPIToken string

	// ActorCallbackStream is the runtime-owned stream manager attached to
	// the gRPC app channel, if any. Its event loop is driven by the
	// runtime's RunnerCloserManager.
	ActorCallbackStream *callbackstream.Manager
}

Jump to

Keyboard shortcuts

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