Documentation ¶
Index ¶
- func NewAbility(plugin common_type.IPlugin, sender common.Sender) common_type.Ability
- func NewEvent(plugin common_type.IPlugin, sender common.Sender) common_type.EventPublisher
- func NewLocalDB(plugin common_type.IPlugin, sender common.Sender) common_type.LocalDB
- func NewSpace(plugin common_type.IPlugin, sender common.Sender) common_type.Workspace
- type APICore
- type Ability
- type CommonDB
- func (d *CommonDB) CommonAsyncSelect(db, sql string, callback common_type.DBCallBack)
- func (d *CommonDB) CommonExec(db, sql string) common_type.PluginError
- func (d *CommonDB) CommonSelect(db, sql string) ([]*common_type.RawData, []*common_type.ColumnDesc, common_type.PluginError)
- func (d *CommonDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, ...) common_type.PluginError
- type CommonNetwork
- type EventPublisher
- type LocalDB
- func (d *LocalDB) AsyncSelect(sql string, callback common_type.DBCallBack)
- func (d *LocalDB) Exec(sql string) common_type.PluginError
- func (d *LocalDB) ImportSQL(sqlFilePath string) common_type.PluginError
- func (d *LocalDB) Select(sql string) ([]*common_type.RawData, []*common_type.ColumnDesc, common_type.PluginError)
- func (d *LocalDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, ...) common_type.PluginError
- type Logger
- type Outdoor
- type Resource
- func (r *Resource) GetAPICore() common_type.APICore
- func (r *Resource) GetAbility() common_type.Ability
- func (r *Resource) GetEventPublisher() common_type.EventPublisher
- func (r *Resource) GetLocalDB() common_type.LocalDB
- func (r *Resource) GetLogger() common_type.PluginLogger
- func (r *Resource) GetOutDoor() common_type.Network
- func (r *Resource) GetSysDB() common_type.SysDB
- func (r *Resource) GetWorkspace() common_type.Workspace
- type ResourceFactor
- type Space
- func (s *Space) AppendBytes(name string, byteSlice []byte) common_type.PluginError
- func (s *Space) AppendStrings(name string, content []string) common_type.PluginError
- func (s *Space) AsyncCopy(originalPath string, newPath string, ...)
- func (s *Space) AsyncGz(name string, callback common_type.AsyncInvokeCallbackParams)
- func (s *Space) AsyncUnGz(name, targetFile string, callback common_type.AsyncInvokeCallbackParams)
- func (s *Space) AsyncUnZip(name, targetDir string, callback common_type.AsyncInvokeCallbackParams)
- func (s *Space) AsyncZip(outFileName string, targetFiles []string, ...)
- func (s *Space) Copy(originalPath string, newPath string) common_type.PluginError
- func (s *Space) CreateFile(name string) common_type.PluginError
- func (s *Space) Gz(name string) common_type.PluginError
- func (s *Space) Hash(name string) ([]byte, common_type.PluginError)
- func (s *Space) IsDir(name string) (bool, common_type.PluginError)
- func (s *Space) IsExist(name string) (bool, common_type.PluginError)
- func (s *Space) List(dirName string) ([]string, common_type.PluginError)
- func (s *Space) MakeDir(dirname string) common_type.PluginError
- func (s *Space) Read(name string) ([]byte, common_type.PluginError)
- func (s *Space) ReadLines(name string, readLineBegin, readLineEnd int32) ([]byte, common_type.PluginError)
- func (s *Space) Remove(name string) common_type.PluginError
- func (s *Space) Rename(originalPath, newPath string) common_type.PluginError
- func (s *Space) UnGz(name, targetFile string) common_type.PluginError
- func (s *Space) UnZip(name, targetDir string) common_type.PluginError
- func (s *Space) WriteBytes(name string, byteSlice []byte) common_type.PluginError
- func (s *Space) WriteStrings(name string, content []string) common_type.PluginError
- func (s *Space) Zip(outFileName string, targetFiles []string) common_type.PluginError
- type SysDB
- func (d *SysDB) AsyncSelect(db, sql string, callback common_type.DBCallBack)
- func (d *SysDB) Exec(db, sql string) common_type.PluginError
- func (d *SysDB) Select(db, sql string) ([]*common_type.RawData, []*common_type.ColumnDesc, common_type.PluginError)
- func (d *SysDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, ...) common_type.PluginError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAbility ¶
func NewAbility(plugin common_type.IPlugin, sender common.Sender) common_type.Ability
func NewEvent ¶
func NewEvent(plugin common_type.IPlugin, sender common.Sender) common_type.EventPublisher
func NewLocalDB ¶
func NewLocalDB(plugin common_type.IPlugin, sender common.Sender) common_type.LocalDB
func NewSpace ¶
func NewSpace(plugin common_type.IPlugin, sender common.Sender) common_type.Workspace
Types ¶
type APICore ¶
type APICore struct {
// contains filtered or unexported fields
}
func NewAPICore ¶
func NewAPICore(plugin common_type.IPlugin, sender common.Sender) *APICore
func (*APICore) Fetch ¶
func (a *APICore) Fetch(httpRequest *common_type.HttpRequest) *common_type.HttpResponse
type Ability ¶
type Ability struct {
// contains filtered or unexported fields
}
func (*Ability) Call ¶
func (a *Ability) Call(kind string, req []byte) (result []byte, err common_type.PluginError)
type CommonDB ¶
type CommonDB struct {
// contains filtered or unexported fields
}
func NewCommonDB ¶
func NewCommonDB(plugin common_type.IPlugin, sender common.Sender) *CommonDB
func (*CommonDB) CommonAsyncSelect ¶
func (d *CommonDB) CommonAsyncSelect(db, sql string, callback common_type.DBCallBack)
func (*CommonDB) CommonExec ¶
func (d *CommonDB) CommonExec(db, sql string) common_type.PluginError
func (*CommonDB) CommonSelect ¶
func (d *CommonDB) CommonSelect(db, sql string) ([]*common_type.RawData, []*common_type.ColumnDesc, common_type.PluginError)
func (*CommonDB) Unmarshal ¶
func (d *CommonDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, v interface{}) common_type.PluginError
type CommonNetwork ¶
type CommonNetwork struct { Type protocol.HttpResourceMessage_HttpResourceType // contains filtered or unexported fields }
type EventPublisher ¶
type EventPublisher struct {
// contains filtered or unexported fields
}
func (*EventPublisher) Subscribe ¶
func (event *EventPublisher) Subscribe(condition []string) common_type.PluginError
func (*EventPublisher) SubscribeWithFilter ¶
func (event *EventPublisher) SubscribeWithFilter(condition []string, filter map[string][]string) common_type.PluginError
func (*EventPublisher) Unsubscribe ¶
func (event *EventPublisher) Unsubscribe(condition []string) common_type.PluginError
type LocalDB ¶
type LocalDB struct {
// contains filtered or unexported fields
}
func (*LocalDB) AsyncSelect ¶
func (d *LocalDB) AsyncSelect(sql string, callback common_type.DBCallBack)
func (*LocalDB) Exec ¶
func (d *LocalDB) Exec(sql string) common_type.PluginError
func (*LocalDB) ImportSQL ¶
func (d *LocalDB) ImportSQL(sqlFilePath string) common_type.PluginError
func (*LocalDB) Select ¶
func (d *LocalDB) Select(sql string) ([]*common_type.RawData, []*common_type.ColumnDesc, common_type.PluginError)
func (*LocalDB) Unmarshal ¶
func (d *LocalDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, v interface{}) common_type.PluginError
type Outdoor ¶
type Outdoor struct {
// contains filtered or unexported fields
}
func NewOutdoor ¶
func NewOutdoor(plugin common_type.IPlugin, sender common.Sender) *Outdoor
func (*Outdoor) AsyncFetch ¶
func (o *Outdoor) AsyncFetch(httpRequest *common_type.HttpRequest, callback common_type.NetworkCallBack)
func (*Outdoor) Fetch ¶
func (o *Outdoor) Fetch(httpRequest *common_type.HttpRequest) *common_type.HttpResponse
type Resource ¶
type Resource struct { Plugin common_type.IPlugin Sender common.Sender // contains filtered or unexported fields }
func (*Resource) GetAPICore ¶
func (r *Resource) GetAPICore() common_type.APICore
func (*Resource) GetAbility ¶
func (r *Resource) GetAbility() common_type.Ability
func (*Resource) GetEventPublisher ¶
func (r *Resource) GetEventPublisher() common_type.EventPublisher
func (*Resource) GetLocalDB ¶
func (r *Resource) GetLocalDB() common_type.LocalDB
func (*Resource) GetLogger ¶
func (r *Resource) GetLogger() common_type.PluginLogger
func (*Resource) GetOutDoor ¶
func (r *Resource) GetOutDoor() common_type.Network
func (*Resource) GetSysDB ¶
func (r *Resource) GetSysDB() common_type.SysDB
func (*Resource) GetWorkspace ¶
func (r *Resource) GetWorkspace() common_type.Workspace
type ResourceFactor ¶
type ResourceFactor func(plugin common_type.IPlugin, sender common.Sender) common_type.IResources
func (ResourceFactor) GetResource ¶
func (f ResourceFactor) GetResource(plugin common_type.IPlugin, sender common.Sender) common_type.IResources
type Space ¶
type Space struct {
// contains filtered or unexported fields
}
func (*Space) AppendBytes ¶
func (s *Space) AppendBytes(name string, byteSlice []byte) common_type.PluginError
func (*Space) AppendStrings ¶
func (s *Space) AppendStrings(name string, content []string) common_type.PluginError
func (*Space) AsyncCopy ¶
func (s *Space) AsyncCopy(originalPath string, newPath string, callback common_type.AsyncInvokeCallbackParams)
func (*Space) AsyncGz ¶
func (s *Space) AsyncGz(name string, callback common_type.AsyncInvokeCallbackParams)
func (*Space) AsyncUnGz ¶
func (s *Space) AsyncUnGz(name, targetFile string, callback common_type.AsyncInvokeCallbackParams)
func (*Space) AsyncUnZip ¶
func (s *Space) AsyncUnZip(name, targetDir string, callback common_type.AsyncInvokeCallbackParams)
func (*Space) AsyncZip ¶
func (s *Space) AsyncZip(outFileName string, targetFiles []string, callback common_type.AsyncInvokeCallbackParams)
func (*Space) Copy ¶
func (s *Space) Copy(originalPath string, newPath string) common_type.PluginError
func (*Space) CreateFile ¶
func (s *Space) CreateFile(name string) common_type.PluginError
func (*Space) Gz ¶
func (s *Space) Gz(name string) common_type.PluginError
func (*Space) Hash ¶
func (s *Space) Hash(name string) ([]byte, common_type.PluginError)
func (*Space) IsDir ¶
func (s *Space) IsDir(name string) (bool, common_type.PluginError)
func (*Space) IsExist ¶
func (s *Space) IsExist(name string) (bool, common_type.PluginError)
func (*Space) List ¶
func (s *Space) List(dirName string) ([]string, common_type.PluginError)
func (*Space) MakeDir ¶
func (s *Space) MakeDir(dirname string) common_type.PluginError
func (*Space) Read ¶
func (s *Space) Read(name string) ([]byte, common_type.PluginError)
func (*Space) ReadLines ¶
func (s *Space) ReadLines(name string, readLineBegin, readLineEnd int32) ([]byte, common_type.PluginError)
func (*Space) Remove ¶
func (s *Space) Remove(name string) common_type.PluginError
func (*Space) Rename ¶
func (s *Space) Rename(originalPath, newPath string) common_type.PluginError
func (*Space) UnGz ¶
func (s *Space) UnGz(name, targetFile string) common_type.PluginError
func (*Space) UnZip ¶
func (s *Space) UnZip(name, targetDir string) common_type.PluginError
func (*Space) WriteBytes ¶
func (s *Space) WriteBytes(name string, byteSlice []byte) common_type.PluginError
func (*Space) WriteStrings ¶
func (s *Space) WriteStrings(name string, content []string) common_type.PluginError
func (*Space) Zip ¶
func (s *Space) Zip(outFileName string, targetFiles []string) common_type.PluginError
type SysDB ¶
type SysDB struct {
// contains filtered or unexported fields
}
func (*SysDB) AsyncSelect ¶
func (d *SysDB) AsyncSelect(db, sql string, callback common_type.DBCallBack)
func (*SysDB) Exec ¶
func (d *SysDB) Exec(db, sql string) common_type.PluginError
func (*SysDB) Select ¶
func (d *SysDB) Select(db, sql string) ([]*common_type.RawData, []*common_type.ColumnDesc, common_type.PluginError)
func (*SysDB) Unmarshal ¶
func (d *SysDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, v interface{}) common_type.PluginError
Click to show internal directories.
Click to hide internal directories.