services

Documentation

Index

• func SetStorageEngine(engine StorageEngine)
• type Base
  • func (s *Base) Close() error
  • func (s *Base) Init(name string, interval time.Duration, handle func())
  • func (s *Base) Open() error
• type StorageEngine
  • func GetStorageEngine() StorageEngine

Functions

func SetStorageEngine

func SetStorageEngine(engine StorageEngine)

Types

type Base

type Base struct {
	Interval time.Duration

	Logger *logger.Logger
	// contains filtered or unexported fields
}

func (*Base) Close

func (s *Base) Close() error

func (*Base) Init

func (s *Base) Init(name string, interval time.Duration, handle func())

func (*Base) Open

func (s *Base) Open() error

type StorageEngine

type StorageEngine interface {
	WriteRec(db, rp, mst string, ptId uint32, shardID uint64, rec *record.Record, binaryRec []byte) error
}

func GetStorageEngine

func GetStorageEngine() StorageEngine