states

Documentation

Index

• Constants
• func CreateStore(ruleId string, qos api.Qos) (api.Store, error)
• type KVStore
  • func (s *KVStore) GetOpState(opId string) (*sync.Map, error)
  • func (s *KVStore) SaveCheckpoint(checkpointId int64) error
  • func (s *KVStore) SaveState(checkpointId int64, opId string, state map[string]interface{}) error
• type MemoryStore
  • func (s *MemoryStore) GetOpState(opId string) (*sync.Map, error)
  • func (s *MemoryStore) SaveCheckpoint(_ int64) error
  • func (s *MemoryStore) SaveState(_ int64, _ string, _ map[string]interface{}) error

Constants

const CheckpointListKey = "checkpoints"

Functions

func CreateStore

func CreateStore(ruleId string, qos api.Qos) (api.Store, error)

Types

type KVStore

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

The manager for checkpoint storage. * *** mapStore keys *** { "checkpoint1", "checkpoint2" ... "checkpointn" : The complete or incomplete snapshot

func (*KVStore) GetOpState

func (s *KVStore) GetOpState(opId string) (*sync.Map, error)

Only run in the initialization

func (*KVStore) SaveCheckpoint

func (s *KVStore) SaveCheckpoint(checkpointId int64) error

func (*KVStore) SaveState

func (s *KVStore) SaveState(checkpointId int64, opId string, state map[string]interface{}) error

type MemoryStore

type MemoryStore sync.Map //The current root store of a rule

func (*MemoryStore) GetOpState

func (s *MemoryStore) GetOpState(opId string) (*sync.Map, error)

func (*MemoryStore) SaveCheckpoint

func (s *MemoryStore) SaveCheckpoint(_ int64) error

func (*MemoryStore) SaveState

func (s *MemoryStore) SaveState(_ int64, _ string, _ map[string]interface{}) error