pool

Documentation

Index

• func NewPool(mgrDB sqlx.DBExecutor) optypes.Pool
• type Pool
  • func (p *Pool) Delete(id types.SFID) error
  • func (p *Pool) Get(accountID types.SFID, opName string) (*optypes.SyncOperator, error)

Functions

func NewPool

func NewPool(mgrDB sqlx.DBExecutor) optypes.Pool

operator memory pool

Types

type Pool

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

func (*Pool) Delete

func (p *Pool) Delete(id types.SFID) error

func (*Pool) Get

func (p *Pool) Get(accountID types.SFID, opName string) (*optypes.SyncOperator, error)