Documentation
¶
Index ¶
- Constants
- type CompactService
- type Service
- func (s *Service) Close() error
- func (s *Service) Open() error
- func (s *Service) ProcessGetTask(typ scheduler.TaskType) (scheduler.Task, uint64, error)
- func (s *Service) SendRequestOnNode(nodeID uint64, typ uint8, req codec.BinaryCodec) (interface{}, error)
- func (s *Service) WithLogger(logger *logger.Logger)
Constants ¶
View Source
const CompactionInterval = 10 * time.Second
View Source
const (
MaxRetryNumber = 10
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompactService ¶
type CompactService struct {
Service
// contains filtered or unexported fields
}
func NewCompactService ¶
func NewCompactService(interval time.Duration, engine engine.Engine) *CompactService
type Service ¶
type Service struct {
MetaClient meta.MetaClient
// contains filtered or unexported fields
}
func NewService ¶
func (*Service) ProcessGetTask ¶
func (*Service) SendRequestOnNode ¶
func (*Service) WithLogger ¶
Source Files
Click to show internal directories.
Click to hide internal directories.