messaging

package
v1.10.0-rc.8 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 2023 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReadChunk added in v1.10.0

func ReadChunk(payload *commonv1pb.StreamPayload, out io.Writer) (seq uint32, err error)

ReadChunk reads a chunk of data from a StreamPayload object. The returned value "seq" indicates the sequence number

Types

type DirectMessaging

type DirectMessaging interface {
	Invoke(ctx context.Context, targetAppID string, req *invokev1.InvokeMethodRequest) (*invokev1.InvokeMethodResponse, error)
	SetAppChannel(appChannel channel.AppChannel)
}

DirectMessaging is the API interface for invoking a remote app.

func NewDirectMessaging

func NewDirectMessaging(opts NewDirectMessagingOpts) DirectMessaging

NewDirectMessaging returns a new direct messaging api.

type NewDirectMessagingOpts added in v1.9.0

type NewDirectMessagingOpts struct {
	AppID              string
	Namespace          string
	Port               int
	Mode               modes.DaprMode
	AppChannel         channel.AppChannel
	ClientConnFn       messageClientConnection
	Resolver           nr.Resolver
	MaxRequestBodySize int
	Proxy              Proxy
	ReadBufferSize     int
	Resiliency         resiliency.Provider
	IsStreamingEnabled bool
}

NewDirectMessaging contains the options for NewDirectMessaging.

type Proxy added in v1.3.0

type Proxy interface {
	Handler() grpc.StreamHandler
	SetRemoteAppFn(func(string) (remoteApp, error))
	SetTelemetryFn(func(context.Context) context.Context)
}

Proxy is the interface for a gRPC transparent proxy.

func NewProxy added in v1.3.0

func NewProxy(opts ProxyOpts) Proxy

NewProxy returns a new proxy.

type ProxyOpts added in v1.10.0

type ProxyOpts struct {
	AppClientFn       func() (grpc.ClientConnInterface, error)
	ConnectionFactory messageClientConnection
	AppID             string
	ACL               *config.AccessControlList
	Resiliency        resiliency.Provider
}

ProxyOpts is the struct with options for NewProxy.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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