gateway

Documentation

Index

• Constants
• func GetAppInfo(code string) (*sdkentity.AppRegisterInfo, error)
• func RegisterMessageRobot(appCode, robotDesc string) error
• func SendMessage(un *utils.UserNamespace, appCode, content, replyUUID string) error
• type FFmpegOSApi
  • func NewFFmpegOSApi(un *utils.UserNamespace) *FFmpegOSApi
  • func (kv *FFmpegOSApi) GetInfo(parentPath, name string) (*sdkdto.FFProbeInfo, error)
• type KVCoreApi
  • func NewKVCoreApi(appCode string, un *utils.UserNamespace) *KVCoreApi
  • func (kv *KVCoreApi) DeleteKV(kvType, key string) error
  • func (kv *KVCoreApi) GetKV(kvType, key string) (*sdkdto.KV, bool)
  • func (kv *KVCoreApi) PutKV(kvType, key, value string) error
• type StorageApi
  • func NewStorageApi(un *utils.UserNamespace) *StorageApi
  • func (s StorageApi) Chtimes(path string, atime time.Time, mtime time.Time) error
  • func (s StorageApi) EnsureDirExist(ps ...string)
  • func (s StorageApi) FileExists(path string) bool
  • func (s StorageApi) InodeToFileInfo(inode int64) *sdkdto.FileInfoRes
  • func (s StorageApi) InodeToPath(inode int64) string
  • func (s StorageApi) InodesToFileInfos(inodes ...int64) map[int64]sdkdto.FileInfoRes
  • func (s StorageApi) MkdirAll(path string) error
  • func (s StorageApi) Open(path string) (*os.File, *net.UnixConn, string, error)
  • func (s StorageApi) OpenFile(path string, flag int, perm os.FileMode) (*os.File, *net.UnixConn, string, error)
  • func (s StorageApi) PathToInode(path string) int64
  • func (s StorageApi) Remove(path string) error
  • func (s StorageApi) Rename(oldPath, newPath string) error

Constants

const (
	KVApiPut    = "/put"
	KVApiDelete = "/delete"
	KVApiGet    = "/value"
)

const (
	AppCodeQuery = "appCode"
	TypeQuery    = "type"
	KeyQuery     = "key"
	ValueQuery   = "value"
)

const CoreHTTPPort = 40100

const LocalhostAddress = "http://10.62.0.1"

const OSHTTPPort = 40000

const UnixSocketPrefix = "/siyouyun/unix-socket/"

Functions

func GetAppInfo

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

func RegisterMessageRobot

func RegisterMessageRobot(appCode, robotDesc string) error

func SendMessage

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

Types

type FFmpegOSApi

type FFmpegOSApi struct {
	Host string
	*utils.UserNamespace
}

func NewFFmpegOSApi

func NewFFmpegOSApi(un *utils.UserNamespace) *FFmpegOSApi

func (*FFmpegOSApi) GetInfo

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

GetInfo GetInfo

type KVCoreApi

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

func NewKVCoreApi

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

func (*KVCoreApi) DeleteKV

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

DeleteKV DeleteKV

func (*KVCoreApi) GetKV

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

GetKV GetKV

func (*KVCoreApi) PutKV

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

PutKV PutKV

type StorageApi

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

func NewStorageApi

func NewStorageApi(un *utils.UserNamespace) *StorageApi

func (StorageApi) Chtimes

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

Chtimes 修改文件时间

func (StorageApi) EnsureDirExist

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

EnsureDirExist 确保目录存在

func (StorageApi) FileExists

func (s StorageApi) FileExists(path string) bool

FileExists 文件是否存在

func (StorageApi) InodeToFileInfo

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

InodeToFileInfo inode转fileInfo

func (StorageApi) InodeToPath

func (s StorageApi) InodeToPath(inode int64) string

InodeToPath inode转path

func (StorageApi) InodesToFileInfos

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

InodesToFileInfos inodes转fileInfos

func (StorageApi) MkdirAll

func (s StorageApi) MkdirAll(path string) error

MkdirAll 递归创建目录

func (StorageApi) Open

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

Open 打开文件

func (StorageApi) OpenFile

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

OpenFile 打开或创建文件

func (StorageApi) PathToInode

func (s StorageApi) PathToInode(path string) int64

PathToInode path转inode

func (StorageApi) Remove

func (s StorageApi) Remove(path string) error

Remove 删除文件

func (StorageApi) Rename

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

Rename 重命名文件