messaging

Documentation

Index

• Constants
• type DirectMessaging
  • func NewDirectMessaging(appID, namespace string, port int, mode modes.DaprMode, ...) DirectMessaging
• type Proxy
  • func NewProxy(connectionFactory messageClientConnection, appID string, ...) Proxy

Constants

const (
	// GRPCFeatureName is the feature name for the Dapr configuration required to enable the proxy.
	GRPCFeatureName = "proxy.grpc"
)

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) 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) Proxy

NewProxy returns a new proxy.