fsm

type BaseFSMSnapshot struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type FSM interface {
	raft.FSM

	// Init is used to pass the original serializer from EasyRaft Node to be able to deserialize messages
	// coming from other nodes
	Init(ser serializer.Serializer)
}

type FSMService interface {
	// Name returns the unique ID/Name which will identify the FSM Service when it comes to routing incoming messages
	Name() string

	// NewLog is called when a new raft log message is committed in the cluster and matched with any of the GetReqDataTypes returned types
	// in this method we can handle what should happen when we got a new raft log regarding our FSM service
	NewLog(requestType interface{}, request map[string]interface{}) interface{}

	// GetReqDataTypes returns all the request structs which are used by this FSMService
	GetReqDataTypes() []interface{}

	// ApplySnapshot is used to decode and apply a snapshot to the FSMService
	ApplySnapshot(input interface{}) error
}

type InMemoryMapService struct {
	sync.RWMutex
	Maps map[string]*Map
}

type Map struct {
	sync.RWMutex
	Data map[string]interface{}
}

type MapGetRequest struct {
	MapName string
	Key     string
}

type MapPutRequest struct {
	MapName string
	Key     string
	Value   interface{}
}

type MapRemoveRequest struct {
	MapName string
	Key     string
}

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