state

type APIHandler func(context.Context, message.Context) ([]WatchKey, error)

type APIID string

type ItemsData struct {
	ID           string   `json:"id"`
	Type         string   `json:"type"`
	Owner        string   `json:"owner"`
	Source       string   `json:"source"`
	PropertyKeys []string `json:"property_keys"`
}

type Machiner interface {
	// GetID return state machine id.
	GetID() string
	// GetEntity returns this.Entity.
	GetEntity() *dao.Entity
	// Context return state context.
	Context() *StateContext
	// OnMessage recv message from pubsub.
	Invoke(ctx context.Context, msgCtx message.Context) Result
	// Flush flush entity data.
	Flush(ctx context.Context) error
}

type ManagerMock struct {
}

type Mapper struct {
	ID          string `json:"id" msgpack:"id"`
	TQL         string `json:"tql" msgpack:"tql"`
	Name        string `json:"name" msgpack:"name"`
	Description string `json:"description" msgpack:"description"`
}

type MessageHandler = func(context.Context, message.Context) []WatchKey

type PatchData struct {
	Path     string      `json:"path"`
	Operator string      `json:"operator"`
	Value    interface{} `json:"value"`
}

type RawData struct {
	ID        string `json:"id"`
	Type      string `json:"type"`
	Mark      string `json:"mark"`
	Path      string `json:"path"`
	Values    string `json:"values"`
	Timestamp int64  `json:"ts"` //nolint
}

type Result struct {
	Err    error
	Status Status
}

type State struct {
	ID    string
	Props map[string]tdtl.Node
}

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

type Status string

type WatchKey = mapper.WatchKey