function

Documentation

Index

• func NewKisFunction(flow kis.Flow, config *config.KisFuncConfig) kis.Function
• func NewKisFunctionC() kis.Function
• func NewKisFunctionE() kis.Function
• func NewKisFunctionL() kis.Function
• func NewKisFunctionS() kis.Function
• func NewKisFunctionV() kis.Function
• type BaseFunction
  • func (base *BaseFunction) AddConnector(conn kis.Connector) error
  • func (base *BaseFunction) Call(ctx context.Context, flow kis.Flow) error
  • func (base *BaseFunction) CreateId()
  • func (base *BaseFunction) GetConfig() *config.KisFuncConfig
  • func (base *BaseFunction) GetConnector() kis.Connector
  • func (base *BaseFunction) GetFlow() kis.Flow
  • func (base *BaseFunction) GetId() string
  • func (base *BaseFunction) GetMetaData(key string) interface{}
  • func (base *BaseFunction) GetNextId() string
  • func (base *BaseFunction) GetPrevId() string
  • func (base *BaseFunction) Next() kis.Function
  • func (base *BaseFunction) Prev() kis.Function
  • func (base *BaseFunction) SetConfig(s *config.KisFuncConfig) error
  • func (base *BaseFunction) SetFlow(f kis.Flow) error
  • func (base *BaseFunction) SetMetaData(key string, value interface{})
  • func (base *BaseFunction) SetN(f kis.Function)
  • func (base *BaseFunction) SetP(f kis.Function)
• type KisFunctionC
  • func (f *KisFunctionC) Call(ctx context.Context, flow kis.Flow) error
• type KisFunctionE
  • func (f *KisFunctionE) Call(ctx context.Context, flow kis.Flow) error
• type KisFunctionL
  • func (f *KisFunctionL) Call(ctx context.Context, flow kis.Flow) error
• type KisFunctionS
  • func (f *KisFunctionS) Call(ctx context.Context, flow kis.Flow) error
• type KisFunctionV
  • func (f *KisFunctionV) Call(ctx context.Context, flow kis.Flow) error

Functions

func NewKisFunction

func NewKisFunction(flow kis.Flow, config *config.KisFuncConfig) kis.Function

NewKisFunction 创建一个NsFunction flow: 当前所属的flow实例 s : 当前function的配置策略

func NewKisFunctionC

func NewKisFunctionC() kis.Function

func NewKisFunctionE

func NewKisFunctionE() kis.Function

func NewKisFunctionL

func NewKisFunctionL() kis.Function

func NewKisFunctionS

func NewKisFunctionS() kis.Function

func NewKisFunctionV

func NewKisFunctionV() kis.Function

Types

type BaseFunction

type BaseFunction struct {
	// Id , KisFunction的实例ID，用于KisFlow内部区分不同的实例对象
	Id     string
	Config *config.KisFuncConfig

	// link
	N kis.Function //下一个流计算Function
	P kis.Function //上一个流计算Function
	// contains filtered or unexported fields
}

func (*BaseFunction) AddConnector

func (base *BaseFunction) AddConnector(conn kis.Connector) error

AddConnector 给当前Function实例添加一个Connector

func (*BaseFunction) Call

func (base *BaseFunction) Call(ctx context.Context, flow kis.Flow) error

Call BaseFunction 为空实现，目的为了让其他具体类型的KisFunction，如KisFunction_V 来继承BaseFuncion来重写此方法

func (*BaseFunction) CreateId

func (base *BaseFunction) CreateId()

func (*BaseFunction) GetConfig

func (base *BaseFunction) GetConfig() *config.KisFuncConfig

func (*BaseFunction) GetConnector

func (base *BaseFunction) GetConnector() kis.Connector

GetConnector 获取当前Function实例所关联的Connector

func (*BaseFunction) GetFlow

func (base *BaseFunction) GetFlow() kis.Flow

func (*BaseFunction) GetId

func (base *BaseFunction) GetId() string

func (*BaseFunction) GetMetaData

func (base *BaseFunction) GetMetaData(key string) interface{}

GetMetaData 得到当前Function的临时数据

func (*BaseFunction) GetNextId

func (base *BaseFunction) GetNextId() string

func (*BaseFunction) GetPrevId

func (base *BaseFunction) GetPrevId() string

func (*BaseFunction) Next

func (base *BaseFunction) Next() kis.Function

func (*BaseFunction) Prev

func (base *BaseFunction) Prev() kis.Function

func (*BaseFunction) SetConfig

func (base *BaseFunction) SetConfig(s *config.KisFuncConfig) error

func (*BaseFunction) SetFlow

func (base *BaseFunction) SetFlow(f kis.Flow) error

func (*BaseFunction) SetMetaData

func (base *BaseFunction) SetMetaData(key string, value interface{})

SetMetaData 设置当前Function的临时数据

func (*BaseFunction) SetN

func (base *BaseFunction) SetN(f kis.Function)

func (*BaseFunction) SetP

func (base *BaseFunction) SetP(f kis.Function)

type KisFunctionC

type KisFunctionC struct {
	BaseFunction
}

func (*KisFunctionC) Call

func (f *KisFunctionC) Call(ctx context.Context, flow kis.Flow) error

type KisFunctionE

type KisFunctionE struct {
	BaseFunction
}

func (*KisFunctionE) Call

func (f *KisFunctionE) Call(ctx context.Context, flow kis.Flow) error

type KisFunctionL

type KisFunctionL struct {
	BaseFunction
}

func (*KisFunctionL) Call

func (f *KisFunctionL) Call(ctx context.Context, flow kis.Flow) error

type KisFunctionS

type KisFunctionS struct {
	BaseFunction
}

func (*KisFunctionS) Call

func (f *KisFunctionS) Call(ctx context.Context, flow kis.Flow) error

type KisFunctionV

type KisFunctionV struct {
	BaseFunction
}

func (*KisFunctionV) Call

func (f *KisFunctionV) Call(ctx context.Context, flow kis.Flow) error