Documentation
¶
Index ¶
- Variables
- func NewInfluxdbClient(serverURL, authToken string) influxdb2.Client
- type AzureReplayStorage
- type ESCommandStorage
- func (es ESCommandStorage) BulkSave(commands []*model.Command) error
- func (es ESCommandStorage) BulkSaveEs(commands []*model.Command) error
- func (es ESCommandStorage) BulkSaveEs8(commands []*model.Command) (err error)
- func (es ESCommandStorage) IsEs8() bool
- func (es ESCommandStorage) TypeName() string
- type FTPServerStorage
- type InfluxdbStorage
- type InfoResponse
- type NullStorage
- type OBSReplayStorage
- type OSSReplayStorage
- type S3ReplayStorage
- type ServerStorage
- type Version
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrEmptyEndpoint = errors.New("oss endpoint is empty")
Functions ¶
func NewInfluxdbClient ¶
Types ¶
type AzureReplayStorage ¶
type AzureReplayStorage struct {
AccountName string
AccountKey string
ContainerName string
EndpointSuffix string
}
func (AzureReplayStorage) TypeName ¶
func (a AzureReplayStorage) TypeName() string
func (AzureReplayStorage) Upload ¶
func (a AzureReplayStorage) Upload(gZipFilePath, target string) (err error)
type ESCommandStorage ¶
type ESCommandStorage struct {
Hosts []string
Index string
DocType string
IsDataStream bool
InsecureSkipVerify bool
}
func (ESCommandStorage) BulkSave ¶
func (es ESCommandStorage) BulkSave(commands []*model.Command) error
func (ESCommandStorage) BulkSaveEs ¶
func (es ESCommandStorage) BulkSaveEs(commands []*model.Command) error
func (ESCommandStorage) BulkSaveEs8 ¶
func (es ESCommandStorage) BulkSaveEs8(commands []*model.Command) (err error)
func (ESCommandStorage) IsEs8 ¶
func (es ESCommandStorage) IsEs8() bool
func (ESCommandStorage) TypeName ¶
func (es ESCommandStorage) TypeName() string
type FTPServerStorage ¶
func (FTPServerStorage) TypeName ¶
func (s FTPServerStorage) TypeName() string
func (FTPServerStorage) Upload ¶
func (s FTPServerStorage) Upload(filePath, target string) (err error)
type InfluxdbStorage ¶
func (InfluxdbStorage) BulkSave ¶
func (influx InfluxdbStorage) BulkSave(commands []*model.Command) (err error)
func (InfluxdbStorage) TypeName ¶
func (influx InfluxdbStorage) TypeName() string
type InfoResponse ¶
type InfoResponse struct {
Version Version `json:"version"`
}
type NullStorage ¶
type NullStorage struct {
}
func NewNullStorage ¶
func NewNullStorage() (storage NullStorage)
func (NullStorage) TypeName ¶
func (f NullStorage) TypeName() string
func (NullStorage) Upload ¶
func (f NullStorage) Upload(gZipFile, target string) (err error)
type OBSReplayStorage ¶
func (OBSReplayStorage) TypeName ¶
func (o OBSReplayStorage) TypeName() string
func (OBSReplayStorage) Upload ¶
func (o OBSReplayStorage) Upload(gZipFilePath, target string) (err error)
type OSSReplayStorage ¶
func (OSSReplayStorage) TypeName ¶
func (o OSSReplayStorage) TypeName() string
func (OSSReplayStorage) Upload ¶
func (o OSSReplayStorage) Upload(gZipFilePath, target string) (err error)
type S3ReplayStorage ¶
type S3ReplayStorage struct {
Bucket string
Region string
AccessKey string
SecretKey string
Endpoint string
}
func (S3ReplayStorage) TypeName ¶
func (s S3ReplayStorage) TypeName() string
func (S3ReplayStorage) Upload ¶
func (s S3ReplayStorage) Upload(gZipFilePath, target string) (err error)
type ServerStorage ¶
func (ServerStorage) BulkSave ¶
func (s ServerStorage) BulkSave(commands []*model.Command) (err error)
func (ServerStorage) TypeName ¶
func (s ServerStorage) TypeName() string
func (ServerStorage) Upload ¶
func (s ServerStorage) Upload(gZipFilePath, target string) (err error)
Click to show internal directories.
Click to hide internal directories.