memory

Documentation

Index

• type MemoryStore
  • func New() *MemoryStore
  • func (s *MemoryStore) Close() error
  • func (s *MemoryStore) CreateStrategy(strategy *definition.Strategy) error
  • func (s *MemoryStore) CreateTask(task *definition.Task) error
  • func (s *MemoryStore) Dump() string
  • func (s *MemoryStore) GetScheduler(id string) (*definition.Scheduler, error)
  • func (s *MemoryStore) GetSchedulers() ([]*definition.Scheduler, error)
  • func (s *MemoryStore) GetStrategies() ([]*definition.Strategy, error)
  • func (s *MemoryStore) GetStrategy(id string) (*definition.Strategy, error)
  • func (s *MemoryStore) GetStrategyRuntime(strategyId, schedulerId string) (*definition.StrategyRuntime, error)
  • func (s *MemoryStore) GetStrategyRuntimes(strategyId string) ([]*definition.StrategyRuntime, error)
  • func (s *MemoryStore) GetTask(id string) (*definition.Task, error)
  • func (s *MemoryStore) GetTaskAssignment(strategyId, taskId, itemId string) (*definition.TaskAssignment, error)
  • func (s *MemoryStore) GetTaskAssignments(strategyId, taskId string) ([]*definition.TaskAssignment, error)
  • func (s *MemoryStore) GetTaskItemsConfigVersion(strategyId, taskId string) (int64, error)
  • func (s *MemoryStore) GetTaskRuntime(strategyId, taskId, id string) (*definition.TaskRuntime, error)
  • func (s *MemoryStore) GetTaskRuntimes(strategyId, taskId string) ([]*definition.TaskRuntime, error)
  • func (s *MemoryStore) GetTasks() ([]*definition.Task, error)
  • func (s *MemoryStore) IncreaseTaskItemsConfigVersion(strategyId, taskId string) error
  • func (s *MemoryStore) Lock() distlock.DistLock
  • func (s *MemoryStore) Name() string
  • func (s *MemoryStore) RegisterScheduler(scheduler *definition.Scheduler) error
  • func (s *MemoryStore) RemoveStrategy(id string) error
  • func (s *MemoryStore) RemoveStrategyRuntime(strategyId, schedulerId string) error
  • func (s *MemoryStore) RemoveTask(id string) error
  • func (s *MemoryStore) RemoveTaskAssignment(strategyId, taskId, itemId string) error
  • func (s *MemoryStore) RemoveTaskRuntime(strategyId, taskId, id string) error
  • func (s *MemoryStore) Sequence() (uint64, error)
  • func (s *MemoryStore) SetStrategyRuntime(runtime *definition.StrategyRuntime) error
  • func (s *MemoryStore) SetTaskAssignment(assignment *definition.TaskAssignment) error
  • func (s *MemoryStore) SetTaskRuntime(runtime *definition.TaskRuntime) error
  • func (s *MemoryStore) Time() int64
  • func (s *MemoryStore) UnregisterScheduler(id string) error
  • func (s *MemoryStore) UpdateStrategy(strategy *definition.Strategy) error
  • func (s *MemoryStore) UpdateTask(task *definition.Task) error

Types

type MemoryStore

type MemoryStore struct {
	// contains filtered or unexported fields
}

func New

func New() *MemoryStore

func (*MemoryStore) Close

func (s *MemoryStore) Close() error

func (*MemoryStore) CreateStrategy

func (s *MemoryStore) CreateStrategy(strategy *definition.Strategy) error

func (*MemoryStore) CreateTask

func (s *MemoryStore) CreateTask(task *definition.Task) error

func (*MemoryStore) Dump

func (s *MemoryStore) Dump() string

func (*MemoryStore) GetScheduler

func (s *MemoryStore) GetScheduler(id string) (*definition.Scheduler, error)

func (*MemoryStore) GetSchedulers

