environment

Documentation

Index

• Variables
• type ActorEnv
• type CleanFunc
• type CleanHandler
• type Effect
• type Environment
  • func (env *Environment) GetStateEnv(stateID string) ActorEnv
  • func (env *Environment) OnMapperChanged(et dao.EnventType, m dao.Mapper) (Effect, error)
  • func (env *Environment) StoreMappers(mappers []dao.Mapper) []dao.Mapper
• type IEnvironment
  • func NewEnvironment() IEnvironment
• type MapperCache
• type StateCache

Variables

var (
	ErrInvalidTQLKey = errors.New("invalid TQL key")
)

Types

type ActorEnv

type ActorEnv struct {
	Mappers   map[string]mapper.Mapper
	Tentacles []mapper.Tentacler
}

type CleanFunc

type CleanFunc func() []string

type CleanHandler

type CleanHandler func() []string

type Effect

type Effect struct {
	StateID        string
	MapperID       string
	EffectStateIDs []string
}

type Environment

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

func (*Environment) GetStateEnv

func (env *Environment) GetStateEnv(stateID string) ActorEnv

GetActorEnv returns Actor Environments.

func (*Environment) OnMapperChanged

func (env *Environment) OnMapperChanged(et dao.EnventType, m dao.Mapper) (Effect, error)

OnMapperChanged respond for mapper.

func (*Environment) StoreMappers

func (env *Environment) StoreMappers(mappers []dao.Mapper) []dao.Mapper

type IEnvironment

type IEnvironment interface {
	GetStateEnv(string) ActorEnv
	StoreMappers([]dao.Mapper) []dao.Mapper
	OnMapperChanged(dao.EnventType, dao.Mapper) (Effect, error)
}

func NewEnvironment

func NewEnvironment() IEnvironment

NewEnvironment returns *Environment.

type MapperCache

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

cache for state machine.

type StateCache

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