runtime

Documentation

Index

• Constants
• Variables
• func NewManager(ctx context.Context, resourceManager types.ResourceManager, ...) (types.Manager, error)
• func NewResources(searchClient *search.Service, tseriesClient tseries.TimeSerier, ...) types.ResourceManager
• type Container
  • func NewContainer(ctx context.Context, id string, mgr *Manager) *Container
  • func (c *Container) Add(machine state.Machiner)
  • func (c *Container) Close()
  • func (c *Container) Get(stateID string) (machine state.Machiner, has bool)
  • func (c *Container) Load(ctx context.Context, stateID string) (machine state.Machiner, err error)
  • func (c *Container) MakeMachine(en *dao.Entity) (machine state.Machiner, err error)
  • func (c *Container) Remove(stateID string)
• type Manager
  • func (m *Manager) EscapedEntities(expression string) []string
  • func (m *Manager) HandleMessage(ctx context.Context, msgCtx message.Context) error
  • func (m *Manager) Resource() types.ResourceManager
  • func (m *Manager) Shutdown() error
  • func (m *Manager) Start() error
• type WatchKey

Constants

const (
	SMTypeBasic        = "BASIC"
	SMTypeSubscription = "SUBSCRIPTION"

	// state machine required fileds.
	SMFieldType     = "type"
	SMFieldOwner    = "owner"
	SMFieldSource   = "source"
	SMFieldTemplate = "template"
)

Variables

var (
	ErrInvalidParams       = errors.New("invalid params")
	ErrInvalidTQLKey       = errors.New("invalid TQL key")
	ErrSubscriptionInvalid = errors.New("invalid subscription")
)

Functions

func NewManager

func NewManager(ctx context.Context, resourceManager types.ResourceManager, dispatcher dispatch.Dispatcher) (types.Manager, error)

func NewResources

func NewResources(
	searchClient *search.Service,
	tseriesClient tseries.TimeSerier,
	repoClient repository.IRepository) types.ResourceManager

Types

type Container

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

func NewContainer

func NewContainer(ctx context.Context, id string, mgr *Manager) *Container

func (*Container) Add

func (c *Container) Add(machine state.Machiner)

func (*Container) Close

func (c *Container) Close()

func (*Container) Get

func (c *Container) Get(stateID string) (machine state.Machiner, has bool)

func (*Container) Load

func (c *Container) Load(ctx context.Context, stateID string) (machine state.Machiner, err error)

func (*Container) MakeMachine

func (c *Container) MakeMachine(en *dao.Entity) (machine state.Machiner, err error)

func (*Container) Remove

func (c *Container) Remove(stateID string)

type Manager

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

func (*Manager) EscapedEntities

func (m *Manager) EscapedEntities(expression string) []string

func (*Manager) HandleMessage

func (m *Manager) HandleMessage(ctx context.Context, msgCtx message.Context) error

func (*Manager) Resource

func (m *Manager) Resource() types.ResourceManager

Resource return resource manager.

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) Start

func (m *Manager) Start() error

type WatchKey

type WatchKey = mapper.WatchKey