handler

package

v0.0.19 Latest Latest Go to latest Published: Dec 4, 2019 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lishimeng/go-libs

Links

Open Source Insights

Documentation ¶

Index ¶

type ChanBasedContext
type CoderSort
type Container
- func NewContainer() (container *Container)
type Context
- func NewContext(rxCapacity int, txCapacity int) *Context
type Handler
type Meta
- func (c Meta) Index() int
type RxContainer
- func (c *RxContainer) NextHandler(currentMeta Meta) (handler Handler, meta Meta, err error)
type TxContainer
- func (c *TxContainer) NextHandler(currentMeta Meta) (handler Handler, meta Meta, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ChanBasedContext ¶

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

func (*ChanBasedContext) RxLen ¶

func (ccb *ChanBasedContext) RxLen() int

func (*ChanBasedContext) RxRead ¶

func (ccb *ChanBasedContext) RxRead() (data interface{}, err error)

func (*ChanBasedContext) RxWrite ¶

func (ccb *ChanBasedContext) RxWrite(data interface{})

func (*ChanBasedContext) TxLen ¶

func (ccb *ChanBasedContext) TxLen() int

func (*ChanBasedContext) TxRead ¶

func (ccb *ChanBasedContext) TxRead() (data interface{}, err error)

func (*ChanBasedContext) TxWrite ¶

func (ccb *ChanBasedContext) TxWrite(data interface{})

type CoderSort ¶

type CoderSort int

const (
	SortASC CoderSort = iota
	SortDESC
)

type Container ¶

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

func NewContainer ¶

func NewContainer() (container *Container)

func (*Container) FirstHandler ¶

func (c *Container) FirstHandler(sort CoderSort) (handler Handler, meta Meta, err error)

func (*Container) Get ¶

func (c *Container) Get(name string) (handler Handler, meta Meta, err error)

func (Container) HasNext ¶

func (c Container) HasNext(meta Meta, sort CoderSort) bool

func (*Container) Next ¶

func (c *Container) Next(currentMeta Meta, sort CoderSort) (handler Handler, meta Meta, err error)

func (*Container) Register ¶

func (c *Container) Register(handler Handler, meta ...Meta) (err error)

func (*Container) RegisterHandlers ¶

func (c *Container) RegisterHandlers(handlers ...Handler) (err error)

type Context ¶

type Context interface {
	RxLen() int
	TxLen() int
	RxWrite(data interface{})
	RxRead() (data interface{}, err error)
	TxWrite(data interface{})
	TxRead() (data interface{}, err error)
}

func NewContext ¶

func NewContext(rxCapacity int, txCapacity int) *Context

type Handler ¶

type Handler interface {
	Context
	Rx(input interface{}) (err error)
	Tx(input interface{}) (err error)
}

type Meta ¶

type Meta struct {
	DisableTx bool
	DisableRx bool
	// contains filtered or unexported fields
}

define

func (Meta) Index ¶

func (c Meta) Index() int

type RxContainer ¶

type RxContainer struct {
	Container
}

func (*RxContainer) NextHandler ¶

func (c *RxContainer) NextHandler(currentMeta Meta) (handler Handler, meta Meta, err error)

type TxContainer ¶

type TxContainer struct {
	Container
}

func (*TxContainer) NextHandler ¶

func (c *TxContainer) NextHandler(currentMeta Meta) (handler Handler, meta Meta, err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL