bus

Documentation

Index

• type Bus
• type ContextHttp
• type Handler
• type Slot
• type SlotBus
  • func NewSlotBus() *SlotBus
  • func (bus *SlotBus) AddSlot(slot Slot)
  • func (bus *SlotBus) AddSlotHandler(slotType SlotType, handler Handler, matches ...interface{}) error
  • func (bus *SlotBus) DelSlotHandler(slotType SlotType, matches ...interface{}) error
• type SlotType

Types

type Bus

type Bus interface {
	AddSlot(slot Slot)
	AddSlotHandler(slotType SlotType, handler Handler, matches ...interface{}) error
	DelSlotHandler(slotType SlotType, matches ...interface{}) error
}

type ContextHttp

type ContextHttp struct {
	iris.Context
	RelativePath string
}

type Handler

type Handler func(interface{})

type Slot

type Slot interface {
	AddHandler(handler Handler, matches ...interface{})
	DelHandler(matches ...interface{})
	Type() SlotType
}

type SlotBus

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

func NewSlotBus

func NewSlotBus() *SlotBus

func (*SlotBus) AddSlot

func (bus *SlotBus) AddSlot(slot Slot)

func (*SlotBus) AddSlotHandler

func (bus *SlotBus) AddSlotHandler(slotType SlotType, handler Handler,
	matches ...interface{}) error

func (*SlotBus) DelSlotHandler

func (bus *SlotBus) DelSlotHandler(slotType SlotType, matches ...interface{}) error

type SlotType

type SlotType int

const (
	SlotHttp SlotType = iota
	SlotRedis
	SlotKafka
)