messaging

Documentation

Index

• type DirectMessaging
  • func NewDirectMessaging(opts NewDirectMessagingOpts) DirectMessaging
• type NewDirectMessagingOpts
• type Proxy
  • func NewProxy(connectionFactory messageClientConnection, appID string, ...) Proxy

Types

type DirectMessaging

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

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
	Mode                modes.DaprMode
	AppChannel          channel.AppChannel
	ClientConnFn        messageClientConnection
	Resolver            nr.Resolver
	MaxRequestBodySize  int
	Proxy               Proxy
	ReadBufferSize      int
	Resiliency          resiliency.Provider
	IsResiliencyEnabled 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(connectionFactory messageClientConnection, appID string, localAppAddress string, remoteDaprPort int, acl *config.AccessControlList, sslEnabled bool, resiliency resiliency.Provider) Proxy

NewProxy returns a new proxy.