Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher dispatch msgs to destination.
func NewOutbound ¶
func NewOutbound(prov provider) (*Dispatcher, error)
NewOutbound return new dispatcher outbound instance.
func (*Dispatcher) Forward ¶
func (o *Dispatcher) Forward(msg interface{}, des *service.Destination) error
Forward forwards the message without packing to the destination.
func (*Dispatcher) Send ¶
func (o *Dispatcher) Send(msg interface{}, senderKey string, des *service.Destination) error
Send sends the message after packing with the sender key and recipient keys.
func (*Dispatcher) SendToDID ¶
func (o *Dispatcher) SendToDID(msg interface{}, myDID, theirDID string) error
SendToDID sends a message from myDID to the agent who owns theirDID.
Source Files
Click to show internal directories.
Click to hide internal directories.