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 ¶
View Source
const ( Load uint8 = 1 ToSave uint8 = 1 << iota DeleteItem )
Variables ¶
This section is empty.
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)
Click to show internal directories.
Click to hide internal directories.