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.
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.
Click to show internal directories.
Click to hide internal directories.