databusutil

Documentation

Index

• type DatabusHandler
  • func NewDatabusHandler() *DatabusHandler
  • func (s *DatabusHandler) Close()
  • func (s *DatabusHandler) GoWatch(bus *databus.Databus, handler func(msg *databus.Message) error)
  • func (s *DatabusHandler) Watch(bus *databus.Databus, handler func(msg *databus.Message) error)

Types

type DatabusHandler

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

DatabusHandler handler

func NewDatabusHandler

func NewDatabusHandler() *DatabusHandler

NewDatabusHandler new handler

func (*DatabusHandler) Close

func (s *DatabusHandler) Close()

Close close

func (*DatabusHandler) GoWatch

func (s *DatabusHandler) GoWatch(bus *databus.Databus, handler func(msg *databus.Message) error)

GoWatch watch with goroutine

func (*DatabusHandler) Watch

func (s *DatabusHandler) Watch(bus *databus.Databus, handler func(msg *databus.Message) error)

Watch watch without goroutine