ability

Dec 26, 2024

Changes in this version

+ type ICleanup interface

+ Cleanup func(ugn *utils.UserGroupNamespace) error

type SystemEventOption

+ func WithCleanupOption(cleanup ICleanup) SystemEventOption

Dec 14, 2024

Changes in this version

type GenericFS

+ AppGenUFI func(path string) string

type SyyFS

+ func (fs *SyyFS) AppGenUFI(path string) string

Dec 11, 2024

Changes in this version

+ type SystemEventMonitor struct

+ func NewSystemEventMonitor(fs *FS, appInfo *sdkdto.AppRegisterInfo, nc *nats.Conn, ...) *SystemEventMonitor

+ func (m *SystemEventMonitor) Close()

+ func (m *SystemEventMonitor) Name() string

+ type SystemEventOption func(monitor *SystemEventMonitor)

+ func WithMigrationOption(migrator IMigrator) SystemEventOption

Nov 9, 2024

Changes in this version

type IMigrator

+ Migrate func(ugn *utils.UserGroupNamespace) error

Nov 7, 2024

Changes in this version

+ type FileEventMonitor struct

+ func NewFileEventMonitor(appCode *string, nc *nats.Conn, preferOps ...sdkdto.PreferOptions) *FileEventMonitor

+ func (m *FileEventMonitor) Close()

+ func (m *FileEventMonitor) Name() string

+ type IMigrator interface

+ MigrateData func(ugn *utils.UserGroupNamespace) error

+ MigrateSchema func(ugn *utils.UserGroupNamespace) error

+ type Migrator struct

+ func NewMigrator(fs *FS, appInfo *sdkdto.AppRegisterInfo, nc *nats.Conn, handler IMigrator) *Migrator

+ func (m *Migrator) Close()

+ func (m *Migrator) Name() string

Nov 4, 2024

Changes in this version

type GenericFS

+ GetDB func() *gorm.DB

type SyyFS

+ func (fs *SyyFS) GetDB() *gorm.DB

Nov 2, 2024

Changes in this version

type GenericFS

+ GetUGN func() *utils.UserGroupNamespace

+ Stat func(ufi string) (*sdkdto.SiyouFileInfo, error)

type SyyFS

+ func (fs *SyyFS) GetUGN() *utils.UserGroupNamespace

+ func (fs *SyyFS) Stat(ufi string) (*sdkdto.SiyouFileInfo, error)

Sep 26, 2024

Changes in this version

type GenericFS

+ Chtimes2 func(ufiStr string, atime time.Time, mtime time.Time) error

+ Open2 func(ufiStr string) (File, error)

+ Remove2 func(ufiStr string) error

+ RemoveAll2 func(ufiStr string) error

type SyyFS

+ func (fs *SyyFS) Chtimes2(ufiStr string, atime time.Time, mtime time.Time) error

+ func (fs *SyyFS) Open2(ufiStr string) (File, error)

+ func (fs *SyyFS) Remove2(ufiStr string) error

+ func (fs *SyyFS) RemoveAll2(ufiStr string) error

Sep 26, 2024

Changes in this version

+ const CantFindOpenFileErr

+ const FileActionErr

+ const FileEOF

+ const NoErr

+ const NotInitErr

+ const OpenFileErr

+ const ParamErr

+ type File interface

+ Name func() string

+ Readdir func(count int) ([]*sdkdto.SiyouFileBasicInfo, error)

+ Readdirnames func(n int) ([]string, error)

+ Stat func() (*sdkdto.SiyouFileBasicInfo, error)

+ Sync func() error

+ Truncate func(size int64) error

+ WriteString func(s string) (ret int, err error)

type GenericFS

+ AppFileExists func(path string) bool

+ AppMkdirAll func(path string) error

+ AppOpenFile func(path string, flag int, perm os.FileMode) (File, error)

+ AppRemoveAll func(path string) error

+ type HTTPFile struct

+ func (H *HTTPFile) Close() error

+ func (H *HTTPFile) Name() string

+ func (H *HTTPFile) Read(p []byte) (int, error)

+ func (H *HTTPFile) ReadAt(p []byte, off int64) (int, error)

+ func (H *HTTPFile) Readdir(n int) ([]*sdkdto.SiyouFileBasicInfo, error)

+ func (H *HTTPFile) Readdirnames(n int) ([]string, error)

+ func (H *HTTPFile) Seek(offset int64, whence int) (int64, error)

+ func (H *HTTPFile) Stat() (*sdkdto.SiyouFileBasicInfo, error)

+ func (H *HTTPFile) Sync() error

+ func (H *HTTPFile) Truncate(size int64) error

+ func (H *HTTPFile) Write(p []byte) (int, error)

+ func (H *HTTPFile) WriteAt(p []byte, off int64) (int, error)

+ func (H *HTTPFile) WriteString(s string) (int, error)

type SyyFS

+ func (fs *SyyFS) AppFileExists(path string) bool

+ func (fs *SyyFS) AppMkdirAll(path string) error

+ func (fs *SyyFS) AppOpenFile(path string, flag int, perm os.FileMode) (File, error)

+ func (fs *SyyFS) AppRemoveAll(path string) error

Jul 11, 2024

Changes in this version

+ type Milvus struct

+ func NewMilvus(appCode *string) (*Milvus, error)

+ func (m *Milvus) Close()

+ func (m *Milvus) GenCollectionName(buzName string) string

+ func (m *Milvus) GenPartitionName(ugn *utils.UserGroupNamespace) string

+ func (m *Milvus) LoadAppCollection(ugn *utils.UserGroupNamespace, collectionName string, ...) error

+ func (m *Milvus) Name() string

Jul 10, 2024

Changes in this version

+ const AppPrefix

