base

Documentation

Index

• Constants
• func CheckEndPoint(ep string) error
• func FormExportName(repoName, exportType string) string
• func FormExportTSDBName(repoName, seriesName, exportType string) string
• func MakeTokenInternal(ak, sk string, desc *TokenDesc) (token string, err error)
• func SetLogger(l Logger)
• func Sign(ak, sk string, req *http.Request) error
• func SignQiniuHeader(header http.Header) (out string)
• func SignQiniuResource(url string, query url.Values) (out string)
• type DefaultLogger
  • func NewDefaultLogger() *DefaultLogger
  • func (l *DefaultLogger) AtMost(v LogLevelType) bool
  • func (l *DefaultLogger) Debug(v ...interface{})
  • func (l *DefaultLogger) Debugf(format string, v ...interface{})
  • func (l *DefaultLogger) EnableTimestamps()
  • func (l *DefaultLogger) Error(v ...interface{})
  • func (l *DefaultLogger) Errorf(format string, v ...interface{})
  • func (l *DefaultLogger) Fatal(v ...interface{})
  • func (l *DefaultLogger) Fatalf(format string, v ...interface{})
  • func (l *DefaultLogger) Info(v ...interface{})
  • func (l *DefaultLogger) Infof(format string, v ...interface{})
  • func (l *DefaultLogger) LogLevel() LogLevelType
  • func (l *DefaultLogger) Panic(v ...interface{})
  • func (l *DefaultLogger) Panicf(format string, v ...interface{})
  • func (l *DefaultLogger) SetLoggerLevel(level LogLevelType)
  • func (l *DefaultLogger) Warn(v ...interface{})
  • func (l *DefaultLogger) Warnf(format string, v ...interface{})
• type LogLevelType
• type Logger
• type TokenDesc
  • func (t *TokenDesc) AddQuery(k, v string)
  • func (t *TokenDesc) SetHeader(k, v string)
  • func (t *TokenDesc) Validate() (err error)
• type Validator

Constants

const (
	MethodGet    string = "GET"
	MethodPost   string = "POST"
	MethodDelete string = "DELETE"
	MethodPut    string = "PUT"
)

const (
	HTTPHeaderAppId         string = "X-AppId"
	HTTPHeaderContentType   string = "Content-Type"
	HTTPHeaderContentLength string = "Content-Length"
	HTTPHeaderContentMD5    string = "Content-MD5"
	HTTPHeaderRequestId     string = "X-Reqid"
	HTTPHeaderAuthorization string = "Authorization"
	HTTPHeaderResourceOwner string = "X-Resource-Owner"
)

