Documentation
¶
Overview ¶
* @Author: LinkLeong link@icewhale.com * @Date: 2021-12-20 14:15:46 * @LastEditors: LinkLeong * @LastEditTime: 2022-06-16 16:47:46 * @FilePath: /CasaOS/service/file.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.
* @Author: LinkLeong link@icewhale.com * @Date: 2021-09-30 18:18:14 * @LastEditors: LinkLeong * @LastEditTime: 2022-06-02 18:00:57 * @FilePath: /CasaOS/service/rely.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.
* @Author: LinkLeong link@icewhale.com * @Date: 2022-03-18 11:40:55 * @LastEditors: LinkLeong * @LastEditTime: 2022-06-23 19:45:49 * @FilePath: /CasaOS/service/user.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.
Index ¶
- Variables
- func CheckFileStatus()
- func Containerd()
- func Dial(msg model.MessageModel, server bool) (m model.MessageModel, err error)
- func DockerContainerStats1() error
- func DockerEx()
- func DockerImageRemove(name string) error
- func DockerLog()
- func DockerLogs()
- func DockerNetwork()
- func DockerPull()
- func Exec(container, row, col string) (hr types.HijackedResponse, err error)
- func ExecOpFile()
- func FileOperate(k string)
- func GetDeviceAllIP() []string
- func GetToken() string
- func LoopFriend()
- func MsqlExec(container string) error
- func NewReader(ctx context.Context, r io.Reader) io.Reader
- func NewWriter(ctx context.Context, w io.Writer) io.Writer
- func ProcessingContent(stream quic.Stream)
- func PushIpInfo(token string)
- func ReadContent(stream quic.Stream)
- func SaveFile(m model.MessageModel, stream quic.Stream) bool
- func SayHello(stream quic.Stream, to string)
- func SendData(stream quic.Stream, m model.MessageModel)
- func SendFileData(stream quic.Stream, filePath, to, uuid, t string) error
- func SendIPToServer()
- func SendMeg()
- func Summary(m model.MessageModel, t string)
- func UDPSendData(msg model.MessageModel, localFilePath string) error
- func UDPService()
- type AppService
- type CasaService
- type DiskService
- type DockerService
- type DownRecordService
- type DownloadService
- type FriendService
- type NotifyServer
- type PersonService
- type RelyService
- type Repository
- type ShortcutsService
- type SystemService
- type UserService
Constants ¶
This section is empty.
Variables ¶
var Cache *cache.Cache
var CancelList map[string]string
var ClientCount int = 0
var FileQueue sync.Map
var InternalInspection map[string][]string
var IpInfo model.PersionModel
var Message chan model.MessageModel
var NewVersionApp map[string]string
var NotifyMsg chan notify.Message
var OpStrArr []string
var PeopleMap map[string]quic.Stream
var ServiceMessage chan model.MessageModel
var SocketRun bool
var StreamList map[string]quic.Stream
var UDPAddressMap map[string]string
var UDPConn *net.UDPConn
var UserRegisterHash = make(map[string]string)
var WebSocketConns []*websocket.Conn
Functions ¶
func Containerd ¶
func Containerd()
func Dial ¶ added in v0.2.10
func Dial(msg model.MessageModel, server bool) (m model.MessageModel, err error)
func DockerContainerStats1 ¶
func DockerContainerStats1() error
func DockerImageRemove ¶
func DockerLogs ¶
func DockerLogs()
func ExecOpFile ¶ added in v0.3.2
func ExecOpFile()
func FileOperate ¶ added in v0.3.2
func FileOperate(k string)
func GetDeviceAllIP ¶ added in v0.2.9
func GetDeviceAllIP() []string
func LoopFriend ¶ added in v0.3.0
func LoopFriend()
func NewReader ¶ added in v0.2.4
NewReader wraps an io.Reader to handle context cancellation.
Context state is checked BEFORE every Read.
func PushIpInfo ¶ added in v0.2.9
func PushIpInfo(token string)
func SaveFile ¶ added in v0.3.1
func SaveFile(m model.MessageModel, stream quic.Stream) bool
Save file fragment
func SendFileData ¶ added in v0.2.10
文件分片发送
func SendIPToServer ¶ added in v0.3.0
func SendIPToServer()
func UDPSendData ¶ added in v0.3.1
func UDPSendData(msg model.MessageModel, localFilePath string) error
func UDPService ¶ added in v0.3.0
func UDPService()
Types ¶
type AppService ¶
type AppService interface {
GetMyList(index, size int, position bool) (*[]model2.MyAppList, *[]model2.MyAppList)
SaveContainer(m model2.AppListDBModel)
GetUninstallInfo(id string) model2.AppListDBModel
DeleteApp(id string)
GetContainerInfo(name string) (types.Container, error)
GetAppDBInfo(id string) model2.AppListDBModel
UpdateApp(m model2.AppListDBModel)
GetSimpleContainerInfo(name string) (types.Container, error)
DelAppConfigDir(path string)
GetSystemAppList() []types.Container
GetHardwareUsageSteam()
GetHardwareUsage() []model.DockerStatsModel
GetAppStats(id string) string
GetAllDBApps() []model2.AppListDBModel
ImportApplications(casaApp bool)
CheckNewImage()
}
func NewAppService ¶
func NewAppService(db *gorm.DB) AppService
type CasaService ¶
type CasaService interface {
GetServerList(index, size, tp, categoryId, key string) model.ServerAppListCollection
GetServerCategoryList() []model.CategoryList
GetServerAppInfo(id, t string, language string) model.ServerAppList
PushHeart(id, t string, language string)
PushConnectionStatus(uuid, err string, from, to, event string)
PushUserInfo()
GetPersonPublic() (list []model.FriendsModel)
GetCasaosVersion() model.Version
AsyncGetServerList() (collection model.ServerAppListCollection)
AsyncGetServerCategoryList() []model.CategoryList
}
func NewCasaService ¶ added in v0.2.10
func NewCasaService() CasaService
type DiskService ¶
type DiskService interface {
GetPlugInDisk() []string
LSBLK(isUseCache bool) []model.LSBLKModel
SmartCTL(path string) model.SmartctlA
FormatDisk(path, format string) []string
UmountPointAndRemoveDir(path string) []string
GetDiskInfo(path string) model.LSBLKModel
DelPartition(path, num string) string
AddPartition(path string) string
GetDiskInfoByPath(path string) *disk.UsageStat
MountDisk(path, volume string)
GetSerialAll() []model2.SerialDisk
SaveMountPoint(m model2.SerialDisk)
DeleteMountPoint(path, mountPoint string)
DeleteMount(id string)
UpdateMountPoint(m model2.SerialDisk)
RemoveLSBLKCache()
}
func NewDiskService ¶
func NewDiskService(db *gorm.DB) DiskService
type DockerService ¶
type DockerService interface {
DockerPullImage(imageName string, icon, name string) error
IsExistImage(imageName string) bool
DockerContainerCreate(imageName string, m model.CustomizationPostData) (containerId string, err error)
DockerContainerCopyCreate(info *types.ContainerJSON) (containerId string, err error)
DockerContainerStart(name string) error
DockerContainerStats(name string) (string, error)
DockerListByName(name string) (*types.Container, error)
DockerListByImage(image, version string) (*types.Container, error)
DockerContainerInfo(name string) (*types.ContainerJSON, error)
DockerImageRemove(name string) error
DockerContainerRemove(name string, update bool) error
DockerContainerStop(id string) error
DockerContainerUpdateName(name, id string) (err error)
DockerContainerUpdate(m model.CustomizationPostData, id string) (err error)
DockerContainerLog(name string) (string, error)
DockerContainerCommit(name string)
DockerContainerList() []types.Container
DockerNetworkModelList() []types.NetworkResource
DockerImageInfo(image string) (types.ImageInspect, error)
GetNetWorkNameByNetWorkID(id string) (string, error)
ContainerExecShell(container_id string) string
}
func NewDockerService ¶ added in v0.2.3
func NewDockerService() DockerService
type DownRecordService ¶ added in v0.3.1
type DownRecordService interface {
AddDownRecord(m model2.PersonDownRecordDBModel)
GetDownloadListByFrom(id string) []model2.PersonDownRecordDBModel
GetDownloadListByPath(path string) (list []model2.PersonDownRecordDBModel)
}
func NewDownRecordService ¶ added in v0.3.1
func NewDownRecordService(db *gorm.DB) DownRecordService
type DownloadService ¶ added in v0.3.0
type DownloadService interface {
AddDownloadTask(m model2.PersonDownloadDBModel) //添加下载任务
EditDownloadState(m model2.PersonDownloadDBModel) //只修改状态
SaveDownload(m model2.PersonDownloadDBModel)
DelDownload(uuid string)
GetDownloadById(uuid string) model2.PersonDownloadDBModel
GetDownloadListByState(state string, t int) []model2.PersonDownloadDBModel
SetDownloadError(m model2.PersonDownloadDBModel)
GetDownloadListByPath(m model2.PersonDownloadDBModel) int
}
func NewDownloadService ¶ added in v0.3.0
func NewDownloadService(db *gorm.DB) DownloadService
type FriendService ¶ added in v0.3.0
type FriendService interface {
AddFriend(m model2.FriendModel)
DeleteFriend(m model2.FriendModel)
EditFriendMark(m model2.FriendModel)
EditFriendWrite(m model2.FriendModel)
EditFriendBlock(m model2.FriendModel)
GetFriendById(m model2.FriendModel) model2.FriendModel
GetFriendList() (list []model2.FriendModel)
GetFriendListRemote() (list []model2.FriendModel)
UpdateAddFriendType(m model2.FriendModel)
AgreeFrined(id string)
GetFriendByToken(token string) model2.FriendModel
UpdateOrCreate(m model2.FriendModel)
InternalInspection(ips []string, token string)
}
func NewFriendService ¶ added in v0.3.0
func NewFriendService(db *gorm.DB) FriendService
type NotifyServer ¶
type NotifyServer interface {
GetLog(id string) model.AppNotify
AddLog(log model.AppNotify)
UpdateLog(log model.AppNotify)
UpdateLogByCustomId(log model.AppNotify)
DelLog(id string)
GetList(c int) (list []model.AppNotify)
MarkRead(id string, state int)
// SendText(m model.AppNotify)
SendUninstallAppBySocket(app notify.Application)
SendNetInfoBySocket(netList []model2.IOCountersStat)
SendCPUInfoBySocket(cpu map[string]interface{})
SendMemInfoBySocket(mem map[string]interface{})
SendUSBInfoBySocket(list []model2.DriveUSB)
SendDiskInfoBySocket(disk model2.Summary)
SendPersonStatusBySocket(status notify.Person)
SendFileOperateNotify(nowSend bool)
SendInstallAppBySocket(app notify.Application)
SendAllHardwareStatusBySocket(disk model2.Summary, list []model2.DriveUSB, mem map[string]interface{}, cpu map[string]interface{}, netList []model2.IOCountersStat)
}
func NewNotifyService ¶
func NewNotifyService(db *gorm.DB) NotifyServer
type PersonService ¶ added in v0.2.9
type PersonService interface {
GetPersionInfo(token string) (m model.PersionModel, err error)
GetPersionNetWorkTypeDetection() string
}
func NewPersonService ¶ added in v0.2.9
func NewPersonService(db *gorm.DB) PersonService
type RelyService ¶
type RelyService interface {
Create(rely model2.RelyDBModel)
Delete(id string)
GetInfo(id string) model2.RelyDBModel
}
func NewRelyService ¶
func NewRelyService(db *gorm.DB) RelyService
type Repository ¶
type Repository interface {
App() AppService
User() UserService
Docker() DockerService
Casa() CasaService
Disk() DiskService
Notify() NotifyServer
Rely() RelyService
System() SystemService
Shortcuts() ShortcutsService
Person() PersonService
Friend() FriendService
Download() DownloadService
DownRecord() DownRecordService
}
var MyService Repository
func NewService ¶
func NewService(db *gorm.DB) Repository
type ShortcutsService ¶
type ShortcutsService interface {
DeleteData(id string)
AddData(m model2.ShortcutsDBModel)
EditData(m model2.ShortcutsDBModel)
GetList() (list []model2.ShortcutsDBModel)
}
func NewShortcutsService ¶
func NewShortcutsService(db *gorm.DB) ShortcutsService
type SystemService ¶
type SystemService interface {
UpSystemConfig(str string, widget string)
UpdateSystemVersion(version string)
GetSystemConfigDebug() []string
GetCasaOSLogs(lineNumber int) string
UpdateAssist()
UpSystemPort(port string)
GetTimeZone() string
UpdateUSBAutoMount(state string)
ExecUSBAutoMountShell(state string)
UpAppOrderFile(str, id string)
GetAppOrderFile(id string) []byte
GetNet(physics bool) []string
GetNetInfo() []net.IOCountersStat
GetCpuCoreNum() int
GetCpuPercent() float64
GetMemInfo() map[string]interface{}
GetCpuInfo() []cpu.InfoStat
GetDirPath(path string) []model.Path
GetDirPathOne(path string) (m model.Path)
GetNetState(name string) string
GetDiskInfo() *disk.UsageStat
GetSysInfo() host.InfoStat
GetDeviceTree() string
CreateFile(path string) (int, error)
RenameFile(oldF, newF string) (int, error)
MkdirAll(path string) (int, error)
}
func NewSystemService ¶
func NewSystemService() SystemService
type UserService ¶
type UserService interface {
SetUser(username, pwd, token, email, desc, nickName string) error
UpLoadFile(file multipart.File, name string) error
CreateUser(m model.UserDBModel) model.UserDBModel
GetUserCount() (userCount int64)
UpdateUser(m model.UserDBModel)
UpdateUserPassword(m model.UserDBModel)
GetUserInfoById(id string) (m model.UserDBModel)
GetUserAllInfoById(id string) (m model.UserDBModel)
GetUserAllInfoByName(userName string) (m model.UserDBModel)
DeleteUserById(id string)
GetUserInfoByUserName(userName string) (m model.UserDBModel)
GetAllUserName() (list []model.UserDBModel)
}
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
* @Author: LinkLeong link@icewhale.com * @Date: 2022-05-13 18:15:46 * @LastEditors: LinkLeong * @LastEditTime: 2022-05-30 17:33:21 * @FilePath: /CasaOS/service/model/o_container.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved.
|
* @Author: LinkLeong link@icewhale.com * @Date: 2022-05-13 18:15:46 * @LastEditors: LinkLeong * @LastEditTime: 2022-05-30 17:33:21 * @FilePath: /CasaOS/service/model/o_container.go * @Description: * @Website: https://www.casaos.io * Copyright (c) 2022 by icewhale, All Rights Reserved. |