release

package
v0.0.0-...-f13fc7a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 13, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

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 (*LocalDB) Unmarshal

func (d *LocalDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, v interface{}) common_type.PluginError

type Logger

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

func NewLogger

func NewLogger(plugin common_type.IPlugin, sender common.Sender) *Logger

func (*Logger) Error

func (l *Logger) Error(content string)

func (*Logger) Info

func (l *Logger) Info(content string)

func (*Logger) Trace

func (l *Logger) Trace(content string)

func (*Logger) Warn

func (l *Logger) Warn(content string)

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 NewSysDB

func NewSysDB(plugin common_type.IPlugin, sender common.Sender) *SysDB

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 (*SysDB) Unmarshal

func (d *SysDB) Unmarshal(rawData []*common_type.RawData, columnDesc []*common_type.ColumnDesc, v interface{}) common_type.PluginError

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL