service

Documentation

Index

• Constants
• type FileService
  • func NewFileService(objectNode string, masters []string, mc *client.MasterGClient) *FileService
  • func (fs *FileService) DownFile(writer http.ResponseWriter, request *http.Request) error
  • func (fs *FileService) Schema() *graphql.Schema
  • func (fs *FileService) UpLoadFile(writer http.ResponseWriter, request *http.Request) error
• type FuseClient
• type FuseRecord
• type KeyValue
• type ListFileInfo
• type LoginService
  • func NewLoginService(client *client.MasterGClient) *LoginService
  • func (ls *LoginService) Schema() *graphql.Schema
• type MonitorService
  • func NewMonitorService(addr, app, cluster, dashboardAddr string) *MonitorService
  • func (fs *MonitorService) Dashboard(ctx context.Context, args struct{}) string
  • func (ms *MonitorService) FuseClientList(ctx context.Context, args struct{}) ([]*FuseRecord, error)
  • func (ms *MonitorService) Query(ctx context.Context, args struct{ ... }) (string, error)
  • func (ms *MonitorService) RangeQuery(ctx context.Context, args struct{ ... }) (string, error)
  • func (ms *MonitorService) RangeQueryURL(ctx context.Context, args struct{ ... }) (string, error)
  • func (ms *MonitorService) Schema() *graphql.Schema
• type UserToken

Constants

const ADMIN permissionMode = permissionMode(1)

const USER permissionMode = permissionMode(2)

Types

type FileService

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

func NewFileService

func NewFileService(objectNode string, masters []string, mc *client.MasterGClient) *FileService

func (*FileService) DownFile

func (fs *FileService) DownFile(writer http.ResponseWriter, request *http.Request) error

?vol_name=abc&path=/aaa/bbb/ddd.txt

func (*FileService) Schema

func (fs *FileService) Schema() *graphql.Schema

func (*FileService) UpLoadFile

func (fs *FileService) UpLoadFile(writer http.ResponseWriter, request *http.Request) error

?vol_name=abc&path=/aaa/bbb/ddd.txt {file}

type FuseClient

type FuseClient struct {
	Name     string `json:"__name__"`
	App      string `json:"app"`
	Cluster  string `json:"cluster"`
	Hostip   string `json:"hostip"`
	Instance string `json:"instance"`
	Job      string `json:"job"`
	Monitor  string `json:"monitor"`
	Role     string `json:"role"`
	Service  string `json:"service"`
}

type FuseRecord

type FuseRecord struct {
	Metric FuseClient `json:"metric"`
	Value  float64    `json:"value"`
}

type KeyValue

type KeyValue struct {
	Key   string
	Value string
}

type ListFileInfo

type ListFileInfo struct {
	Infos       []*FSFileInfo
	NextMarker  string
	IsTruncated bool
	Prefixes    []string
}

type LoginService

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

func NewLoginService

func NewLoginService(client *client.MasterGClient) *LoginService

func (*LoginService) Schema

func (ls *LoginService) Schema() *graphql.Schema

type MonitorService

type MonitorService struct {
	Address       string
	App           string
	Cluster       string
	DashboardAddr string
}

func NewMonitorService

func NewMonitorService(addr, app, cluster, dashboardAddr string) *MonitorService

func (*MonitorService) Dashboard

func (fs *MonitorService) Dashboard(ctx context.Context, args struct{}) string

func (*MonitorService) FuseClientList

func (ms *MonitorService) FuseClientList(ctx context.Context, args struct{}) ([]*FuseRecord, error)

func (*MonitorService) Query

func (ms *MonitorService) Query(ctx context.Context, args struct {
	Query string
}) (string, error)

func (*MonitorService) RangeQuery

func (ms *MonitorService) RangeQuery(ctx context.Context, args struct {
	Query string
	Start uint32
	End   uint32
	Step  uint32
}) (string, error)

func (*MonitorService) RangeQueryURL

func (ms *MonitorService) RangeQueryURL(ctx context.Context, args struct {
	Query string
	Start uint32
	End   uint32
	Step  uint32
}) (string, error)

func (*MonitorService) Schema

func (ms *MonitorService) Schema() *graphql.Schema

type UserToken

type UserToken struct {
	UserID   string `json:"userID"`
	Token    string `json:"token"`
	Status   bool   `json:"status"`
	UserInfo *user.UserInfo
}