gateway

package
v0.2.42 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KVApiPut    = "/put"
	KVApiDelete = "/delete"
	KVApiGet    = "/value"
)
View Source 
const (
	AppCodeQuery = "appCode"
	TypeQuery    = "type"
	KeyQuery     = "key"
	ValueQuery   = "value"
)
View Source 
const (
	ScheduleOnceCreateApi = "/once/create"
	ScheduleOnceUpdateApi = "/once/update"
	ScheduleCronCreateApi = "/cron/create"
	ScheduleCronUpdateApi = "/cron/update"
)
View Source 
const CoreHTTPPort = 40100
View Source 
const LocalhostAddress = "http://10.62.0.1"
View Source 
const OSHTTPPort = 40000
View Source 
const UnixSocketPrefix = "/siyouyun/unix-socket/"

Variables

This section is empty.

Functions

func GetAppInfo 

func GetAppInfo(code string) (*sdkentity.AppRegisterInfo, error)

func RegisterMessageRobot added in v0.2.20 

func RegisterMessageRobot(appCode, robotDesc string) error

func SendMessage added in v0.2.20 

func SendMessage(un *utils.UserNamespace, appCode, content, replyUUID string) error

Types

type CronCreateBody added in v0.2.29 

type CronCreateBody struct {
	AppCode   string `json:"appCode"`
	Username  string `json:"username"`
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	Payload   []byte `json:"payload"`
	Cron      string `json:"cron"`
}

type FFmpegOSApi added in v0.2.3 

type FFmpegOSApi struct {
	Host string
	*utils.UserNamespace
}

func NewFFmpegOSApi added in v0.2.3 

func NewFFmpegOSApi(un *utils.UserNamespace) *FFmpegOSApi

func (*FFmpegOSApi) GetInfo added in v0.2.3 

func (kv *FFmpegOSApi) GetInfo(parentPath, name string) (*sdkdto.FFProbeInfo, error)

GetInfo GetInfo

type KVCoreApi added in v0.2.3 

type KVCoreApi struct {
	Host    string
	AppCode string
	*utils.UserNamespace
}

func NewKVCoreApi added in v0.2.3 

func NewKVCoreApi(appCode string, un *utils.UserNamespace) *KVCoreApi

func (*KVCoreApi) DeleteKV added in v0.2.3 

func (kv *KVCoreApi) DeleteKV(kvType, key string) error

DeleteKV DeleteKV

func (*KVCoreApi) GetKV added in v0.2.3 

func (kv *KVCoreApi) GetKV(kvType, key string) (*sdkdto.KV, bool)

GetKV GetKV

func (*KVCoreApi) PutKV added in v0.2.3 

func (kv *KVCoreApi) PutKV(kvType, key, value string) error

PutKV PutKV

type OnceCreateBody added in v0.2.29 

type OnceCreateBody struct {
	AppCode    string `json:"appCode"`
	Username   string `json:"username"`
	Namespace  string `json:"namespace"`
	Name       string `json:"name"`
	Payload    []byte `json:"payload"`
	RemindTime int64  `json:"remindTime"`
}

type ScheduleApi added in v0.2.29 

type ScheduleApi struct {
	Host    string
	AppCode string
	*utils.UserNamespace
}

func NewScheduleApi added in v0.2.29 

func NewScheduleApi(appCode string, un *utils.UserNamespace) *ScheduleApi

func (*ScheduleApi) CronCreate added in v0.2.29 

func (sa *ScheduleApi) CronCreate(name string, payload []byte, c string) (error, *int64)

func (*ScheduleApi) CronUpdate added in v0.2.32 

func (sa *ScheduleApi) CronUpdate(eventId int64, c string) error

func (*ScheduleApi) OnceCreate added in v0.2.29 

func (sa *ScheduleApi) OnceCreate(name string, payload []byte, remindTime int64) (error, *int64)

func (*ScheduleApi) OnceUpdate added in v0.2.32 

func (sa *ScheduleApi) OnceUpdate(eventId int64, remindTime int64) error

type StorageApi added in v0.1.21 

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

func NewStorageApi added in v0.1.21 

func NewStorageApi(un *utils.UserNamespace) *StorageApi

func (StorageApi) Chtimes added in v0.1.25 

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

Chtimes 修改文件时间

func (StorageApi) EnsureDirExist added in v0.1.21 

func (s StorageApi) EnsureDirExist(ps ...string)

EnsureDirExist 确保目录存在

func (StorageApi) FileExists added in v0.1.21 

func (s StorageApi) FileExists(path string) bool

FileExists 文件是否存在

func (StorageApi) InodeToFileInfo added in v0.1.21 

func (s StorageApi) InodeToFileInfo(inode int64) *sdkdto.FileInfoRes

InodeToFileInfo inode转fileInfo

func (StorageApi) InodeToPath added in v0.1.21 

func (s StorageApi) InodeToPath(inode int64) string

InodeToPath inode转path

func (StorageApi) InodesToFileInfos added in v0.1.21 

func (s StorageApi) InodesToFileInfos(inodes ...int64) map[int64]sdkdto.FileInfoRes

InodesToFileInfos inodes转fileInfos

func (StorageApi) MkdirAll added in v0.1.21 

func (s StorageApi) MkdirAll(path string) error

MkdirAll 递归创建目录

func (StorageApi) Open added in v0.1.21 

func (s StorageApi) Open(path string) (*os.File, *net.UnixConn, string, error)

Open 打开文件

func (StorageApi) OpenFile added in v0.1.21 

func (s StorageApi) OpenFile(path string, flag int, perm os.FileMode) (*os.File, *net.UnixConn, string, error)

OpenFile 打开或创建文件

func (StorageApi) PathToInode added in v0.1.21 

func (s StorageApi) PathToInode(path string) int64

PathToInode path转inode

func (StorageApi) Remove added in v0.1.21 

func (s StorageApi) Remove(path string) error

Remove 删除文件

func (StorageApi) Rename added in v0.1.21 

func (s StorageApi) Rename(oldPath, newPath string) error

Rename 重命名文件

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.