utils

Documentation

Index

• Constants
• Variables
• func GetAIServiceURL() string
• func GetCoreServiceURL() string
• func GetMilvusServiceURL() string
• func GetNatsServiceURL() string
• func GetOSServiceURL() string
• type IdentifierType
• type Pagination
  • func NewPaginationFromIris(ctx iris.Context) *Pagination
• type StorageType
  • func (t StorageType) IsSiyouyunStorage() bool
  • func (t StorageType) String() string
• type UFI
  • func NewUFI[T IdentifierType](storageType StorageType, uuid string, mode UFIMode, identifier T) *UFI
  • func (ufi *UFI) Serialize() string
  • func (ufi *UFI) Validate() bool
• type UFIMode
  • func (U UFIMode) String() string
• type UFIProtocol
  • func (U UFIProtocol) String() string
• type UserGroupNamespace
  • func NewUserGroupNamespace(username, groupname, namespace string) *UserGroupNamespace
  • func NewUserNamespaceFromIris(ctx iris.Context) *UserGroupNamespace
  • func (ugn *UserGroupNamespace) DatabaseName() string
  • func (ugn *UserGroupNamespace) GetRealPrefix(poolName string) string
  • func (ugn *UserGroupNamespace) String() string

Constants

const (
	PageCurrent = "page"
	PageSize    = "pageSize"
)

Variables

var ReadBufPool = sync.Pool{
	New: func() interface{} {
		b := make([]byte, 1024)
		return &b
	},
}

ReadBufPool 读取缓冲池

Functions

func GetAIServiceURL

func GetAIServiceURL() string

func GetCoreServiceURL

func GetCoreServiceURL() string

func GetMilvusServiceURL

func GetMilvusServiceURL() string

func GetNatsServiceURL

func GetNatsServiceURL() string

func GetOSServiceURL

func GetOSServiceURL() string

Types

type IdentifierType

type IdentifierType interface {
	~int | ~int32 | ~int64 | ~uint | ~uint32 | uint64 | ~string
}

IdentifierType 定义identifier类型约束接口

type Pagination

type Pagination struct {
	Page     int `json:"page"`
	PageSize int `json:"pageSize"`
}

func NewPaginationFromIris

func NewPaginationFromIris(ctx iris.Context) *Pagination

type StorageType

type StorageType string

const (
	RawDisk     StorageType = "raw-disk"
	USB         StorageType = "usb"
	Baiduyun    StorageType = "baiduyun"
	CommonOSS   StorageType = "oss"
	AliyunOSS   StorageType = "aliyun-oss"
	TencentOSS  StorageType = "tencent-oss"
	SambaClient StorageType = "smb-client"
	UFSMeta     StorageType = "siyouyun-meta"
	UFSRaw      StorageType = "siyouyun-raw"
	UFSSandbox  StorageType = "siyouyun-sandbox"
	Snapshot    StorageType = "siyouyun-snapshot"
	Trash       StorageType = "siyouyun-trash"
	Webdav      StorageType = "webdav"
	FTP         StorageType = "ftp"
)

func (StorageType) IsSiyouyunStorage

func (t StorageType) IsSiyouyunStorage() bool

func (StorageType) String

func (t StorageType) String() string

type UFI

type UFI struct {
	StorageType StorageType `json:"storageType"`
	UUID        string      `json:"uuid"`
	Mode        UFIMode     `json:"mode"`       // 标识符类型: id path
	Identifier  string      `json:"identifier"` // 标识符正文
	// contains filtered or unexported fields
}

UFI 统一文件定位

func NewUFI

func NewUFI[T IdentifierType](storageType StorageType, uuid string, mode UFIMode, identifier T) *UFI

func (*UFI) Serialize

func (ufi *UFI) Serialize() string

Serialize siyouyun-pool的uuid需要同时传递UGN确定存储空间 usb的uuid是label的hash,不包含UGN信息,由权限管理控制访问 其余存储的uuid隐藏含义包含了UGN信息 eg:

• 样板 /ufi/{storageType}/{uuid}/id/110 /ufi/{storageType}/{uuid}/path/123.png

func (*UFI) Validate

func (ufi *UFI) Validate() bool

type UFIMode

type UFIMode string

UFIMode ufi文件定位模式

const (
	IdUFI   UFIMode = "id"
	PathUFI UFIMode = "path"
)

func (UFIMode) String

func (U UFIMode) String() string

type UFIProtocol

type UFIProtocol string

const (
	UFIv1 UFIProtocol = "ufi"
)

func (UFIProtocol) String

func (U UFIProtocol) String() string

type UserGroupNamespace

type UserGroupNamespace struct {
	Username  string `json:"username"`  // 用户名
	GroupName string `json:"groupname"` // 组名
	Namespace string `json:"namespace"` // 命名空间
}

func NewUserGroupNamespace

func NewUserGroupNamespace(username, groupname, namespace string) *UserGroupNamespace

func NewUserNamespaceFromIris

func NewUserNamespaceFromIris(ctx iris.Context) *UserGroupNamespace

func (*UserGroupNamespace) DatabaseName

func (ugn *UserGroupNamespace) DatabaseName() string

func (*UserGroupNamespace) GetRealPrefix

func (ugn *UserGroupNamespace) GetRealPrefix(poolName string) string

func (*UserGroupNamespace) String

func (ugn *UserGroupNamespace) String() string