Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDirectMessaging ¶
func NewDirectMessaging(opts NewDirectMessagingOpts) invokev1.DirectMessaging
NewDirectMessaging returns a new direct messaging api.
func ReadChunk ¶ added in v1.10.0
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 NewDirectMessagingOpts ¶ added in v1.9.0
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
}
NewDirectMessaging contains the options for NewDirectMessaging.
type Proxy ¶ added in v1.3.0
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.
type ProxyOpts ¶ added in v1.10.0
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.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.