Documentation ¶
Index ¶
- type Etcdv3Store
- func (s *Etcdv3Store) Close() error
- func (s *Etcdv3Store) CreateStrategy(strategy *definition.Strategy) error
- func (s *Etcdv3Store) CreateTask(task *definition.Task) error
- func (s *Etcdv3Store) Dump() string
- func (s *Etcdv3Store) GetScheduler(id string) (*definition.Scheduler, error)
- func (s *Etcdv3Store) GetSchedulers() ([]*definition.Scheduler, error)
- func (s *Etcdv3Store) GetStrategies() ([]*definition.Strategy, error)
- func (s *Etcdv3Store) GetStrategy(id string) (*definition.Strategy, error)
- func (s *Etcdv3Store) GetStrategyRuntime(strategyId, schedulerId string) (*definition.StrategyRuntime, error)
- func (s *Etcdv3Store) GetStrategyRuntimes(strategyId string) ([]*definition.StrategyRuntime, error)
- func (s *Etcdv3Store) GetTask(id string) (*definition.Task, error)
- func (s *Etcdv3Store) GetTaskAssignment(strategyId, taskId, itemId string) (*definition.TaskAssignment, error)
- func (s *Etcdv3Store) GetTaskAssignments(strategyId, taskId string) ([]*definition.TaskAssignment, error)
- func (s *Etcdv3Store) GetTaskItemsConfigVersion(strategyId, taskId string) (int64, error)
- func (s *Etcdv3Store) GetTaskRuntime(strategyId, taskId, id string) (*definition.TaskRuntime, error)
- func (s *Etcdv3Store) GetTaskRuntimes(strategyId, taskId string) ([]*definition.TaskRuntime, error)
- func (s *Etcdv3Store) GetTasks() ([]*definition.Task, error)
- func (s *Etcdv3Store) IncreaseTaskItemsConfigVersion(strategyId, taskId string) error
- func (s *Etcdv3Store) Name() string
- func (s *Etcdv3Store) RegisterScheduler(scheduler *definition.Scheduler) error
- func (s *Etcdv3Store) RemoveStrategy(id string) error
- func (s *Etcdv3Store) RemoveStrategyRuntime(strategyId, schedulerId string) error
- func (s *Etcdv3Store) RemoveTask(id string) error
- func (s *Etcdv3Store) RemoveTaskAssignment(strategyId, taskId, itemId string) error
- func (s *Etcdv3Store) RemoveTaskRuntime(strategyId, taskId, id string) error
- func (s *Etcdv3Store) Sequence() (uint64, error)
- func (s *Etcdv3Store) SetStrategyRuntime(runtime *definition.StrategyRuntime) error
- func (s *Etcdv3Store) SetTaskAssignment(assignment *definition.TaskAssignment) error
- func (s *Etcdv3Store) SetTaskRuntime(runtime *definition.TaskRuntime) error
- func (s *Etcdv3Store) Time() int64
- func (s *Etcdv3Store) UnregisterScheduler(id string) error
- func (s *Etcdv3Store) UpdateStrategy(strategy *definition.Strategy) error
- func (s *Etcdv3Store) UpdateTask(task *definition.Task) error
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Etcdv3Store ¶
type Etcdv3Store struct {
// contains filtered or unexported fields
}
func (*Etcdv3Store) Close ¶
func (s *Etcdv3Store) Close() error
func (*Etcdv3Store) CreateStrategy ¶
func (s *Etcdv3Store) CreateStrategy(strategy *definition.Strategy) error
func (*Etcdv3Store) CreateTask ¶
func (s *Etcdv3Store) CreateTask(task *definition.Task) error
func (*Etcdv3Store) Dump ¶
func (s *Etcdv3Store) Dump() string
func (*Etcdv3Store) GetScheduler ¶
func (s *Etcdv3Store) GetScheduler(id string) (*definition.Scheduler, error)
func (*Etcdv3Store) GetSchedulers ¶
func (s *Etcdv3Store) GetSchedulers() ([]*definition.Scheduler, error)
func (*Etcdv3Store) GetStrategies ¶
func (s *Etcdv3Store) GetStrategies() ([]*definition.Strategy, error)
func (*Etcdv3Store) GetStrategy ¶
func (s *Etcdv3Store) GetStrategy(id string) (*definition.Strategy, error)
func (*Etcdv3Store) GetStrategyRuntime ¶
func (s *Etcdv3Store) GetStrategyRuntime(strategyId, schedulerId string) (*definition.StrategyRuntime, error)
func (*Etcdv3Store) GetStrategyRuntimes ¶
func (s *Etcdv3Store) GetStrategyRuntimes(strategyId string) ([]*definition.StrategyRuntime, error)
func (*Etcdv3Store) GetTask ¶
func (s *Etcdv3Store) GetTask(id string) (*definition.Task, error)
func (*Etcdv3Store) GetTaskAssignment ¶
func (s *Etcdv3Store) GetTaskAssignment(strategyId, taskId, itemId string) (*definition.TaskAssignment, error)
func (*Etcdv3Store) GetTaskAssignments ¶
func (s *Etcdv3Store) GetTaskAssignments(strategyId, taskId string) ([]*definition.TaskAssignment, error)
func (*Etcdv3Store) GetTaskItemsConfigVersion ¶
func (s *Etcdv3Store) GetTaskItemsConfigVersion(strategyId, taskId string) (int64, error)
func (*Etcdv3Store) GetTaskRuntime ¶
func (s *Etcdv3Store) GetTaskRuntime(strategyId, taskId, id string) (*definition.TaskRuntime, error)
func (*Etcdv3Store) GetTaskRuntimes ¶
func (s *Etcdv3Store) GetTaskRuntimes(strategyId, taskId string) ([]*definition.TaskRuntime, error)
func (*Etcdv3Store) GetTasks ¶
func (s *Etcdv3Store) GetTasks() ([]*definition.Task, error)
func (*Etcdv3Store) IncreaseTaskItemsConfigVersion ¶
func (s *Etcdv3Store) IncreaseTaskItemsConfigVersion(strategyId, taskId string) error
func (*Etcdv3Store) Name ¶
func (s *Etcdv3Store) Name() string
func (*Etcdv3Store) RegisterScheduler ¶
func (s *Etcdv3Store) RegisterScheduler(scheduler *definition.Scheduler) error
func (*Etcdv3Store) RemoveStrategy ¶
func (s *Etcdv3Store) RemoveStrategy(id string) error
func (*Etcdv3Store) RemoveStrategyRuntime ¶
func (s *Etcdv3Store) RemoveStrategyRuntime(strategyId, schedulerId string) error
func (*Etcdv3Store) RemoveTask ¶
func (s *Etcdv3Store) RemoveTask(id string) error
func (*Etcdv3Store) RemoveTaskAssignment ¶
func (s *Etcdv3Store) RemoveTaskAssignment(strategyId, taskId, itemId string) error
func (*Etcdv3Store) RemoveTaskRuntime ¶
func (s *Etcdv3Store) RemoveTaskRuntime(strategyId, taskId, id string) error
func (*Etcdv3Store) Sequence ¶
func (s *Etcdv3Store) Sequence() (uint64, error)
func (*Etcdv3Store) SetStrategyRuntime ¶
func (s *Etcdv3Store) SetStrategyRuntime(runtime *definition.StrategyRuntime) error
func (*Etcdv3Store) SetTaskAssignment ¶
func (s *Etcdv3Store) SetTaskAssignment(assignment *definition.TaskAssignment) error
func (*Etcdv3Store) SetTaskRuntime ¶
func (s *Etcdv3Store) SetTaskRuntime(runtime *definition.TaskRuntime) error
func (*Etcdv3Store) Time ¶
func (s *Etcdv3Store) Time() int64
func (*Etcdv3Store) UnregisterScheduler ¶
func (s *Etcdv3Store) UnregisterScheduler(id string) error
func (*Etcdv3Store) UpdateStrategy ¶
func (s *Etcdv3Store) UpdateStrategy(strategy *definition.Strategy) error
func (*Etcdv3Store) UpdateTask ¶
func (s *Etcdv3Store) UpdateTask(task *definition.Task) error
Click to show internal directories.
Click to hide internal directories.