outbound

Documentation

Index

• type Dispatcher
  • func NewOutbound(prov provider) (*Dispatcher, error)
  • func (o *Dispatcher) Forward(msg interface{}, des *service.Destination) error
  • func (o *Dispatcher) Send(msg interface{}, senderKey string, des *service.Destination) error
  • func (o *Dispatcher) SendToDID(msg interface{}, myDID, theirDID string) error

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.