messaging

Documentation

Index

• type DirectMessaging
  • func NewDirectMessaging(appID, namespace string, port int, mode modes.DaprMode, ...) DirectMessaging
• 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(
	appID, namespace string,
	port int, mode modes.DaprMode,
	appChannel channel.AppChannel,
	clientConnFn messageClientConnection,
	resolver nr.Resolver,
	tracingSpec config.TracingSpec,
	maxRequestBodySize int,
	proxy Proxy,
	readBufferSize int,
	streamRequestBody bool,
	resiliency resiliency.Provider,
	isResiliencyEnabled bool,
) DirectMessaging

NewDirectMessaging returns a new direct messaging api.

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.