func (s *MemoryStore) GetSchedulers() ([]*definition.Scheduler, error)

func (*MemoryStore) GetStrategies

func (s *MemoryStore) GetStrategies() ([]*definition.Strategy, error)

func (*MemoryStore) GetStrategy

func (s *MemoryStore) GetStrategy(id string) (*definition.Strategy, error)

func (*MemoryStore) GetStrategyRuntime

func (s *MemoryStore) GetStrategyRuntime(strategyId, schedulerId string) (*definition.StrategyRuntime, error)

func (*MemoryStore) GetStrategyRuntimes

func (s *MemoryStore) GetStrategyRuntimes(strategyId string) ([]*definition.StrategyRuntime, error)

func (*MemoryStore) GetTask

func (s *MemoryStore) GetTask(id string) (*definition.Task, error)

func (*MemoryStore) GetTaskAssignment

func (s *MemoryStore) GetTaskAssignment(strategyId, taskId, itemId string) (*definition.TaskAssignment, error)

func (*MemoryStore) GetTaskAssignments

func (s *MemoryStore) GetTaskAssignments(strategyId, taskId string) ([]*definition.TaskAssignment, error)

func (*MemoryStore) GetTaskItemsConfigVersion

func (s *MemoryStore) GetTaskItemsConfigVersion(strategyId, taskId string) (int64, error)

func (*MemoryStore) GetTaskRuntime

func (s *MemoryStore) GetTaskRuntime(strategyId, taskId, id string) (*definition.TaskRuntime, error)

func (*MemoryStore) GetTaskRuntimes

func (s *MemoryStore) GetTaskRuntimes(strategyId, taskId string) ([]*definition.TaskRuntime, error)

func (*MemoryStore) GetTasks

func (s *MemoryStore) GetTasks() ([]*definition.Task, error)

func (*MemoryStore) IncreaseTaskItemsConfigVersion

func (s *MemoryStore) IncreaseTaskItemsConfigVersion(strategyId, taskId string) error

func (*MemoryStore) Lock

func (s *MemoryStore) Lock() distlock.DistLock

func (*MemoryStore) Name

func (s *MemoryStore) Name() string

func (*MemoryStore) RegisterScheduler

func (s *MemoryStore) RegisterScheduler(scheduler *definition.Scheduler) error

func (*MemoryStore) RemoveStrategy

func (s *MemoryStore) RemoveStrategy(id string) error

func (*MemoryStore) RemoveStrategyRuntime

func (s *MemoryStore) RemoveStrategyRuntime(strategyId, schedulerId string) error

func (*MemoryStore) RemoveTask

func (s *MemoryStore) RemoveTask(id string) error

func (*MemoryStore) RemoveTaskAssignment

func (s *MemoryStore) RemoveTaskAssignment(strategyId, taskId, itemId string) error

func (*MemoryStore) RemoveTaskRuntime

func (s *MemoryStore) RemoveTaskRuntime(strategyId, taskId, id string) error

func (*MemoryStore) Sequence

func (s *MemoryStore) Sequence() (uint64, error)

func (*MemoryStore) SetStrategyRuntime

func (s *MemoryStore) SetStrategyRuntime(runtime *definition.StrategyRuntime) error

func (*MemoryStore) SetTaskAssignment

func (s *MemoryStore) SetTaskAssignment(assignment *definition.TaskAssignment) error

func (*MemoryStore) SetTaskRuntime

func (s *MemoryStore) SetTaskRuntime(runtime *definition.TaskRuntime) error

func (*MemoryStore) Time

func (s *MemoryStore) Time() int64

func (*MemoryStore) UnregisterScheduler

func (s *MemoryStore) UnregisterScheduler(id string) error

func (*MemoryStore) UpdateStrategy

func (s *MemoryStore) UpdateStrategy(strategy *definition.Strategy) error

func (*MemoryStore) UpdateTask

func (s *MemoryStore) UpdateTask(task *definition.Task) error