mfs

Documentation

Index

• type Context
  • func (c *Context) Back(a ...int)
  • func (c *Context) Close(err error) error
  • func (c *Context) Get(key string) any
  • func (c *Context) Next()
  • func (c *Context) Set(key string, val any)
  • func (c *Context) Stop()
• type Factory
  • func GenerateFactory(name string) *Factory
  • func (f *Factory) AppendMethods(methods ...Method)
  • func (f *Factory) Do()
  • func (f *Factory) EndMessage() (string, error)
  • func (f *Factory) Next() bool
• type Method
• type MethodChain
  • func (m MethodChain) Length() int

Types

type Context

type Context struct {
	TaskId string // now task id
	// contains filtered or unexported fields
}

Context

func (*Context) Back

func (c *Context) Back(a ...int)

func (*Context) Close

func (c *Context) Close(err error) error

func (*Context) Get

func (c *Context) Get(key string) any

func (*Context) Next

func (c *Context) Next()

func (*Context) Set

func (c *Context) Set(key string, val any)

func (*Context) Stop

func (c *Context) Stop()

type Factory

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

func GenerateFactory

func GenerateFactory(name string) *Factory

GenerateFactory

func (*Factory) AppendMethods

func (f *Factory) AppendMethods(methods ...Method)

func (*Factory) Do

func (f *Factory) Do()

func (*Factory) EndMessage

func (f *Factory) EndMessage() (string, error)

EndMessage

func (*Factory) Next

func (f *Factory) Next() bool

Next

type Method

type Method interface {
	TaskId() string  // return this method name
	Do(ctx *Context) // runner func
}

Method

type MethodChain

type MethodChain []Method

MethodChain

func (MethodChain) Length

func (m MethodChain) Length() int