+ const SiyouyunPrefix

+ type AI struct

+ func NewAI() *AI

+ func (a *AI) Close()

+ func (a *AI) Name() string

+ type FFmpeg struct

+ func NewFFmpeg() *FFmpeg

+ func (ff *FFmpeg) Close()

+ func (ff *FFmpeg) GetBasicInfo(ugn *utils.UserGroupNamespace, parentPath, name string) (*sdkdto.FFmpegBasicInfo, error)

+ func (ff *FFmpeg) GetDetailInfo(ugn *utils.UserGroupNamespace, parentPath, name string) (*sdkdto.FFProbeInfo, error)

+ func (ff *FFmpeg) Name() string

+ type FS struct

+ func NewFS(appCode *string, db *gorm.DB) *FS

+ func (f *FS) Close()

+ func (f *FS) Name() string

+ func (f *FS) NewAppFSFromCtx(ctx iris.Context) GenericFS

+ func (f *FS) NewAppFSFromUserGroupNamespace(ugn *utils.UserGroupNamespace) GenericFS

+ func (f *FS) NewFSFromCtx(ctx iris.Context) GenericFS

+ func (f *FS) NewFSFromUserGroupNamespace(ugn *utils.UserGroupNamespace) GenericFS

+ type GenericFS interface

+ Chtimes func(path string, atime time.Time, mtime time.Time) error

+ Destroy func()

+ EnsureDirExist func(path string)

+ Exec func(f func(*gorm.DB) error) error

+ FileExists func(path string) bool

+ InodeToFileInfo func(inode uint64) *sdkdto.FileInfoRes

+ InodeToPath func(inode uint64) string

+ InodesToFileInfos func(inodes ...uint64) map[uint64]*sdkdto.FileInfoRes

+ MkdirAll func(path string) error

+ Open func(path string) (*os.File, error)

+ OpenAvatarFile func(path string) (*os.File, error)

+ OpenByInode func(inode uint64) (*os.File, error)

+ OpenFile func(path string, flag int, perm os.FileMode) (*os.File, error)

+ PathToInode func(path string) uint64

+ Remove func(path string) error

+ RemoveAll func(path string) error

+ Rename func(oldPath, newPath string) error

+ type KV struct

+ func NewKV(appCode *string) *KV

+ func (kv *KV) Close()

+ func (kv *KV) DeleteKV(ugn *utils.UserGroupNamespace, kvType, key string) error

+ func (kv *KV) GetKV(ugn *utils.UserGroupNamespace, kvType, key string) (*sdkdto.KV, bool)

+ func (kv *KV) Name() string

+ func (kv *KV) PutKV(ugn *utils.UserGroupNamespace, kvType, key, value string) error

+ type Message struct

+ func NewMessage(appCode *string, nc *nats.Conn) *Message

+ func (m *Message) AddHandler(desc string, triggerPhrasePerl string, ...)

+ func (m *Message) Close()

+ func (m *Message) Name() string

+ func (m *Message) SendMsg(ugn *utils.UserGroupNamespace, content string) error

+ type MessageEvent struct

+ Content string

+ SendByAdmin bool

+ SessionId string

+ UGN utils.UserGroupNamespace

+ UUID string

+ type Schedule struct

+ Handler map[string]ScheduleEventHandler

+ func NewSchedule(appCode *string) *Schedule

+ func (s *Schedule) AddCronScheduleEvent(ugn *utils.UserGroupNamespace, name string, payload []byte, cron string) (err error, eventId *int64)

+ func (s *Schedule) AddOnceScheduleEvent(ugn *utils.UserGroupNamespace, name string, payload []byte, remindTime int64) (err error, eventId *int64)

+ func (s *Schedule) Close()

+ func (s *Schedule) Name() string

+ func (s *Schedule) SetHandler(shs ...ScheduleEventHandler)

+ func (s *Schedule) UpdateCronScheduleEvent(ugn *utils.UserGroupNamespace, eventId int64, cron string) (err error)

+ func (s *Schedule) UpdateOnceScheduleEvent(ugn *utils.UserGroupNamespace, eventId int64, remindTime int64) (err error)

+ type ScheduleEvent struct

+ Name string

+ Payload []byte

+ RemindTime int64

+ UGN utils.UserGroupNamespace

+ type ScheduleEventHandler struct

+ Handler func(se *ScheduleEvent)

+ Name string

+ type SyyFS struct

+ func (fs *SyyFS) Chtimes(path string, atime time.Time, mtime time.Time) error

+ func (fs *SyyFS) Destroy()

+ func (fs *SyyFS) EnsureDirExist(path string)

+ func (fs *SyyFS) Exec(f func(*gorm.DB) error) error

+ func (fs *SyyFS) FileExists(path string) bool

+ func (fs *SyyFS) InodeToFileInfo(inode uint64) *sdkdto.FileInfoRes

+ func (fs *SyyFS) InodeToPath(inode uint64) string

+ func (fs *SyyFS) InodesToFileInfos(inodes ...uint64) map[uint64]*sdkdto.FileInfoRes

+ func (fs *SyyFS) MkdirAll(path string) error

+ func (fs *SyyFS) Open(path string) (*os.File, error)

+ func (fs *SyyFS) OpenAvatarFile(path string) (*os.File, error)

+ func (fs *SyyFS) OpenByInode(inode uint64) (*os.File, error)

+ func (fs *SyyFS) OpenFile(path string, flag int, perm os.FileMode) (*os.File, error)

+ func (fs *SyyFS) PathToInode(path string) uint64

+ func (fs *SyyFS) Remove(path string) error

+ func (fs *SyyFS) RemoveAll(path string) error

+ func (fs *SyyFS) Rename(oldPath, newPath string) error