fakejob

Documentation

Index

• type DummyWorkerStatus
  • func (s *DummyWorkerStatus) DoTick()
  • func (s *DummyWorkerStatus) GetEtcdCheckpoint() WorkerCheckpoint
  • func (s *DummyWorkerStatus) Marshal() ([]byte, error)
  • func (s *DummyWorkerStatus) SetEtcdCheckpoint(ckpt *WorkerCheckpoint)
  • func (s *DummyWorkerStatus) Unmarshal(data []byte) error
• type WorkerCheckpoint
• type WorkerConfig

Types

type DummyWorkerStatus

type DummyWorkerStatus struct {
	BusinessID int               `json:"business-id"`
	Tick       int64             `json:"tick"`
	Checkpoint *WorkerCheckpoint `json:"checkpoint"`
	// contains filtered or unexported fields
}

DummyWorkerStatus is used in fake worker as status.

func (*DummyWorkerStatus) DoTick

func (s *DummyWorkerStatus) DoTick()

DoTick is a periodically tick function.

func (*DummyWorkerStatus) GetEtcdCheckpoint

func (s *DummyWorkerStatus) GetEtcdCheckpoint() WorkerCheckpoint

GetEtcdCheckpoint returns cached checkpoint stored in etcd.

func (*DummyWorkerStatus) Marshal

func (s *DummyWorkerStatus) Marshal() ([]byte, error)

Marshal returns the JSON encoding of DummyWorkerStatus.

func (*DummyWorkerStatus) SetEtcdCheckpoint

func (s *DummyWorkerStatus) SetEtcdCheckpoint(ckpt *WorkerCheckpoint)

SetEtcdCheckpoint sets checkpoint to memory cache.

func (*DummyWorkerStatus) Unmarshal

func (s *DummyWorkerStatus) Unmarshal(data []byte) error

Unmarshal parses the JSON-encoded data and stores the result in DummyWorkerStatus.

type WorkerCheckpoint

type WorkerCheckpoint struct {
	Tick      int64  `json:"tick"`
	Revision  int64  `json:"revision"`
	MvccCount int    `json:"mvcc-count"`
	Value     string `json:"value"`
}

WorkerCheckpoint is used to resume a new worker from old checkpoint

type WorkerConfig

type WorkerConfig struct {
	ID         int   `json:"id"`
	TargetTick int64 `json:"target-tick"`

	EtcdWatchEnable     bool          `json:"etcd-watch-enable"`
	EtcdEndpoints       []string      `json:"etcd-endpoints"`
	EtcdWatchPrefix     string        `json:"etcd-watch-prefix"`
	InjectErrorInterval time.Duration `json:"inject-error-interval"`

	Checkpoint WorkerCheckpoint `json:"checkpoint"`
}

WorkerConfig defines config of fake worker