messaging

type NewDirectMessagingOpts struct {
	AppID              string
	Namespace          string
	Port               int
	CompStore          *compstore.ComponentStore
	Mode               modes.DaprMode
	Channels           *channels.Channels
	ClientConnFn       messageClientConnection
	Resolver           nr.Resolver
	MultiResolver      nr.ResolverMulti
	MaxRequestBodySize int
	Proxy              Proxy
	ReadBufferSize     int
	Resiliency         resiliency.Provider
}

type Proxy interface {
	Handler() grpc.StreamHandler
	SetRemoteAppFn(func(string) (remoteApp, error))
	SetTelemetryFn(func(context.Context) context.Context)
}

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