Documentation
¶
Index ¶
- type KisConnector
- func (conn *KisConnector) Call(ctx context.Context, flow kis.Flow, args interface{}) (interface{}, error)
- func (conn *KisConnector) GetConfig() *config.KisConnConfig
- func (conn *KisConnector) GetId() string
- func (conn *KisConnector) GetMetaData(key string) interface{}
- func (conn *KisConnector) GetName() string
- func (conn *KisConnector) Init() error
- func (conn *KisConnector) SetMetaData(key string, value interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KisConnector ¶
type KisConnector struct {
// Connector ID
CId string
// Connector Name
CName string
// Connector Config
Conf *config.KisConnConfig
// contains filtered or unexported fields
}
func NewKisConnector ¶
func NewKisConnector(config *config.KisConnConfig) *KisConnector
NewKisConnector 根据配置策略创建一个KisConnector
func (*KisConnector) Call ¶
func (conn *KisConnector) Call(ctx context.Context, flow kis.Flow, args interface{}) (interface{}, error)
Call 调用Connector 外挂存储逻辑的读写操作
func (*KisConnector) GetConfig ¶
func (conn *KisConnector) GetConfig() *config.KisConnConfig
func (*KisConnector) GetId ¶
func (conn *KisConnector) GetId() string
func (*KisConnector) GetMetaData ¶
func (conn *KisConnector) GetMetaData(key string) interface{}
GetMetaData 得到当前Connector的临时数据
func (*KisConnector) GetName ¶
func (conn *KisConnector) GetName() string
func (*KisConnector) SetMetaData ¶
func (conn *KisConnector) SetMetaData(key string, value interface{})
SetMetaData 设置当前Connector的临时数据
Source Files
Click to show internal directories.
Click to hide internal directories.