servicebus

Documentation

Index

• type ServiceBus
  • func (sb *ServiceBus) Forward(target provider.Target, data interface{}) (response interface{}, err error)
  • func (sb *ServiceBus) GoToTarget(data map[string]interface{}, stop chan struct{}) (interface{}, error)
  • func (sb *ServiceBus) Name() string
  • func (sb *ServiceBus) RegisterListener(handle listener.Handle) error
  • func (sb *ServiceBus) UnregisterListener()

Types

type ServiceBus

type ServiceBus struct {
	TargetURL string
	// contains filtered or unexported fields
}

func (*ServiceBus) Forward

func (sb *ServiceBus) Forward(target provider.Target, data interface{}) (response interface{}, err error)

func (*ServiceBus) GoToTarget

func (sb *ServiceBus) GoToTarget(data map[string]interface{}, stop chan struct{}) (interface{}, error)

func (*ServiceBus) Name

func (sb *ServiceBus) Name() string

func (*ServiceBus) RegisterListener

func (sb *ServiceBus) RegisterListener(handle listener.Handle) error

func (*ServiceBus) UnregisterListener

func (sb *ServiceBus) UnregisterListener()