ability

Documentation

Index

• func AsyncExecute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) (chan *common_type.AbilityResponse, error)
• func CancelAbility(instanceID string)
• func CheckAbility(abilities []*types.Ability) bool
• func GetConfig(instanceID, abilityID string) (map[string]string, error)
• func InitAbility()
• func RegisterAbility(instanceID string, abilities []*types.Ability)
• func SyncExecute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) ([]byte, error)
• type Ability
  • func NewAbility() *Ability
  • func (a *Ability) Cancel(instanceID string)
  • func (a *Ability) Check(abilities []*types.Ability) bool
  • func (a *Ability) Execute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) (chan *common_type.AbilityResponse, error)
  • func (a *Ability) GetConfig(instanceID, abilityID string) (map[string]string, error)
  • func (a *Ability) Register(instanceID string, abilities []*types.Ability)
  • func (a *Ability) Search(instanceID, abilityID string) (*types.Ability, error)
  • func (a *Ability) SyncExecute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) ([]byte, error)

Functions

func AsyncExecute

func AsyncExecute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) (chan *common_type.AbilityResponse, error)

func CancelAbility

func CancelAbility(instanceID string)

func CheckAbility

func CheckAbility(abilities []*types.Ability) bool

func GetConfig

func GetConfig(instanceID, abilityID string) (map[string]string, error)

func InitAbility

func InitAbility()

func RegisterAbility

func RegisterAbility(instanceID string, abilities []*types.Ability)

func SyncExecute

func SyncExecute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) ([]byte, error)

Types

type Ability

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

func NewAbility

func NewAbility() *Ability

func (*Ability) Cancel

func (a *Ability) Cancel(instanceID string)

func (*Ability) Check

func (a *Ability) Check(abilities []*types.Ability) bool

TODO 检测是否完整实现了Ability的所有函数

func (*Ability) Execute

func (a *Ability) Execute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) (chan *common_type.AbilityResponse, error)

func (*Ability) GetConfig

func (a *Ability) GetConfig(instanceID, abilityID string) (map[string]string, error)

func (*Ability) Register

func (a *Ability) Register(instanceID string, abilities []*types.Ability)

func (*Ability) Search

func (a *Ability) Search(instanceID, abilityID string) (*types.Ability, error)

func (*Ability) SyncExecute

func (a *Ability) SyncExecute(instanceID, abilityID, abilityType, abilityFuncKey string, arg []byte) ([]byte, error)