const (
	OpCreateGroup         string = "CreateGroup"
	OpUpdateGroup         string = "UpdateGroup"
	OpStartGroupTask      string = "StartGroupTask"
	OpStopGroupTask       string = "StopGroupTask"
	OpListGroups          string = "ListGroup"
	OpGetGroup            string = "GetGroup"
	OpDeleteGroup         string = "DeleteGroup"
	OpCreateRepo          string = "CreateRepo"
	OpGetRepo             string = "GetRepo"
	OpGetSampleData       string = "GetSampleData"
	OpListRepos           string = "ListRepo"
	OpListReposWithDag    string = "ListRepoWithDag"
	OpDeleteRepo          string = "DeleteRepo"
	OpRepoExists          string = "RepoExists"
	OpPostData            string = "PostData"
	OpCreateTransform     string = "CreateTransform"
	OpUpdateTransform     string = "UpdateTransform"
	OpGetTransform        string = "GetTransform"
	OpListTransforms      string = "ListTransform"
	OpDeleteTransform     string = "DeleteTransform"
	OpTransformExists     string = "TransformExists"
	OpCreateExport        string = "CreateExport"
	OpUpdateExport        string = "UpdateExport"
	OpGetExport           string = "GetExport"
	OpListExports         string = "ListExport"
	OpDeleteExport        string = "DeleteExport"
	OpExportExists        string = "ExportExists"
	OpUploadPlugin        string = "UploadPlugin"
	OpGetPlugin           string = "GetPlugin"
	OpListPlugins         string = "ListPlugin"
	OpVerifyPlugin        string = "VerifyPlugin"
	OpDeletePlugin        string = "DeletePlugin"
	OpCreateDatasource    string = "CreateDatasource"
	OpGetDatasource       string = "GetDatasource"
	OpListDatasources     string = "ListDatasources"
	OpDeleteDatasource    string = "DeleteDatasource"
	OpDatasourceExists    string = "DatasourceExists"
	OpCreateJob           string = "CreateJob"
	OpGetJob              string = "GetJob"
	OpListJobs            string = "ListJobs"
	OpDeleteJob           string = "DeleteJob"
	OpStartJob            string = "StartJob"
	OpStopJob             string = "StopJob"
	OpJobExists           string = "JobExists"
	OpGetJobHistory       string = "GetJobHistory"
	OpStopJobBatch        string = "StopJobBatch"
	OpRerunJobBatch       string = "RerunJobBatch"
	OpCreateJobExport     string = "CreateJobExport"
	OpGetJobExport        string = "GetJobExport"
	OpListJobExports      string = "ListJobExports"
	OpDeleteJobExport     string = "DeleteJobExport"
	OpJobExportExists     string = "JobExportExists"
	OpRetrieveSchema      string = "RetrieveSchema"
	OpUploadUdf           string = "UploadUdf"
	OpPutUdfMeta          string = "PutUdfMeta"
	OpDeleteUdf           string = "DeleteUdf"
	OpListUdfs            string = "ListUdfs"
	OpRegUdfFunc          string = "RegisterUdfFunction"
	OpDeregUdfFunc        string = "DeregisterUdfFunction"
	OpListUdfFuncs        string = "ListUdfFuncs"
	OpListUdfBuiltinFuncs string = "ListUdfBuiltinFuncs"
	OpCreateWorkflow      string = "CreateWorkflow"
	OpUpdateWorkflow      string = "UpdateWorkflow"
	OpDeleteWorkflow      string = "DeleteWorkflow"
	OpListWorkflows       string = "ListWorkflow"
	OpGetWorkflow         string = "GetWorkflow"
	OpGetWorkflowStatus   string = "GetWorkflowStatus"
	OpStartWorkflow       string = "StartWorkflow"
	OpStopWorkflow        string = "StopWorkflow"
	OpSearchDAGlog        string = "SearchDAGLog"
	OpCreateVariable      string = "CreateVariable"
	OpUpdateVariable      string = "UpdateVariable"
	OpDeleteVariable      string = "DeleteVariable"
	OpGetVariable         string = "GetVariable"
	OpListUserVariables   string = "ListUserVariables"
	OpListSystemVariables string = "ListSystemVariables"

	OpUpdateRepo        string = "UpdateRepo"
	OpSendLog           string = "SendLog"
	OpQueryLog          string = "QueryLog"
	OpQueryScroll       string = "QueryScroll"
	OpQueryHistogramLog string = "QueryHistogramLog"
	OpPutRepoConfig     string = "PutRepoConfig"
	OpGetRepoConfig     string = "GetRepoConfig"
	OpPartialQuery      string = "PartialQuery"
	OpSchemaRef         string = "SchemaRef"
	OpAnalysisLogJob    string = "AnalysisLogJob"
	OpAnalysisLog       string = "AnalysisLog"
	OpSearchLogJob      string = "SearchLogJob"
	OpSearchLog         string = "SearchLog"

	OpUpdateRepoMetadata string = "UpdataRepoMetadata"
	OpDeleteRepoMetadata string = "DeleteRepoMetadata"
	OpUpdateViewMetadata string = "UpdataViewMetadata"
	OpDeleteViewMetadata string = "DeleteViewMetadata"

	OpCreateSeries         string = "CreateSeries"
	OpUpdateSeriesMetadata string = "UpdataSeriesMetadata"
	OpDeleteSeriesMetadata string = "DeleteSeriesMetadata"
	OpListSeries           string = "ListSeries"
	OpDeleteSeries         string = "DeleteSeries"

	OpCreateView  string = "CreateView"
	OpListView    string = "ListView"
	OpGetView     string = "GetView"
	OpDeleteView  string = "DeleteView"
	OpQueryPoints string = "QueryPoints"
	OpWritePoints string = "WritePoints"

	OpActivateUser   string = "ActivateUser"
	OpCreateDatabase string = "CreateDatabase"
	OpListDatabases  string = "ListDatabases"
	OpDeleteDatabase string = "DeleteDatabase"
	OpCreateTable    string = "CreateTable"
	OpUpdateTable    string = "UpdateTable"
	OpListTables     string = "ListTables"
	OpDeleteTable    string = "DeleteTable"
	OpGetTable       string = "GetTable"
)

