messaging

Documentation

Index

• func ReadChunk(payload *commonv1pb.StreamPayload, out io.Writer) (seq uint64, err error)
• type DirectMessaging
  • func NewDirectMessaging(opts NewDirectMessagingOpts) DirectMessaging
• type NewDirectMessagingOpts
• type Proxy
  • func NewProxy(opts ProxyOpts) Proxy
• type ProxyOpts

Functions

func ReadChunk

func ReadChunk(payload *commonv1pb.StreamPayload, out io.Writer) (seq uint64, 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)
	SetHTTPEndpointsAppChannel(appChannel channel.HTTPEndpointAppChannel)
}

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

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

NewDirectMessaging contains the options for NewDirectMessaging.

type Proxy

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

func NewProxy(opts ProxyOpts) Proxy

NewProxy returns a new proxy.

type ProxyOpts

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

ProxyOpts is the struct with options for NewProxy.