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