M2N

Documentation

Index

• Constants
• func NewM2NMachine(dataSources []asynchronousIO.DataSource, ...) asynchronousIO.AsynchronousIOMachine
• type CmdTableForUnChangeableDataSource
  • func (t *CmdTableForUnChangeableDataSource) Delete(k int64, cs *sync.Pool) (c chan asynchronousIO.Bean, start bool)
  • func (t *CmdTableForUnChangeableDataSource) Get(k int64, lastCmd uint8, lastBean asynchronousIO.Bean) (cmd uint8, bean asynchronousIO.Bean, c chan asynchronousIO.Bean, restart bool)
  • func (t *CmdTableForUnChangeableDataSource) Load(k int64, cs *sync.Pool) (c chan asynchronousIO.Bean, bean asynchronousIO.Bean)
  • func (t *CmdTableForUnChangeableDataSource) Save(key int64, bean asynchronousIO.Bean, notify bool, cs *sync.Pool) (c chan asynchronousIO.Bean, start bool)

Constants

const (
	Load   uint8 = 1
	ToSave uint8 = 1 << iota
	DeleteItem
)

Functions

func NewM2NMachine

func NewM2NMachine(dataSources []asynchronousIO.DataSource, beanTypeNumbers, exceptBufferNumber int64, reIn bool) asynchronousIO.AsynchronousIOMachine

Types

type CmdTableForUnChangeableDataSource

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

func (*CmdTableForUnChangeableDataSource) Delete

func (t *CmdTableForUnChangeableDataSource) Delete(k int64, cs *sync.Pool) (c chan asynchronousIO.Bean, start bool)

func (*CmdTableForUnChangeableDataSource) Get

func (t *CmdTableForUnChangeableDataSource) Get(k int64, lastCmd uint8, lastBean asynchronousIO.Bean) (cmd uint8, bean asynchronousIO.Bean, c chan asynchronousIO.Bean, restart bool)

func (*CmdTableForUnChangeableDataSource) Load

func (t *CmdTableForUnChangeableDataSource) Load(k int64, cs *sync.Pool) (c chan asynchronousIO.Bean, bean asynchronousIO.Bean)

func (*CmdTableForUnChangeableDataSource) Save

func (t *CmdTableForUnChangeableDataSource) Save(key int64, bean asynchronousIO.Bean, notify bool, cs *sync.Pool) (c chan asynchronousIO.Bean, start bool)