state

Documentation

Index

• Constants
• func CreateStore(ruleId string, qos def.Qos) (api.Store, error)
• type KVStore
  • func (s *KVStore) Clean() error
  • 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) Clean() error
  • func (s *MemoryStore) GetOpState(_ 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 def.Qos) (api.Store, error)

Types

type KVStore

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

KVStore The manager for checkpoint storage.

mapStore keys

{ "checkpoint1", "checkpoint2" ... "checkpointn" : The complete or incomplete snapshot

func (*KVStore) Clean

func (s *KVStore) Clean() error

func (*KVStore) GetOpState

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

GetOpState 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) Clean

func (s *MemoryStore) Clean() error

func (*MemoryStore) GetOpState

func (s *MemoryStore) GetOpState(_ 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