Documentation
¶
Index ¶
- type Action
- type ShardScheduler
- func (s *ShardScheduler) Pause()
- func (s *ShardScheduler) Resume()
- func (s *ShardScheduler) ScheduleAction(action Action) chan error
- func (s *ShardScheduler) ScheduleActionFireAndForget(action Action)
- func (s *ShardScheduler) ShardID() uint64
- func (s *ShardScheduler) Start()
- func (s *ShardScheduler) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ShardScheduler ¶
type ShardScheduler struct {
// contains filtered or unexported fields
}
func NewShardScheduler ¶
func NewShardScheduler(shardID uint64) *ShardScheduler
func (*ShardScheduler) Pause ¶
func (s *ShardScheduler) Pause()
func (*ShardScheduler) Resume ¶
func (s *ShardScheduler) Resume()
func (*ShardScheduler) ScheduleAction ¶
func (s *ShardScheduler) ScheduleAction(action Action) chan error
func (*ShardScheduler) ScheduleActionFireAndForget ¶
func (s *ShardScheduler) ScheduleActionFireAndForget(action Action)
func (*ShardScheduler) ShardID ¶
func (s *ShardScheduler) ShardID() uint64
func (*ShardScheduler) Start ¶
func (s *ShardScheduler) Start()
func (*ShardScheduler) Stop ¶
func (s *ShardScheduler) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.