const (
	ContentTypeJson        string = "application/json"
	ContentTypeJar         string = "application/java-archive"
	ContentTypeText        string = "text/plain"
	ContentTypeOctetStream string = "application/octet-stream"
)

const (
	// workflow 状态
	WorkflowReady    = "Ready"    // 新建状态
	WorkflowStarting = "Starting" // 存在任一资源为 Starting
	WorkflowStarted  = "Started"  // 所有资源为 Started
	WorkflowStopping = "Stopping" // 存在任一资源为 Stopping
	WorkflowStopped  = "Stopped"  // 所有资源为 Stopped
	WorkflowUnknown  = "Unknown"  // 获取状态失败时的异常状态，
)

const (
	NestLimit int = 5
)

Functions

func CheckEndPoint

func CheckEndPoint(ep string) error

func FormExportName

func FormExportName(repoName, exportType string) string

func FormExportTSDBName

func FormExportTSDBName(repoName, seriesName, exportType string) string

func MakeTokenInternal

func MakeTokenInternal(ak, sk string, desc *TokenDesc) (token string, err error)

func SetLogger

func SetLogger(l Logger)

func Sign

func Sign(ak, sk string, req *http.Request) error

func SignQiniuHeader

func SignQiniuHeader(header http.Header) (out string)

func SignQiniuResource

func SignQiniuResource(url string, query url.Values) (out string)

Types

type DefaultLogger

type DefaultLogger struct {
	*log.Logger
	// contains filtered or unexported fields
}

func NewDefaultLogger

func NewDefaultLogger() *DefaultLogger

func (*DefaultLogger) AtMost

func (l *DefaultLogger) AtMost(v LogLevelType) bool

func (*DefaultLogger) Debug

func (l *DefaultLogger) Debug(v ...interface{})

func (*DefaultLogger) Debugf

func (l *DefaultLogger) Debugf(format string, v ...interface{})

func (*DefaultLogger) EnableTimestamps

func (l *DefaultLogger) EnableTimestamps()

func (*DefaultLogger) Error

func (l *DefaultLogger) Error(v ...interface{})

func (*DefaultLogger) Errorf

func (l *DefaultLogger) Errorf(format string, v ...interface{})

func (*DefaultLogger) Fatal

func (l *DefaultLogger) Fatal(v ...interface{})

func (*DefaultLogger) Fatalf

func (l *DefaultLogger) Fatalf(format string, v ...interface{})

func (*DefaultLogger) Info

func (l *DefaultLogger) Info(v ...interface{})

func (*DefaultLogger) Infof

func (l *DefaultLogger) Infof(format string, v ...interface{})

func (*DefaultLogger) LogLevel

func (l *DefaultLogger) LogLevel() LogLevelType

func (*DefaultLogger) Panic

func (l *DefaultLogger) Panic(v ...interface{})

func (*DefaultLogger) Panicf

func (l *DefaultLogger) Panicf(format string, v ...interface{})

func (*DefaultLogger) SetLoggerLevel

func (l *DefaultLogger) SetLoggerLevel(level LogLevelType)

func (*DefaultLogger) Warn

func (l *DefaultLogger) Warn(v ...interface{})

func (*DefaultLogger) Warnf

func (l *DefaultLogger) Warnf(format string, v ...interface{})

type LogLevelType

type LogLevelType uint

const (
	LogDebug LogLevelType = iota
	LogInfo
	LogWarn
	LogError
	LogPanic
	LogFatal
	LogOff
)

type Logger

type Logger interface {
	SetLoggerLevel(LogLevelType)

	Debug(v ...interface{})
	Debugf(format string, v ...interface{})

	Error(v ...interface{})
	Errorf(format string, v ...interface{})

	Info(v ...interface{})
	Infof(format string, v ...interface{})

	Warn(v ...interface{})
	Warnf(format string, v ...interface{})

	Panic(v ...interface{})
	Panicf(format string, v ...interface{})

	Fatal(v ...interface{})
	Fatalf(format string, v ...interface{})
}

type TokenDesc

type TokenDesc struct {
	Url         string
	QueryString url.Values
	Expires     int64
	ContentMD5  string
	ContentType string
	Method      string
	Headers     http.Header
}

func (*TokenDesc) AddQuery

func (t *TokenDesc) AddQuery(k, v string)

func (*TokenDesc) SetHeader

func (t *TokenDesc) SetHeader(k, v string)

func (*TokenDesc) Validate

func (t *TokenDesc) Validate() (err error)

type Validator

type Validator interface {
	Validate() error
}