dispatcher

Documentation

Index

• type Outbound
• type OutboundCreator
• type OutboundDispatcher
  • func NewOutbound(prov Provider) *OutboundDispatcher
  • func (o *OutboundDispatcher) Send(msg interface{}, senderVerKey string, des *service.Destination) error
• type Provider
• type Service

Types

type Outbound

type Outbound interface {
	Send(interface{}, string, *service.Destination) error
}

Outbound interface

type OutboundCreator

type OutboundCreator func(prov Provider) (Outbound, error)

OutboundCreator method to create new outbound dispatcher service

type OutboundDispatcher

type OutboundDispatcher struct {
	// contains filtered or unexported fields
}

OutboundDispatcher dispatch msgs to destination

func NewOutbound

func NewOutbound(prov Provider) *OutboundDispatcher

NewOutbound return new dispatcher outbound instance

func (*OutboundDispatcher) Send

func (o *OutboundDispatcher) Send(msg interface{}, senderVerKey string, des *service.Destination) error

Send msg

type Provider

type Provider interface {
	Packager() commontransport.Packager
	OutboundTransports() []transport.OutboundTransport
}

Provider interface for outbound ctx

type Service

type Service interface {
	service.Handler
	Accept(msgType string) bool
	Name() string
}

Service protocol service