Versions in this module Expand all Collapse all v0 v0.1.94 Dec 12, 2024 v0.1.93 Dec 12, 2024 v0.1.92 Dec 12, 2024 Changes in this version + const AggQuery + const BAD_REQUEST + const BodyRawSize + const CHARGE_BY_DATA_INGEST + const CHARGE_BY_FUNCTION + const CONFIG_ALREADY_EXIST + const CONFIG_NOT_EXIST + const Compress_LZ4 + const Compress_Max + const Compress_None + const Compress_ZSTD + const CountConditionKey + const CpuCores + const CpuSec + const DataSinkADB + const DataSinkGENERAL + const DataSinkLOG + const DataSinkODPS + const DataSinkOSS + const DataSinkTSDB + const DataSourceBSS + const DataSourceCMS + const DataSourceGeneral + const DataSourceJDBC + const DataSourceKafka + const DataSourceMaxCompute + const DataSourceOSS + const DataSourceS3 + const DefaultLogUserAgent + const ECS_RAM_ROLE_RETRY_TIMES + const ECS_RAM_ROLE_URL_PREFIX + const ETLSinksType + const ETLType + const ETLVersion + const ElapsedMillisecond + const EtlMetaAllTagMatch + const EtlMetaNameURI + const EtlMetaURI + const EventStoreIndex + const EventStoreTelemetryType + const ExportVersion2 + const GROUP_ALREADY_EXIST + const GROUP_NOT_EXIST + const GetLogsCountHeader + const GetLogsQueryInfo + const GroupTypeCustom + const GroupTypeLabelsAuto + const GroupTypeNoGroup + const HTTPHeaderAPIVersion + const HTTPHeaderAcsSecurityToken + const HTTPHeaderAuthorization + const HTTPHeaderBodyRawSize + const HTTPHeaderContentLength + const HTTPHeaderContentMD5 + const HTTPHeaderContentType + const HTTPHeaderDate + const HTTPHeaderHost + const HTTPHeaderLogContentSha256 + const HTTPHeaderLogDate + const HTTPHeaderSignatureMethod + const HTTPHeaderUserAgent + const HasSQLHeader + const INTERNAL_SERVER_ERROR + const INVALID_API_VERSION + const INVALID_BODY_RAW_SIZE + const INVALID_COMPRESS_TYPE + const INVALID_CONTENT_TYPE + const INVALID_CURSOR + const INVALID_DATE_FORMAT + const INVALID_ENCODING + const INVALID_KEY + const INVALID_LINE + const INVALID_LOGSTORE_QUERY + const INVALID_OFFSET + const INVALID_PARAMETER + const INVALID_QUERY_STRING + const INVALID_REVERSE + const INVALID_SIGNATURE_METHOD + const INVALID_TIMESTAMP + const INVALID_TIME_RANGE + const ISO8601 + const InputTypeFile + const InputTypePlugin + const InputTypeStreamlog + const InputTypeSyslog + const InsertedSql + const JoinTypeConcat + const JoinTypeCross + const JoinTypeFull + const JoinTypeInner + const JoinTypeLeft + const JoinTypeLeftExclude + const JoinTypeNo + const JoinTypeRight + const JoinTypeRightExclude + const KafkaPositionEarliest + const KafkaPositionGroupOffsets + const KafkaPositionLatest + const KafkaPositionTimeStamp + const KafkaValueTypeJSON + const KafkaValueTypeText + const LOGSTORE_ALREADY_EXIST + const LOGSTORE_INFO_INVALID + const LOGSTORE_NOT_EXIST + const LOGSTORE_WITHOUT_SHARD + const LogFileTypeApsaraLog + const LogFileTypeDelimiterLog + const LogFileTypeJSONLog + const LogFileTypeRegexLog + const LoggingURI + const MISSING_API_VERSION + const MISSING_BODY_RAW_SIZE + const MISSING_CONTENT_LENGTH + const MISSING_CONTENT_TYPE + const MISSING_DATE + const MISSING_HOST + const MISSING_SIGNATURE_METHOD + const MISS_ACCESS_KEY_ID + const MachineIDTypeIP + const MachineIDTypeUserDefined + const MergeTypeLogstore + const MergeTypeTopic + const MetricAggRulesPromQL + const MetricAggRulesSQL + const NOT_SUPPORTED + const NotificationTypeDingTalk + const NotificationTypeEmail + const NotificationTypeMessageCenter + const NotificationTypeSMS + const NotificationTypeWebhook + const OSSCompressionTypeGzip + const OSSCompressionTypeNone + const OSSCompressionTypeSnappy + const OSSCompressionTypeZstd + const OSSContentDetailTypeCSV + const OSSContentDetailTypeJSON + const OSSContentDetailTypeORC + const OSSContentDetailTypeParquet + const OSSDataFormatTypeDelimitedText + const OSSDataFormatTypeJSON + const OSSDataFormatTypeLine + const OSSDataFormatTypeMultiline + const OSSDataFormatTypeParquet + const OSSShipperType + const OffsetNewest + const OffsetOldest + const OutputTypeLogService + const PARAMETER_INVALID + const POST_BODY_INVALID + const POST_BODY_TOO_LARGE + const POST_BODY_UNCOMPRESS_ERROR + const PPluginInputTypeCanal + const PROJECT_DATA_REDUNDANCY_TYPE_LRS + const PROJECT_DATA_REDUNDANCY_TYPE_UNKNOWN + const PROJECT_DATA_REDUNDANCY_TYPE_ZRS + const PROJECT_FORBIDDEN + const PROJECT_NOT_EXIST + const PROJECT_QUOTA_EXCEED + const PluginInputTypeDockerStdout + const PowerSql + const ProcessedBytes + const ProcessedRows + const ProgressHeader + const READ_QUOTA_EXCEED + const REQUEST_TIME_TOO_SKEWED + const RequestIDHeader + const ResourceNameActionPolicy + const ResourceNameAlertPolicy + const ResourceNameContentTemplate + const ResourceNameGlobalConfig + const ResourceNameUser + const ResourceNameUserGroup + const ResourceNameWebhookIntegration + const ResourceTypeUserDefine + const SERVER_BUSY + const SHARD_NOT_EXIST + const SHARD_READ_QUOTA_EXCEED + const SHARD_WRITE_QUOTA_EXCEED + const SHIPPER_NOT_EXIST + const SIGNATURE_NOT_MATCH + const STORE_VIEW_STORE_TYPE_LOGSTORE + const STORE_VIEW_STORE_TYPE_METRICSTORE + const ScheduleTypeCron + const ScheduleTypeDaily + const ScheduleTypeDayRun + const ScheduleTypeFixedRate + const ScheduleTypeHourly + const ScheduleTypeResident + const ScheduleTypeWeekly + const StoreTypeLog + const StoreTypeMeta + const StoreTypeMetric + const TelemetryType + const TopicFormatMachineGroup + const TopicFormatNone + const UN_AUTHORIZED + const UPDATE_FUNC_RETRY_TIMES + const WRITE_QUOTA_EXCEED + const WhereQuery + var File_log_proto protoreflect.FileDescriptor + var GlobalDebugLevel = 0 + var GlobalForceUsingHTTP = false + var InvalidCompressError = errors.New("Invalid Compress Type") + var InvalidTypeError = errors.New("invalid config type") + var Logger = initDefaultSLSLogger() + var MaxCompletedRetryCount = 20 + var MaxCompletedRetryLatency = 5 * time.Minute + var NoConfigFieldError = errors.New("no this config field") + var RetryOnServerErrorEnabled = true + func AddNecessaryApsaraLogInputConfigField(inputConfigDetail map[string]interface{}) + func AddNecessaryDelimiterLogInputConfigField(inputConfigDetail map[string]interface{}) + func AddNecessaryInputConfigField(inputConfigDetail map[string]interface{}) + func AddNecessaryJSONLogInputConfigField(inputConfigDetail map[string]interface{}) + func AddNecessaryLocalFileInputConfigField(inputConfigDetail map[string]interface{}) + func AddNecessaryRegexLogInputConfigField(inputConfigDetail map[string]interface{}) + func BoolPtrToStringNum(b *bool) string + func BoolToInt64(b bool) int64 + func GenResourceId(project string, subResourceId string) string + func GenerateInnerLogger(logFileName, isJsonType, logMaxSize, logFileBackupCount, allowLogLevel string) log.Logger + func GetFileConfigInputDetailType(detail InputDetailInterface) (string, bool) + func InitApsaraLogConfigInputDetail(detail *ApsaraLogConfigInputDetail) + func InitCommonConfigInputDetail(detail *CommonConfigInputDetail) + func InitDelimiterConfigInputDetail(detail *DelimiterConfigInputDetail) + func InitJSONConfigInputDetail(detail *JSONConfigInputDetail) + func InitLocalFileConfigInputDetail(detail *LocalFileConfigInputDetail) + func InitPluginLogConfigInputDetail(detail *PluginLogConfigInputDetail) + func InitRegexConfigInputDetail(detail *RegexConfigInputDetail) + func InitStreamLogConfigInputDetail(detail *StreamLogConfigInputDetail) + func Int64PtrToString(i *int64) string + func IsDebugLevelMatched(level int) bool + func IsTokenError(err error) bool + func IsValidInputType(inputType string) bool + func JsonMarshal(v interface{}) string + func ParseHeaderInt(r *http.Response, headerName string) (int, error) + func Retry(ctx context.Context, o backoff.Operation) error + func RetryWithAttempt(ctx context.Context, maxAttempt int, o ConditionOperation) error + func RetryWithBackOff(ctx context.Context, b backoff.BackOff, o backoff.Operation) error + func RetryWithCondition(ctx context.Context, b backoff.BackOff, o ConditionOperation) error + func SetZstdCompressor(compressor LogCompressor) error + func UpdateInputConfigField(detail InputDetailInterface, key string, val interface{}) error + type Alert struct + Configuration *AlertConfiguration + CreateTime int64 + Description string + DisplayName string + LastModifiedTime int64 + Name string + Schedule *Schedule + State string + Status string + func (alert *Alert) MarshalJSON() ([]byte, error) + type AlertConfiguration struct + Annotations []*Tag + AutoAnnotation bool + Condition string + Dashboard string + GroupConfiguration GroupConfiguration + JoinConfigurations []*JoinConfiguration + Labels []*Tag + MuteUntil int64 + NoDataFire bool + NoDataSeverity Severity + NotificationList []*Notification + NotifyThreshold int32 + PolicyConfiguration PolicyConfiguration + QueryList []*AlertQuery + SendResolved bool + SeverityConfigurations []*SeverityConfiguration + SinkAlerthub *SinkAlerthubConfiguration + SinkCms *SinkCmsConfiguration + SinkEventStore *SinkEventStoreConfiguration + Tags []string + TemplateConfiguration *TemplateConfiguration + Threshold int + Throttling string + Type string + Version string + type AlertQuery struct + ChartTitle string + DashboardId string + End string + LogStore string + PowerSqlMode PowerSqlMode + Project string + Query string + Region string + RoleArn string + Start string + Store string + StoreType string + TimeSpanType string + type AliyunBssSource struct + HistoryMonth int64 + RoleArn string + type AliyunCloudMonitorSource struct + AccessKeyID string + AccessKeySecret string + DelayTime int64 + Namespaces []string + OutputType string + StartTime int64 + type AliyunGeneralSink struct + Fields map[string]interface{} + Type DataSinkType + func (_ *AliyunGeneralSink) DataSinkType() DataSinkType + type AliyunMaxComputeSource struct + AccessKeyID string + AccessKeySecret string + Endpoint string + PartitionSpec string + Project string + Table string + TimeField string + TimeFormat string + TimeZone string + TunnelEndpoint string + type AliyunODPSSink struct + Fields []string + OdpsAccessKeyId string + OdpsAccessSecret string + OdpsEndpoint string + OdpsProject string + OdpsRolearn string + OdpsTable string + OdpsTunnelEndpoint string + PartitionColumn []string + PartitionTimeFormat string + TimeZone string + Type DataSinkType + func (_ *AliyunODPSSink) DataSinkType() DataSinkType + type AliyunOSSSink struct + Bucket string + BufferInterval int64 + BufferSize int64 + CompressionType OSSCompressionType + ContentDetail interface{} + ContentType OSSContentType + PathFormat string + PathFormatType string + Prefix string + RoleArn string + Suffix string + TimeZone string + Type DataSinkType + func (_ *AliyunOSSSink) DataSinkType() DataSinkType + type AliyunOSSSource struct + Bucket string + CompressionCodec string + Encoding string + Endpoint string + Format interface{} + LastModifyTimeAsLogTime bool + Pattern string + Prefix string + RestoreObjectEnable bool + RoleArn string + type ApsaraLogConfigInputDetail struct + LogBeginRegex string + func ConvertToApsaraLogConfigInputDetail(detail InputDetailInterface) (*ApsaraLogConfigInputDetail, bool) + type AuthVersionType string + const AuthV0 + const AuthV1 + const AuthV4 + type BadResponseError struct + HTTPCode int + RespBody string + RespHeader map[string][]string + func NewBadResponseError(body string, header map[string][]string, httpCode int) *BadResponseError + func (e BadResponseError) Error() string + func (e BadResponseError) String() string + type BaseJob struct + CreateTime int64 + Description string + DisplayName string + LastModifyTime int64 + Name string + Recyclable bool + Type JobType + type Chart struct + Display ChartDisplay + Search ChartSearch + Title string + Type string + type ChartDisplay struct + DisplayName string + Height float64 + Width float64 + XAxisKeys []string + XPosition float64 + YAxisKeys []string + YPosition float64 + type ChartSearch struct + End string + Logstore string + Query string + Start string + Topic string + type Client struct + AccessKeyID string + AccessKeySecret string + AuthVersion AuthVersionType + CommonHeaders map[string]string + Endpoint string + HTTPClient *http.Client + InnerHeaders map[string]string + Region string + RequestTimeOut time.Duration + RetryTimeOut time.Duration + SecurityToken string + UserAgent string + func (c *Client) ApplyConfigToMachineGroup(project string, confName, groupName string) (err error) + func (c *Client) CheckConfigExist(project string, config string) (ok bool, err error) + func (c *Client) CheckLogstoreExist(project string, logstore string) (bool, error) + func (c *Client) CheckMachineGroupExist(project string, machineGroup string) (bool, error) + func (c *Client) CheckProjectExist(name string) (bool, error) + func (c *Client) Close() error + func (c *Client) CreateAlert(project string, alert *Alert) error + func (c *Client) CreateAlertString(project string, alert string) error + func (c *Client) CreateChart(project, dashboardName string, chart Chart) error + func (c *Client) CreateConfig(project string, config *LogConfig) (err error) + func (c *Client) CreateConfigString(project string, config string) (err error) + func (c *Client) CreateConsumerGroup(project, logstore string, cg ConsumerGroup) (err error) + func (c *Client) CreateDashboard(project string, dashboard Dashboard) error + func (c *Client) CreateDashboardString(project string, dashboardStr string) error + func (c *Client) CreateETL(project string, etljob ETL) error + func (c *Client) CreateEtlMeta(project string, etlMeta *EtlMeta) (err error) + func (c *Client) CreateEventStore(project string, eventStore *LogStore) error + func (c *Client) CreateExport(project string, export *Export) error + func (c *Client) CreateIndex(project, logstore string, index Index) error + func (c *Client) CreateIndexString(project, logstore string, index string) error + func (c *Client) CreateIngestion(project string, ingestion *Ingestion) error + func (c *Client) CreateLogStore(project string, logstore string, ttl, shardCnt int, autoSplit bool, ...) error + func (c *Client) CreateLogStoreV2(project string, logstore *LogStore) error + func (c *Client) CreateLogging(project string, detail *Logging) error + func (c *Client) CreateMachineGroup(project string, m *MachineGroup) error + func (c *Client) CreateMetricAggRules(project string, aggRules *MetricAggRules) error + func (c *Client) CreateMetricStore(project string, metricStore *LogStore) error + func (c *Client) CreateProject(name, description string) (*LogProject, error) + func (c *Client) CreateProjectV2(name, description, dataRedundancyType string) (*LogProject, error) + func (c *Client) CreateResource(resource *Resource) error + func (c *Client) CreateResourceRecord(resourceName string, record *ResourceRecord) error + func (c *Client) CreateResourceRecordString(resourceName, recordStr string) error + func (c *Client) CreateResourceString(resourceStr string) error + func (c *Client) CreateSavedSearch(project string, savedSearch *SavedSearch) error + func (c *Client) CreateScheduledSQL(project string, scheduledsql *ScheduledSQL) error + func (c *Client) CreateStoreView(project string, storeView *StoreView) error + func (c *Client) CreateSubStore(project, logstore string, sss *SubStore) (err error) + func (c *Client) DeleteAlert(project string, alertName string) error + func (c *Client) DeleteChart(project, dashboardName, chartName string) error + func (c *Client) DeleteConfig(project string, config string) (err error) + func (c *Client) DeleteConsumerGroup(project, logstore string, cgName string) (err error) + func (c *Client) DeleteDashboard(project, name string) error + func (c *Client) DeleteETL(project string, etlName string) error + func (c *Client) DeleteEtlMeta(project string, etlMetaName, etlMetaKey string) (err error) + func (c *Client) DeleteEventStore(project, name string) error + func (c *Client) DeleteExport(project string, name string) error + func (c *Client) DeleteIndex(project, logstore string) error + func (c *Client) DeleteIngestion(project string, name string) error + func (c *Client) DeleteLogStore(project string, logstore string) (err error) + func (c *Client) DeleteLogging(project string) error + func (c *Client) DeleteMachineGroup(project string, machineGroup string) (err error) + func (c *Client) DeleteMetricAggRules(project string, ruleID string) error + func (c *Client) DeleteMetricStore(project, name string) error + func (c *Client) DeleteProject(name string) error + func (c *Client) DeleteProjectPolicy(project string) error + func (c *Client) DeleteResource(name string) error + func (c *Client) DeleteResourceRecord(resourceName, recordId string) error + func (c *Client) DeleteSavedSearch(project string, savedSearchName string) error + func (c *Client) DeleteScheduledSQL(project string, name string) error + func (c *Client) DeleteStoreView(project string, storeViewName string) error + func (c *Client) DeleteSubStore(project, logstore string, name string) (err error) + func (c *Client) DisableAlert(project string, alertName string) error + func (c *Client) EnableAlert(project string, alertName string) error + func (c *Client) GetAlert(project string, alertName string) (*Alert, error) + func (c *Client) GetAlertString(project string, alertName string) (string, error) + func (c *Client) GetAppliedConfigs(project string, groupName string) (confNames []string, err error) + func (c *Client) GetAppliedMachineGroups(project string, confName string) (groupNames []string, err error) + func (c *Client) GetChart(project, dashboardName, chartName string) (chart *Chart, err error) + func (c *Client) GetCheckpoint(project, logstore string, cgName string) (checkPointList []*ConsumerGroupCheckPoint, err error) + func (c *Client) GetConfig(project string, config string) (logConfig *LogConfig, err error) + func (c *Client) GetConfigString(project string, config string) (logConfig string, err error) + func (c *Client) GetCursor(project, logstore string, shardID int, from string) (cursor string, err error) + func (c *Client) GetCursorTime(project, logstore string, shardID int, cursor string) (cursorTime time.Time, err error) + func (c *Client) GetDashboard(project, name string) (dashboard *Dashboard, err error) + func (c *Client) GetDashboardString(project, name string) (dashboard string, err error) + func (c *Client) GetETL(project string, etlName string) (ETLJob *ETL, err error) + func (c *Client) GetEtlMeta(project string, etlMetaName, etlMetaKey string) (etlMeta *EtlMeta, err error) + func (c *Client) GetEventStore(project, name string) (*LogStore, error) + func (c *Client) GetExport(project, name string) (*Export, error) + func (c *Client) GetHistograms(project, logstore string, topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error) + func (c *Client) GetHistogramsToCompleted(project, logstore string, topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error) + func (c *Client) GetHistogramsToCompletedV2(project, logstore string, ghr *GetHistogramRequest) (*GetHistogramsResponse, error) + func (c *Client) GetHistogramsV2(project, logstore string, ghr *GetHistogramRequest) (*GetHistogramsResponse, error) + func (c *Client) GetIndex(project, logstore string) (*Index, error) + func (c *Client) GetIndexString(project, logstore string) (string, error) + func (c *Client) GetIngestion(project string, name string) (*Ingestion, error) + func (c *Client) GetLogLines(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogLinesResponse, error) + func (c *Client) GetLogLinesByNano(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogLinesResponse, error) + func (c *Client) GetLogLinesV2(project, logstore string, req *GetLogRequest) (*GetLogLinesResponse, error) + func (c *Client) GetLogStore(project string, logstore string) (*LogStore, error) + func (c *Client) GetLogStoreMeteringMode(project string, logstore string) (*GetMeteringModeResponse, error) + func (c *Client) GetLogging(project string) (*Logging, error) + func (c *Client) GetLogs(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogsResponse, error) + func (c *Client) GetLogsByNano(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogsResponse, error) + func (c *Client) GetLogsBytes(project, logstore string, shardID int, cursor, endCursor string, ...) (out []byte, nextCursor string, err error) + func (c *Client) GetLogsBytesV2(plr *PullLogRequest) (out []byte, nextCursor string, err error) + func (c *Client) GetLogsBytesWithQuery(plr *PullLogRequest) (out []byte, plm *PullLogMeta, err error) + func (c *Client) GetLogsToCompleted(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogsResponse, error) + func (c *Client) GetLogsToCompletedV2(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error) + func (c *Client) GetLogsToCompletedV3(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error) + func (c *Client) GetLogsV2(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error) + func (c *Client) GetLogsV3(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error) + func (c *Client) GetMachineGroup(project string, machineGroup string) (m *MachineGroup, err error) + func (c *Client) GetMetricAggRules(project string, ruleID string) (*MetricAggRules, error) + func (c *Client) GetMetricStore(project, name string) (*LogStore, error) + func (c *Client) GetPrevCursorTime(project, logstore string, shardID int, cursor string) (cursorTime time.Time, err error) + func (c *Client) GetProject(name string) (*LogProject, error) + func (c *Client) GetProjectPolicy(project string) (policy string, err error) + func (c *Client) GetResource(name string) (resource *Resource, err error) + func (c *Client) GetResourceRecord(resourceName, recordId string) (record *ResourceRecord, err error) + func (c *Client) GetResourceRecordString(resourceName, recordId string) (recordStr string, err error) + func (c *Client) GetResourceString(name string) (resource string, err error) + func (c *Client) GetSavedSearch(project string, savedSearchName string) (*SavedSearch, error) + func (c *Client) GetScheduledSQL(project string, name string) (*ScheduledSQL, error) + func (c *Client) GetScheduledSQLJobInstance(projectName, jobName, instanceId string, result bool) (*ScheduledSQLJobInstance, error) + func (c *Client) GetStoreView(project string, storeViewName string) (*StoreView, error) + func (c *Client) GetStoreViewIndex(project string, storeViewName string) (*GetStoreViewIndexResponse, error) + func (c *Client) GetSubStore(project, logstore, name string) (sortedSubStore *SubStore, err error) + func (c *Client) GetSubStoreTTL(project, logstore string) (ttl int, err error) + func (c *Client) HeartBeat(project, logstore string, cgName, consumer string, heartBeatShardIDs []int) (shardIDs []int, err error) + func (c *Client) ListAlert(project, alertName, dashboard string, offset, size int) (alerts []*Alert, total int, count int, err error) + func (c *Client) ListConfig(project string, offset, size int) (cfgNames []string, total int, err error) + func (c *Client) ListConsumerGroup(project, logstore string) (cgList []*ConsumerGroup, err error) + func (c *Client) ListDashboard(project string, dashboardName string, offset, size int) (dashboardList []string, count, total int, err error) + func (c *Client) ListDashboardV2(project string, dashboardName string, offset, size int) (dashboardList []string, dashboardItems []ResponseDashboardItem, ...) + func (c *Client) ListETL(project string, offset int, size int) (*ListETLResponse, error) + func (c *Client) ListEtlMeta(project string, etlMetaName string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + func (c *Client) ListEtlMetaName(project string, offset, size int) (total int, count int, etlMetaNameList []string, err error) + func (c *Client) ListEtlMetaWithTag(project string, etlMetaName, etlMetaTag string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + func (c *Client) ListEventStore(project string, offset, size int) ([]string, error) + func (c *Client) ListExport(project, logstore, name, displayName string, offset, size int) (exports []*Export, total, count int, error error) + func (c *Client) ListIngestion(project, logstore, name, displayName string, offset, size int) (ingestions []*Ingestion, total, count int, error error) + func (c *Client) ListLogStore(project string) ([]string, error) + func (c *Client) ListLogStoreV2(project string, offset, size int, telemetryType string) ([]string, error) + func (c *Client) ListMachineGroup(project string, offset, size int) (m []string, total int, err error) + func (c *Client) ListMachines(project, machineGroupName string) (ms []*Machine, total int, err error) + func (c *Client) ListMachinesV2(project, machineGroupName string, offset, size int) (ms []*Machine, total int, err error) + func (c *Client) ListMetricAggRules(project string, offset int, size int) ([]*MetricAggRules, error) + func (c *Client) ListProject() (projectNames []string, err error) + func (c *Client) ListProjectV2(offset, size int) (projects []LogProject, count, total int, err error) + func (c *Client) ListResource(resourceType string, resourceName string, offset, size int) (resourceList []*Resource, count, total int, err error) + func (c *Client) ListResourceRecord(resourceName string, offset, size int) (recordList []*ResourceRecord, count, total int, err error) + func (c *Client) ListSavedSearch(project string, savedSearchName string, offset, size int) (savedSearches []string, total int, count int, err error) + func (c *Client) ListSavedSearchV2(project string, savedSearchName string, offset, size int) (savedSearches []string, savedsearchItems []ResponseSavedSearchItem, total int, ...) + func (c *Client) ListScheduledSQL(project, name, displayName string, offset, size int) (scheduledsqls []*ScheduledSQL, total, count int, error error) + func (c *Client) ListScheduledSQLJobInstances(projectName, jobName string, status *InstanceStatus) (instances []*ScheduledSQLJobInstance, total, count int64, err error) + func (c *Client) ListShards(project, logstore string) (shardIDs []*Shard, err error) + func (c *Client) ListStoreViews(project string, req *ListStoreViewsRequest) (*ListStoreViewsResponse, error) + func (c *Client) ListSubStore(project, logstore string) (sortedSubStores []string, err error) + func (c *Client) ListSystemTagResources(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error) + func (c *Client) ListTagResources(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error) + func (c *Client) MergeShards(project, logstore string, shardID int) (shards []*Shard, err error) + func (c *Client) ModifyScheduledSQLJobInstanceState(projectName, jobName, instanceId string, state ScheduledSQLState) error + func (c *Client) PostLogStoreLogs(project, logstore string, lg *LogGroup, hashKey *string) (err error) + func (c *Client) PostLogStoreLogsV2(project, logstore string, req *PostLogStoreLogsRequest) (err error) + func (c *Client) PostRawLogWithCompressType(project, logstore string, rawLogData []byte, compressType int, hashKey *string) (err error) + func (c *Client) PublishAlertEvent(project string, alertResult []byte) error + func (c *Client) PullLogs(project, logstore string, shardID int, cursor, endCursor string, ...) (gl *LogGroupList, nextCursor string, err error) + func (c *Client) PullLogsV2(plr *PullLogRequest) (gl *LogGroupList, nextCursor string, err error) + func (c *Client) PullLogsWithQuery(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error) + func (c *Client) PutLogs(project, logstore string, lg *LogGroup) (err error) + func (c *Client) PutLogsWithCompressType(project, logstore string, lg *LogGroup, compressType int) (err error) + func (c *Client) PutLogsWithMetricStoreURL(project, logstore string, lg *LogGroup) (err error) + func (c *Client) PutRawLogWithCompressType(project, logstore string, rawLogData []byte, compressType int) (err error) + func (c *Client) RemoveConfigFromMachineGroup(project string, confName, groupName string) (err error) + func (c *Client) ResetAccessKeyToken(accessKeyID, accessKeySecret, securityToken string) + func (c *Client) RestartETL(project string, etljob ETL) error + func (c *Client) RestartExport(project string, export *Export) error + func (c *Client) SetAuthVersion(version AuthVersionType) + func (c *Client) SetHTTPClient(client *http.Client) + func (c *Client) SetRegion(region string) + func (c *Client) SetRetryTimeout(timeout time.Duration) + func (c *Client) SetUserAgent(userAgent string) + func (c *Client) SplitNumShard(project, logstore string, shardID, shardsNum int) (shards []*Shard, err error) + func (c *Client) SplitShard(project, logstore string, shardID int, splitKey string) (shards []*Shard, err error) + func (c *Client) StartETL(project, name string) error + func (c *Client) StopETL(project, name string) error + func (c *Client) TagResources(project string, tags *ResourceTags) error + func (c *Client) TagResourcesSystemTags(project string, tags *ResourceSystemTags) error + func (c *Client) UnTagResources(project string, tags *ResourceUnTags) error + func (c *Client) UnTagResourcesSystemTags(project string, tags *ResourceUnSystemTags) error + func (c *Client) UpdateAlert(project string, alert *Alert) error + func (c *Client) UpdateAlertString(project string, alertName, alert string) error + func (c *Client) UpdateChart(project, dashboardName string, chart Chart) error + func (c *Client) UpdateCheckpoint(project, logstore string, cgName string, consumer string, shardID int, ...) (err error) + func (c *Client) UpdateConfig(project string, config *LogConfig) (err error) + func (c *Client) UpdateConfigString(project string, configName, configDetail string) (err error) + func (c *Client) UpdateConsumerGroup(project, logstore string, cg ConsumerGroup) (err error) + func (c *Client) UpdateDashboard(project string, dashboard Dashboard) error + func (c *Client) UpdateDashboardString(project string, dashboardName, dashboardStr string) error + func (c *Client) UpdateETL(project string, etljob ETL) error + func (c *Client) UpdateEtlMeta(project string, etlMeta *EtlMeta) (err error) + func (c *Client) UpdateEventStore(project string, eventStore *LogStore) error + func (c *Client) UpdateExport(project string, export *Export) error + func (c *Client) UpdateIndex(project, logstore string, index Index) error + func (c *Client) UpdateIndexString(project, logstore string, index string) error + func (c *Client) UpdateIngestion(project string, ingestion *Ingestion) error + func (c *Client) UpdateLogStore(project string, logstore string, ttl, shardCnt int) (err error) + func (c *Client) UpdateLogStoreMeteringMode(project string, logstore string, meteringMode string) error + func (c *Client) UpdateLogStoreV2(project string, logstore *LogStore) (err error) + func (c *Client) UpdateLogging(project string, detail *Logging) error + func (c *Client) UpdateMachineGroup(project string, m *MachineGroup) (err error) + func (c *Client) UpdateMetricAggRules(project string, aggRules *MetricAggRules) error + func (c *Client) UpdateMetricStore(project string, metricStore *LogStore) error + func (c *Client) UpdateProject(name, description string) (*LogProject, error) + func (c *Client) UpdateProjectPolicy(project string, policy string) error + func (c *Client) UpdateResource(resource *Resource) error + func (c *Client) UpdateResourceRecord(resourceName string, record *ResourceRecord) error + func (c *Client) UpdateResourceRecordString(resourceName, recordStr string) error + func (c *Client) UpdateResourceString(resourceName, resourceStr string) error + func (c *Client) UpdateSavedSearch(project string, savedSearch *SavedSearch) error + func (c *Client) UpdateScheduledSQL(project string, scheduledsql *ScheduledSQL) error + func (c *Client) UpdateStoreView(project string, storeView *StoreView) error + func (c *Client) UpdateSubStore(project, logstore string, sss *SubStore) (err error) + func (c *Client) UpdateSubStoreTTL(project, logstore string, ttl int) (err error) + func (c *Client) WithCredentialsProvider(provider CredentialsProvider) *Client + type ClientInterface interface + ApplyConfigToMachineGroup func(project string, confName, groupName string) (err error) + CheckConfigExist func(project string, config string) (ok bool, err error) + CheckLogstoreExist func(project string, logstore string) (bool, error) + CheckMachineGroupExist func(project string, machineGroup string) (bool, error) + CheckProjectExist func(name string) (bool, error) + Close func() error + CreateAlert func(project string, alert *Alert) error + CreateAlertString func(project string, alert string) error + CreateChart func(project, dashboardName string, chart Chart) error + CreateConfig func(project string, config *LogConfig) (err error) + CreateConfigString func(project string, config string) (err error) + CreateConsumerGroup func(project, logstore string, cg ConsumerGroup) (err error) + CreateDashboard func(project string, dashboard Dashboard) error + CreateDashboardString func(project string, dashboardStr string) error + CreateETL func(project string, etljob ETL) error + CreateEtlMeta func(project string, etlMeta *EtlMeta) (err error) + CreateEventStore func(project string, eventStore *LogStore) error + CreateExport func(project string, export *Export) error + CreateIndex func(project, logstore string, index Index) error + CreateIndexString func(project, logstore string, indexStr string) error + CreateIngestion func(project string, ingestion *Ingestion) error + CreateLogStore func(project string, logstore string, ttl, shardCnt int, autoSplit bool, ...) error + CreateLogStoreV2 func(project string, logstore *LogStore) error + CreateMachineGroup func(project string, m *MachineGroup) error + CreateMetricStore func(project string, metricStore *LogStore) error + CreateProject func(name, description string) (*LogProject, error) + CreateProjectV2 func(name, description, dataRedundancyType string) (*LogProject, error) + CreateResource func(resource *Resource) error + CreateResourceRecord func(resourceName string, record *ResourceRecord) error + CreateResourceRecordString func(resourceName, recordStr string) error + CreateResourceString func(resourceStr string) error + CreateSavedSearch func(project string, savedSearch *SavedSearch) error + CreateScheduledSQL func(project string, scheduledsql *ScheduledSQL) error + CreateStoreView func(project string, storeView *StoreView) error + DeleteAlert func(project string, alertName string) error + DeleteChart func(project, dashboardName, chartName string) error + DeleteConfig func(project string, config string) (err error) + DeleteConsumerGroup func(project, logstore string, cgName string) (err error) + DeleteDashboard func(project, name string) error + DeleteETL func(project string, etlName string) error + DeleteEtlMeta func(project string, etlMetaName, etlMetaKey string) (err error) + DeleteEventStore func(project, name string) error + DeleteExport func(project string, name string) error + DeleteIndex func(project, logstore string) error + DeleteIngestion func(project string, name string) error + DeleteLogStore func(project string, logstore string) (err error) + DeleteMachineGroup func(project string, machineGroup string) (err error) + DeleteMetricStore func(project, name string) error + DeleteProject func(name string) error + DeleteProjectPolicy func(project string) error + DeleteResource func(name string) error + DeleteResourceRecord func(resourceName, recordId string) error + DeleteSavedSearch func(project string, savedSearchName string) error + DeleteScheduledSQL func(project string, name string) error + DeleteStoreView func(project string, storeViewName string) error + DisableAlert func(project string, alertName string) error + EnableAlert func(project string, alertName string) error + GetAlert func(project string, alertName string) (*Alert, error) + GetAlertString func(project string, alertName string) (string, error) + GetAppliedConfigs func(project string, groupName string) (confNames []string, err error) + GetAppliedMachineGroups func(project string, confName string) (groupNames []string, err error) + GetChart func(project, dashboardName, chartName string) (chart *Chart, err error) + GetCheckpoint func(project, logstore string, cgName string) (checkPointList []*ConsumerGroupCheckPoint, err error) + GetConfig func(project string, config string) (logConfig *LogConfig, err error) + GetConfigString func(name string, config string) (c string, err error) + GetCursor func(project, logstore string, shardID int, from string) (cursor string, err error) + GetCursorTime func(project, logstore string, shardID int, cursor string) (cursorTime time.Time, err error) + GetDashboard func(project, name string) (dashboard *Dashboard, err error) + GetDashboardString func(project, name string) (dashboard string, err error) + GetETL func(project string, etlName string) (ETLJob *ETL, err error) + GetEtlMeta func(project string, etlMetaName, etlMetaKey string) (etlMeta *EtlMeta, err error) + GetEventStore func(project, name string) (*LogStore, error) + GetExport func(project, name string) (*Export, error) + GetHistograms func(project, logstore string, topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error) + GetHistogramsToCompleted func(project, logstore string, topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error) + GetHistogramsToCompletedV2 func(project, logstore string, ghr *GetHistogramRequest) (*GetHistogramsResponse, error) + GetHistogramsV2 func(project, logstore string, ghr *GetHistogramRequest) (*GetHistogramsResponse, error) + GetIndex func(project, logstore string) (*Index, error) + GetIndexString func(project, logstore string) (string, error) + GetIngestion func(project string, name string) (*Ingestion, error) + GetLogLines func(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogLinesResponse, error) + GetLogLinesByNano func(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogLinesResponse, error) + GetLogLinesV2 func(project, logstore string, req *GetLogRequest) (*GetLogLinesResponse, error) + GetLogStore func(project string, logstore string) (*LogStore, error) + GetLogStoreMeteringMode func(project string, logstore string) (*GetMeteringModeResponse, error) + GetLogs func(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogsResponse, error) + GetLogsByNano func(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogsResponse, error) + GetLogsBytes func(project, logstore string, shardID int, cursor, endCursor string, ...) (out []byte, nextCursor string, err error) + GetLogsBytesV2 func(plr *PullLogRequest) (out []byte, nextCursor string, err error) + GetLogsBytesWithQuery func(plr *PullLogRequest) (out []byte, plm *PullLogMeta, err error) + GetLogsToCompleted func(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogsResponse, error) + GetLogsToCompletedV2 func(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error) + GetLogsToCompletedV3 func(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error) + GetLogsV2 func(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error) + GetLogsV3 func(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error) + GetMachineGroup func(project string, machineGroup string) (m *MachineGroup, err error) + GetMetricStore func(project, name string) (*LogStore, error) + GetProject func(name string) (*LogProject, error) + GetProjectPolicy func(project string) (string, error) + GetResource func(name string) (resource *Resource, err error) + GetResourceRecord func(resourceName, recordId string) (record *ResourceRecord, err error) + GetResourceRecordString func(resourceName, name string) (record string, err error) + GetResourceString func(name string) (resource string, err error) + GetSavedSearch func(project string, savedSearchName string) (*SavedSearch, error) + GetScheduledSQL func(project string, name string) (*ScheduledSQL, error) + GetScheduledSQLJobInstance func(projectName, jobName, instanceId string, result bool) (instance *ScheduledSQLJobInstance, err error) + GetStoreView func(project string, storeViewName string) (*StoreView, error) + GetStoreViewIndex func(project string, storeViewName string) (*GetStoreViewIndexResponse, error) + HeartBeat func(project, logstore string, cgName, consumer string, heartBeatShardIDs []int) (shardIDs []int, err error) + ListAlert func(project, alertName, dashboard string, offset, size int) (alerts []*Alert, total int, count int, err error) + ListConfig func(project string, offset, size int) (cfgNames []string, total int, err error) + ListConsumerGroup func(project, logstore string) (cgList []*ConsumerGroup, err error) + ListDashboard func(project string, dashboardName string, offset, size int) (dashboardList []string, count, total int, err error) + ListDashboardV2 func(project string, dashboardName string, offset, size int) (dashboardList []string, dashboardItems []ResponseDashboardItem, ...) + ListETL func(project string, offset int, size int) (*ListETLResponse, error) + ListEtlMeta func(project string, etlMetaName string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + ListEtlMetaName func(project string, offset, size int) (total int, count int, etlMetaNameList []string, err error) + ListEtlMetaWithTag func(project string, etlMetaName, etlMetaTag string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + ListEventStore func(project string, offset, size int) ([]string, error) + ListExport func(project, logstore, name, displayName string, offset, size int) (exports []*Export, total, count int, error error) + ListIngestion func(project, logstore, name, displayName string, offset, size int) (ingestions []*Ingestion, total, count int, error error) + ListLogStore func(project string) ([]string, error) + ListLogStoreV2 func(project string, offset, size int, telemetryType string) ([]string, error) + ListMachineGroup func(project string, offset, size int) (m []string, total int, err error) + ListMachines func(project, machineGroupName string) (ms []*Machine, total int, err error) + ListMachinesV2 func(project, machineGroupName string, offset, size int) (ms []*Machine, total int, err error) + ListProject func() (projectNames []string, err error) + ListProjectV2 func(offset, size int) (projects []LogProject, count, total int, err error) + ListResource func(resourceType string, resourceName string, offset, size int) (resourceList []*Resource, count, total int, err error) + ListResourceRecord func(resourceName string, offset, size int) (recordList []*ResourceRecord, count, total int, err error) + ListSavedSearch func(project string, savedSearchName string, offset, size int) (savedSearches []string, total int, count int, err error) + ListSavedSearchV2 func(project string, savedSearchName string, offset, size int) (savedSearches []string, savedsearchItems []ResponseSavedSearchItem, total int, ...) + ListScheduledSQL func(project, name, displayName string, offset, size int) ([]*ScheduledSQL, int, int, error) + ListScheduledSQLJobInstances func(projectName, jobName string, status *InstanceStatus) (instances []*ScheduledSQLJobInstance, total, count int64, err error) + ListShards func(project, logstore string) (shards []*Shard, err error) + ListStoreViews func(project string, req *ListStoreViewsRequest) (*ListStoreViewsResponse, error) + ListSystemTagResources func(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error) + ListTagResources func(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error) + MergeShards func(project, logstore string, shardID int) (shards []*Shard, err error) + ModifyScheduledSQLJobInstanceState func(projectName, jobName, instanceId string, state ScheduledSQLState) error + PostLogStoreLogs func(project, logstore string, lg *LogGroup, hashKey *string) (err error) + PostLogStoreLogsV2 func(project, logstore string, req *PostLogStoreLogsRequest) (err error) + PostRawLogWithCompressType func(project, logstore string, rawLogData []byte, compressType int, hashKey *string) (err error) + PublishAlertEvent func(project string, alertResult []byte) error + PullLogs func(project, logstore string, shardID int, cursor, endCursor string, ...) (gl *LogGroupList, nextCursor string, err error) + PullLogsV2 func(plr *PullLogRequest) (gl *LogGroupList, nextCursor string, err error) + PullLogsWithQuery func(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error) + PutLogs func(project, logstore string, lg *LogGroup) (err error) + PutLogsWithCompressType func(project, logstore string, lg *LogGroup, compressType int) (err error) + PutLogsWithMetricStoreURL func(project, logstore string, lg *LogGroup) (err error) + PutRawLogWithCompressType func(project, logstore string, rawLogData []byte, compressType int) (err error) + RemoveConfigFromMachineGroup func(project string, confName, groupName string) (err error) + ResetAccessKeyToken func(accessKeyID, accessKeySecret, securityToken string) + RestartETL func(project string, etljob ETL) error + RestartExport func(project string, export *Export) error + SetAuthVersion func(version AuthVersionType) + SetHTTPClient func(client *http.Client) + SetRegion func(region string) + SetRetryTimeout func(timeout time.Duration) + SetUserAgent func(userAgent string) + SplitNumShard func(project, logstore string, shardID, shardsNum int) (shards []*Shard, err error) + SplitShard func(project, logstore string, shardID int, splitKey string) (shards []*Shard, err error) + StartETL func(project, name string) error + StopETL func(project, name string) error + TagResources func(project string, tags *ResourceTags) error + TagResourcesSystemTags func(project string, tags *ResourceSystemTags) error + UnTagResources func(project string, tags *ResourceUnTags) error + UnTagResourcesSystemTags func(project string, tags *ResourceUnSystemTags) error + UpdateAlert func(project string, alert *Alert) error + UpdateAlertString func(project string, alertName, alert string) error + UpdateChart func(project, dashboardName string, chart Chart) error + UpdateCheckpoint func(project, logstore string, cgName string, consumer string, shardID int, ...) (err error) + UpdateConfig func(project string, config *LogConfig) (err error) + UpdateConfigString func(project string, configName, configDetail string) (err error) + UpdateConsumerGroup func(project, logstore string, cg ConsumerGroup) (err error) + UpdateDashboard func(project string, dashboard Dashboard) error + UpdateDashboardString func(project string, dashboardName, dashboardStr string) error + UpdateETL func(project string, etljob ETL) error + UpdateEtlMeta func(project string, etlMeta *EtlMeta) (err error) + UpdateEventStore func(project string, eventStore *LogStore) error + UpdateExport func(project string, export *Export) error + UpdateIndex func(project, logstore string, index Index) error + UpdateIndexString func(project, logstore string, indexStr string) error + UpdateIngestion func(project string, ingestion *Ingestion) error + UpdateLogStore func(project string, logstore string, ttl, shardCnt int) (err error) + UpdateLogStoreMeteringMode func(project string, logstore string, meteringMode string) error + UpdateLogStoreV2 func(project string, logstore *LogStore) error + UpdateMachineGroup func(project string, m *MachineGroup) (err error) + UpdateMetricStore func(project string, metricStore *LogStore) error + UpdateProject func(name, description string) (*LogProject, error) + UpdateProjectPolicy func(project string, policy string) error + UpdateResource func(resource *Resource) error + UpdateResourceRecord func(resourceName string, record *ResourceRecord) error + UpdateResourceRecordString func(resourceName, recordStr string) error + UpdateResourceString func(resourceName, resourceStr string) error + UpdateSavedSearch func(project string, savedSearch *SavedSearch) error + UpdateScheduledSQL func(project string, scheduledsql *ScheduledSQL) error + UpdateStoreView func(project string, storeView *StoreView) error + func CreateNormalInterface(endpoint, accessKeyID, accessKeySecret, securityToken string) ClientInterface + func CreateNormalInterfaceV2(endpoint string, credentialsProvider CredentialsProvider) ClientInterface + func CreateTokenAutoUpdateClient(endpoint string, tokenUpdateFunc UpdateTokenFunction, shutdown <-chan struct{}) (client ClientInterface, err error) + type Column struct + Name string + Type string + type ColumnStorageContentDetail struct + Columns []Column + type CommonConfigInputDetail struct + AdjustTimeZone bool + DelayAlarmBytes int + EnableRawLog bool + EnableTag bool + FilterKeys []string + FilterRegex []string + LocalStorage bool + LogTimeZone string + MaxSendRate int + MergeType string + Priority int + SendRateExpire int + SensitiveKeys []SensitiveKey + ShardHashKey []string + type ConditionConfiguration struct + Condition string + CountCondition string + type ConditionOperation func() (bool, error) + type ConfigPluginCanal struct + Charset string + EnableDDL bool + EnableDelete bool + EnableGTID bool + EnableInsert bool + EnableUpdate bool + EnableXID bool + ExcludeTables []string + Flavor string + HeartBeatPeriod int + Host string + IncludeTables []string + Password string + Port int + ReadTimeout int + ServerID int + StartBinLogPos int + StartBinName string + StartFromBegining bool + TextToString bool + User string + func CreateConfigPluginCanal() *ConfigPluginCanal + type ConfigPluginDockerStdout struct + BeginLineCheckLength int + BeginLineRegex string + BeginLineTimeoutMs int + ExcludeEnv map[string]string + ExcludeLabel map[string]string + FlushIntervalMs int + IncludeEnv map[string]string + IncludeLabel map[string]string + MaxLogSize int + Stderr bool + Stdout bool + TimeoutMs int + func CreateConfigPluginDockerStdout() *ConfigPluginDockerStdout + type ConsumerGroup struct + ConsumerGroupName string + InOrder bool + Timeout int + func (cg *ConsumerGroup) String() string + type ConsumerGroupCheckPoint struct + CheckPoint string + Consumer string + ShardID int + UpdateTime int64 + type Credentials struct + AccessKeyID string + AccessKeySecret string + SecurityToken string + type CredentialsFetcher = func() (*tempCredentials, error) + type CredentialsProvider interface + GetCredentials func() (Credentials, error) + func NewEcsRamRoleCredentialsProvider(roleName string) CredentialsProvider + type CsvContentDetail struct + ColumnNames []string + Delimiter string + Escape string + Header bool + LineFeed string + Null string + Quote string + type Dashboard struct + ChartList []Chart + DashboardName string + Description string + DisplayName string + type DataFormat string + const LOG_TO_LOG + const LOG_TO_METRIC + const METRIC_TO_metric + type DataSink interface + DataSinkType func() DataSinkType + type DataSinkType string + type DataSource struct + DataSourceType DataSourceType + type DataSourceType string + type DelimitedTextFormat struct + EscapeChar string + FieldDelimiter string + FieldNames []string + FirstRowAsHeader bool + MaxLines int64 + QuoteChar string + SkipLeadingRows int64 + type DelimiterConfigInputDetail struct + AcceptNoEnoughKeys bool + AutoExtend bool + Key []string + Quote string + Separator string + TimeKey string + func ConvertToDelimiterConfigInputDetail(detail InputDetailInterface) (*DelimiterConfigInputDetail, bool) + type ETL struct + Configuration ETLConfiguration + CreateTime int32 + Description string + DisplayName string + LastModifiedTime int32 + Name string + Schedule ETLSchedule + Status string + Type string + func NewETL(endpoint, accessKeyId, accessKeySecret, logstore, name, project string) ETL + type ETLConfiguration struct + AccessKeyId string + AccessKeySecret string + ETLSinks []ETLSink + FromTime int64 + Logstore string + Parameters map[string]string + RoleArn string + Script string + ToTime int32 + Version int8 + type ETLJob struct + CreateTime int64 + Enable bool + FunctionConfig *FunctionConfig + FunctionParameter interface{} + JobName string + LogConfig *JobLogConfig + SourceConfig *SourceConfig + TriggerConfig *TriggerConfig + UpdateTime int64 + func (job *ETLJob) UnmarshalJSON(data []byte) error + type ETLSchedule struct + Type string + type ETLSink struct + AccessKeyId string + AccessKeySecret string + Endpoint string + Logstore string + Name string + Project string + RoleArn string + Type string + type EncryptConf struct + Enable bool + EncryptType string + UserCmkInfo *EncryptUserCmkConf + type EncryptUserCmkConf struct + Arn string + CmkKeyId string + RegionId string + type Error struct + Code string + HTTPCode int32 + Message string + RequestID string + func NewClientError(err error) *Error + func (e Error) Error() string + func (e Error) String() string + type EtlMeta struct + MetaKey string + MetaName string + MetaTag string + MetaValue map[string]string + type Export struct + ExportConfiguration *ExportConfiguration + type ExportConfiguration struct + DataSink DataSink + FromTime int64 + LogStore string + Parameters map[string]string + RoleArn string + ToTime int64 + Version ExportVersion + func (e *ExportConfiguration) UnmarshalJSON(data []byte) error + type ExportVersion string + type FunctionConfig struct + AccountID string + Endpoint string + FunctionName string + FunctionProvider string + RegionName string + RoleARN string + ServiceName string + type GetContextLogsResponse struct + BackLines int64 + ForwardLines int64 + Logs []map[string]string + Progress string + TotalLines int64 + func (resp *GetContextLogsResponse) IsComplete() bool + type GetHistogramRequest struct + From int64 + Interval int32 + Query string + To int64 + Topic string + func (ghr *GetHistogramRequest) ToURLParams() url.Values + type GetHistogramsResponse struct + Count int64 + Histograms []SingleHistogram + Progress string + func (resp *GetHistogramsResponse) IsComplete() bool + type GetLogLinesResponse struct + Lines []json.RawMessage + type GetLogRequest struct + From int64 + FromNsPart int32 + IsAccurate bool + Lines int64 + NeedHighlight bool + Offset int64 + PowerSQL bool + Query string + Reverse bool + To int64 + ToNsPart int32 + Topic string + func (glr *GetLogRequest) ToURLParams() url.Values + type GetLogsResponse struct + Contents string + Count int64 + HasSQL bool + Header http.Header + Logs []map[string]string + Progress string + func (resp *GetLogsResponse) GetKeys() (error, []string) + func (resp *GetLogsResponse) IsComplete() bool + type GetLogsV3Response struct + Logs []map[string]string + Meta GetLogsV3ResponseMeta + func (resp *GetLogsV3Response) IsComplete() bool + type GetLogsV3ResponseMeta struct + AggQuery string + ColumnTypes []string + Count int64 + CpuCores float64 + CpuSec float64 + ElapsedMillisecond int64 + HasSQL bool + Highlights []map[string]string + InsertedSql string + IsAccurate *bool + Keys []string + Limited int64 + Marker *string + Mode *int + PhraseQueryInfo *PhraseQueryInfoV3 + PowerSql bool + ProcessedBytes int64 + ProcessedRows int64 + Progress string + ScanBytes *int64 + Shard *int + TelemetryType string + Terms []MetaTerm + WhereQuery string + type GetMeteringModeResponse struct + MeteringMode string + type GetStoreViewIndexResponse struct + Indexes []*StoreViewIndex + StoreViewErrors []*StoreViewErrors + type GlobalConfig struct + ConfigDetail struct{ ... } + ConfigId string + ConfigName string + type GroupConfiguration struct + Fields []string + Type string + type Index struct + Keys map[string]IndexKey + Line *IndexLine + LogReduce bool + LogReduceBlackListDict []string + LogReduceWhiteListDict []string + MaxTextLen uint32 + Ttl uint32 + func CreateDefaultIndex() *Index + type IndexKey struct + Alias string + CaseSensitive bool + Chn bool + DocValue bool + JsonKeys map[string]*JsonKey + Token []string + Type string + type IndexLine struct + CaseSensitive bool + Chn bool + ExcludeKeys []string + IncludeKeys []string + Token []string + type Ingestion struct + IngestionConfiguration *IngestionConfiguration + type IngestionConfiguration struct + DataSource interface{} + LogStore string + NumberOfInstance int32 + Version string + type IngestionGeneralSource struct + Fields map[string]interface{} + type InputDetail struct + AutoExtend bool + FilePattern string + FilterKeys []string + FilterRegex []string + Keys []string + LocalStorage bool + LogBeginRegex string + LogPath string + LogType string + Regex string + Separator string + TimeFormat string + TimeKey string + TopicFormat string + func ConvertToInputDetail(detail InputDetailInterface) (*InputDetail, bool) + type InputDetailInterface interface + type InstanceStatus struct + FromTime int64 + Offset int64 + Size int64 + State ScheduledSQLState + ToTime int64 + type JSONConfigInputDetail struct + TimeKey string + func ConvertToJSONConfigInputDetail(detail InputDetailInterface) (*JSONConfigInputDetail, bool) + type JSONFormat struct + SkipInvalidRows bool + type JobLogConfig struct + Endpoint string + LogstoreName string + ProjectName string + type JobType string + const ALERT_JOB + const AUDIT_JOB_JOB + const ETL_JOB + const EXPORT_JOB + const INGESTION_JOB + const REBUILD_INDEX_JOB + const REPORT_JOB + const SCHEDULED_SQL_JOB + type JoinConfiguration struct + Condition string + Type string + type JsonContentDetail struct + EnableTag bool + type JsonKey struct + Alias string + DocValue bool + Type string + type KafkaPosition string + type KafkaSource struct + AdditionalProps map[string]string + BootStrapServers string + Communication string + FromPosition KafkaPosition + FromTimeStamp int64 + NameResolutions string + TimeField string + TimeFormat string + TimePattern string + TimeZone string + ToTimeStamp int64 + Topics string + ValueType KafkaValueType + VpcId string + type KafkaValueType string + type LineFormat struct + TimePattern string + type ListETLResponse struct + Count int + Results []*ETL + Total int + type ListStoreViewsRequest struct + Offset int + Size int + type ListStoreViewsResponse struct + Count int + StoreViews []string + Total int + type LocalFileConfigInputDetail struct + Advanced map[string]interface{} + DelaySkipBytes int + DiscardNonUtf8 bool + DiscardUnmatch bool + DockerExcludeEnv map[string]string + DockerExcludeLabel map[string]string + DockerIncludeEnv map[string]string + DockerIncludeLabel map[string]string + FileEncoding string + FilePattern string + IsDockerFile bool + LogPath string + LogType string + MaxDepth int + PluginDetail map[string]interface{} + Preserve bool + PreserveDepth int + TailExisted bool + TimeFormat string + TopicFormat string + type Log struct + Contents []*LogContent + Time *uint32 + TimeNs *uint32 + func (*Log) Descriptor() ([]byte, []int) + func (*Log) ProtoMessage() + func (x *Log) GetContents() []*LogContent + func (x *Log) GetTime() uint32 + func (x *Log) GetTimeNs() uint32 + func (x *Log) ProtoReflect() protoreflect.Message + func (x *Log) Reset() + func (x *Log) String() string + type LogCompressor interface + Compress func(src, dst []byte) ([]byte, error) + Decompress func(src, dst []byte) ([]byte, error) + type LogConfig struct + CreateTime uint32 + InputDetail InputDetailInterface + InputType string + LastModifyTime uint32 + LogSample string + Name string + OutputDetail OutputDetail + OutputType string + type LogConfigPluginInput struct + Aggregators []*PluginInputItem + Flushers []*PluginInputItem + Inputs []*PluginInputItem + Processors []*PluginInputItem + type LogContent struct + Key *string + Value *string + func (*LogContent) Descriptor() ([]byte, []int) + func (*LogContent) ProtoMessage() + func (x *LogContent) GetKey() string + func (x *LogContent) GetValue() string + func (x *LogContent) ProtoReflect() protoreflect.Message + func (x *LogContent) Reset() + func (x *LogContent) String() string + type LogGroup struct + Category *string + LogTags []*LogTag + Logs []*Log + MachineUUID *string + Source *string + Topic *string + func (*LogGroup) Descriptor() ([]byte, []int) + func (*LogGroup) ProtoMessage() + func (l *LogGroup) GetCursor() string + func (x *LogGroup) GetCategory() string + func (x *LogGroup) GetLogTags() []*LogTag + func (x *LogGroup) GetLogs() []*Log + func (x *LogGroup) GetMachineUUID() string + func (x *LogGroup) GetSource() string + func (x *LogGroup) GetTopic() string + func (x *LogGroup) ProtoReflect() protoreflect.Message + func (x *LogGroup) Reset() + func (x *LogGroup) String() string + type LogGroupList struct + LogGroups []*LogGroup + func LogsBytesDecode(data []byte) (gl *LogGroupList, err error) + func (*LogGroupList) Descriptor() ([]byte, []int) + func (*LogGroupList) ProtoMessage() + func (x *LogGroupList) GetLogGroups() []*LogGroup + func (x *LogGroupList) ProtoReflect() protoreflect.Message + func (x *LogGroupList) Reset() + func (x *LogGroupList) String() string + type LogProject struct + AccessKeyID string + AccessKeySecret string + AuthVersion AuthVersionType + CommonHeaders map[string]string + CreateTime string + DataRedundancyType string + Description string + Endpoint string + InnerHeaders map[string]string + LastModifyTime string + Location string + Name string + Owner string + Region string + SecurityToken string + Status string + UserAgent string + UsingHTTP bool + func NewLogProject(name, endpoint, accessKeyID, accessKeySecret string) (p *LogProject, err error) + func NewLogProjectV2(name, endpoint string, provider CredentialsProvider) (p *LogProject, err error) + func (p *LogProject) ApplyConfigToMachineGroup(confName, groupName string) (err error) + func (p *LogProject) CheckConfigExist(name string) (bool, error) + func (p *LogProject) CheckLogstoreExist(name string) (bool, error) + func (p *LogProject) CheckMachineGroupExist(name string) (bool, error) + func (p *LogProject) CreateConfig(c *LogConfig) (err error) + func (p *LogProject) CreateConfigString(c string) (err error) + func (p *LogProject) CreateETLJob(j *ETLJob) error + func (p *LogProject) CreateEtlMeta(etlMeta *EtlMeta) (err error) + func (p *LogProject) CreateLogStore(name string, ttl, shardCnt int, autoSplit bool, maxSplitShard int) error + func (p *LogProject) CreateLogStoreV2(logstore *LogStore) error + func (p *LogProject) CreateLogging(detail *Logging) (err error) + func (p *LogProject) CreateMachineGroup(m *MachineGroup) error + func (p *LogProject) DeleteConfig(name string) (err error) + func (p *LogProject) DeleteETLJob(name string) error + func (p *LogProject) DeleteEtlMeta(etlMetaName, etlMetaKey string) (err error) + func (p *LogProject) DeleteLogStore(name string) (err error) + func (p *LogProject) DeleteLogging() (err error) + func (p *LogProject) DeleteMachineGroup(name string) (err error) + func (p *LogProject) GetAppliedConfigs(groupName string) (confNames []string, err error) + func (p *LogProject) GetAppliedMachineGroups(confName string) (groupNames []string, err error) + func (p *LogProject) GetConfig(name string) (c *LogConfig, err error) + func (p *LogProject) GetConfigString(name string) (c string, err error) + func (p *LogProject) GetETLJob(name string) (*ETLJob, error) + func (p *LogProject) GetEtlMeta(etlMetaName, etlMetaKey string) (etlMeta *EtlMeta, err error) + func (p *LogProject) GetLogStore(name string) (*LogStore, error) + func (p *LogProject) GetLogging() (c *Logging, err error) + func (p *LogProject) GetMachineGroup(name string) (m *MachineGroup, err error) + func (p *LogProject) ListConfig(offset, size int) (cfgNames []string, total int, err error) + func (p *LogProject) ListETLJobs() ([]string, error) + func (p *LogProject) ListEtlMeta(etlMetaName string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + func (p *LogProject) ListEtlMetaName(offset, size int) (total int, count int, etlMetaNameList []string, err error) + func (p *LogProject) ListEtlMetaWithTag(etlMetaName, etlMetaTag string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + func (p *LogProject) ListLogStore() ([]string, error) + func (p *LogProject) ListLogStoreV2(offset, size int, telemetryType string) ([]string, error) + func (p *LogProject) ListMachineGroup(offset, size int) (m []string, total int, err error) + func (p *LogProject) RawRequest(method, uri string, headers map[string]string, body []byte) (*http.Response, error) + func (p *LogProject) RemoveConfigFromMachineGroup(confName, groupName string) (err error) + func (p *LogProject) UpdateConfig(c *LogConfig) (err error) + func (p *LogProject) UpdateConfigString(configName, c string) (err error) + func (p *LogProject) UpdateETLJob(name string, job *ETLJob) error + func (p *LogProject) UpdateEtlMeta(etlMeta *EtlMeta) (err error) + func (p *LogProject) UpdateLogStore(name string, ttl, shardCnt int) (err error) + func (p *LogProject) UpdateLogStoreV2(logstore *LogStore) (err error) + func (p *LogProject) UpdateLogging(detail *Logging) (err error) + func (p *LogProject) UpdateMachineGroup(m *MachineGroup) (err error) + func (p *LogProject) WithCredentialsProvider(provider CredentialsProvider) *LogProject + func (p *LogProject) WithRequestTimeout(timeout time.Duration) *LogProject + func (p *LogProject) WithRetryTimeout(timeout time.Duration) *LogProject + func (p *LogProject) WithToken(token string) (*LogProject, error) + type LogStore struct + AppendMeta bool + AutoSplit bool + CreateTime uint32 + EncryptConf *EncryptConf + HotTTL int32 + LastModifyTime uint32 + MaxSplitShard int + Mode string + Name string + ProductType string + ShardCount int + TTL int + TelemetryType string + WebTracking bool + func NewLogStore(logStoreName string, project *LogProject) (*LogStore, error) + func (s *LogStore) CheckIndexExist() (bool, error) + func (s *LogStore) CreateIndex(index Index) error + func (s *LogStore) CreateIndexString(indexStr string) error + func (s *LogStore) CreateShipper(shipper *Shipper) error + func (s *LogStore) DeleteIndex() error + func (s *LogStore) DeleteShipper(shipperName string) error + func (s *LogStore) GetContextLogs(backLines int32, forwardLines int32, packID string, packMeta string) (*GetContextLogsResponse, error) + func (s *LogStore) GetCursor(shardID int, from string) (cursor string, err error) + func (s *LogStore) GetHistograms(topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error) + func (s *LogStore) GetHistogramsToCompleted(topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error) + func (s *LogStore) GetHistogramsToCompletedV2(ghr *GetHistogramRequest) (*GetHistogramsResponse, error) + func (s *LogStore) GetHistogramsV2(ghr *GetHistogramRequest) (*GetHistogramsResponse, error) + func (s *LogStore) GetIndex() (*Index, error) + func (s *LogStore) GetIndexString() (string, error) + func (s *LogStore) GetLogLines(topic string, from int64, to int64, queryExp string, maxLineNum int64, ...) (*GetLogLinesResponse, error) + func (s *LogStore) GetLogLinesByNano(topic string, fromInNS int64, toInNs int64, queryExp string, maxLineNum int64, ...) (*GetLogLinesResponse, error) + func (s *LogStore) GetLogLinesV2(req *GetLogRequest) (*GetLogLinesResponse, error) + func (s *LogStore) GetLogs(topic string, from int64, to int64, queryExp string, maxLineNum int64, ...) (*GetLogsResponse, error) + func (s *LogStore) GetLogsByNano(topic string, fromInNS int64, toInNs int64, queryExp string, maxLineNum int64, ...) (*GetLogsResponse, error) + func (s *LogStore) GetLogsBytes(shardID int, cursor, endCursor string, logGroupMaxCount int) (out []byte, nextCursor string, err error) + func (s *LogStore) GetLogsBytesV2(plr *PullLogRequest) ([]byte, string, error) + func (s *LogStore) GetLogsBytesWithQuery(plr *PullLogRequest) ([]byte, *PullLogMeta, error) + func (s *LogStore) GetLogsToCompleted(topic string, from int64, to int64, queryExp string, maxLineNum int64, ...) (*GetLogsResponse, error) + func (s *LogStore) GetLogsToCompletedV2(req *GetLogRequest) (*GetLogsResponse, error) + func (s *LogStore) GetLogsToCompletedV3(req *GetLogRequest) (*GetLogsV3Response, error) + func (s *LogStore) GetLogsV2(req *GetLogRequest) (*GetLogsResponse, error) + func (s *LogStore) GetLogsV3(req *GetLogRequest) (*GetLogsV3Response, error) + func (s *LogStore) GetMeteringMode() (*GetMeteringModeResponse, error) + func (s *LogStore) GetShipper(shipperName string) (*Shipper, error) + func (s *LogStore) ListShards() (shardIDs []*Shard, err error) + func (s *LogStore) ListShipper() ([]string, error) + func (s *LogStore) PostLogStoreLogs(lg *LogGroup, hashKey *string) (err error) + func (s *LogStore) PostRawLogs(body []byte, hashKey *string) (err error) + func (s *LogStore) PullLogs(shardID int, cursor, endCursor string, logGroupMaxCount int) (gl *LogGroupList, nextCursor string, err error) + func (s *LogStore) PullLogsV2(plr *PullLogRequest) (*LogGroupList, string, error) + func (s *LogStore) PullLogsWithQuery(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error) + func (s *LogStore) PutLogs(lg *LogGroup) (err error) + func (s *LogStore) PutRawLog(rawLogData []byte) (err error) + func (s *LogStore) SetPutLogCompressType(compressType int) error + func (s *LogStore) UpdateIndex(index Index) error + func (s *LogStore) UpdateIndexString(indexStr string) error + func (s *LogStore) UpdateMeteringMode(meteringMode string) error + func (s *LogStore) UpdateShipper(shipper *Shipper) error + type LogTag struct + Key *string + Value *string + func (*LogTag) Descriptor() ([]byte, []int) + func (*LogTag) ProtoMessage() + func (x *LogTag) GetKey() string + func (x *LogTag) GetValue() string + func (x *LogTag) ProtoReflect() protoreflect.Message + func (x *LogTag) Reset() + func (x *LogTag) String() string + type Logging struct + LoggingDetails []*LoggingDetail + Project string + type LoggingDetail struct + Logstore string + Type string + type MachinGroupAttribute struct + ExternalName string + TopicName string + type Machine struct + IP string + LastHeartBeatTime int + UniqueID string + UserdefinedID string + type MachineGroup struct + Attribute MachinGroupAttribute + CreateTime uint32 + LastModifyTime uint32 + MachineIDList []string + MachineIDType string + Name string + Type string + type MachineList struct + Machines []*Machine + Total int + type MetaTerm struct + Key string + Term string + type MetricAggRuleItem struct + BeginUnixTime int64 + DelaySeconds int64 + EndUnixTime int64 + Interval int64 + LabelNames map[string]string + MetricNames []string + Name string + Query string + QueryType string + TimeName string + type MetricAggRules struct + AggRules []MetricAggRuleItem + Desc string + DestAccessKeyID string + DestAccessKeySecret string + DestEndpoint string + DestProject string + DestStore string + ID string + Name string + SrcAccessKeyID string + SrcAccessKeySecret string + SrcStore string + type MultiLineFormat struct + FlushPattern string + Match string + MaxLines int64 + Negate bool + Pattern string + type Notification struct + Content string + EmailList []string + Headers map[string]string + Method string + MobileList []string + ServiceUri string + Type string + type OSSCompressionType string + type OSSContentType string + type OSSDataFormat struct + TimeFormat string + TimeZone string + Type OSSDataFormatType + type OSSDataFormatType string + type OSSShipperConfig struct + BufferInterval int + BufferSize int + CompressType string + Format string + OssBucket string + OssPrefix string + PathFormat string + RoleArn string + Storage ShipperStorage + type OrcContentDetail ColumnStorageContentDetail + type OssStorageJsonDetail struct + EnableTag bool + type OssStoreageCsvDetail struct + Columns []string + Delimiter string + Header bool + LineFeed string + NullIdentifier string + Quote string + type OssStoreageParquet struct + Columns []ParquetConfig + type OutputDetail struct + CompressType string + LogStoreName string + ProjectName string + type ParquetConfig struct + Name string + Type string + type ParquetContentDetail ColumnStorageContentDetail + type ParquetFormat struct + type PhraseQueryInfoV2 struct + BeginOffset string + EndOffset string + EndTime string + ScanAll string + type PhraseQueryInfoV3 struct + BeginOffset *int64 + EndOffset *int64 + EndTime *int64 + ScanAll *bool + type PluginInputItem struct + Detail PluginInterface + Type string + func CreatePluginInputItem(t string, detail PluginInterface) *PluginInputItem + type PluginInterface interface + type PluginLogConfigInputDetail struct + PluginDetail LogConfigPluginInput + func ConvertToPluginLogConfigInputDetail(detail InputDetailInterface) (*PluginLogConfigInputDetail, bool) + type PolicyConfiguration struct + ActionPolicyId string + AlertPolicyId string + RepeatInterval string + UseDefault bool + type PostLogStoreLogsRequest struct + CompressType int + HashKey *string + LogGroup *LogGroup + type PowerSqlMode string + const PowerSqlModeAuto + const PowerSqlModeDisable + const PowerSqlModeEnable + type PullLogMeta struct + Count int + DataCountBeforeQuery int + FailedLines int + Lines int + LinesBeforeQuery int + Netflow int + NextCursor string + RawSize int + RawSizeBeforeQuery int + type PullLogRequest struct + CompressType int + Cursor string + EndCursor string + LogGroupMaxCount int + Logstore string + Project string + PullMode string + Query string + QueryId string + ShardID int + func (plr *PullLogRequest) ToURLParams() url.Values + type QueryInfoV2 struct + ColumnTypes []string + Highlights []map[string]string + IsAccurate *int64 + Keys []string + Limited string + Marker *string + Mode *int + PhraseQueryInfo *PhraseQueryInfoV2 + ScanBytes *int64 + Shard *int + Terms [][]string + type RegexConfigInputDetail struct + CustomizedFields string + Key []string + LogBeginRegex string + Regex string + func ConvertToRegexConfigInputDetail(detail InputDetailInterface) (*RegexConfigInputDetail, bool) + type Resource struct + CreateTime int64 + Description string + ExtInfo string + LastModifyTime int64 + Name string + Schema string + Type string + type ResourceActionPolicy struct + ActionPolicyId string + ActionPolicyName string + EscalationEnabled bool + EscalationInprogressEnabled bool + EscalationInprogressTimeout string + EscalationStartEnabled bool + EscalationStartTimeout string + EscalationTimeout string + IsDefault bool + Labels map[string]string + PrimaryPolicyScript string + SecondaryPolicyScript string + type ResourceAlertPolicy struct + GroupPolicy string + InhibitPolicy string + IsDefault bool + Parent string + PolicyId string + PolicyName string + SilencePolicy string + type ResourceContentTemplate struct + IsDefault bool + TemplateId string + TemplateName string + Templates ResourceTemplates + type ResourceFilterTag struct + Key *string + Value *string + type ResourcePool string + const DEFAULT + const ENHANCED + type ResourceRecord struct + CreateTime int64 + Id string + LastModifyTime int64 + Tag string + Value string + type ResourceSchema struct + Schema []*ResourceSchemaItem + func (rs *ResourceSchema) FromJsonString(schema string) error + func (rs *ResourceSchema) ToString() string + type ResourceSchemaItem struct + Column string + Desc string + ExtInfo interface{} + Required bool + Type string + type ResourceSystemTags struct + Scope string + TagOwnerUid string + func NewResourceSystemTags(resourceType string, resourceId string, tagOwnerUid string, tags []ResourceTag) *ResourceSystemTags + type ResourceTag struct + Key string + Value string + type ResourceTagResponse struct + ResourceID string + ResourceType string + TagKey string + TagValue string + type ResourceTags struct + ResourceID []string + ResourceType string + Tags []ResourceTag + func NewProjectTags(project string, tags []ResourceTag) *ResourceTags + func NewResourceTags(resourceType string, resourceId string, tags []ResourceTag) *ResourceTags + type ResourceTemplate struct + Content string + Limit int + Locale string + SendType string + Subject string + Title string + type ResourceTemplates struct + Dingtalk ResourceTemplate + Email ResourceTemplate + Lark ResourceTemplate + MessageCenter ResourceTemplate + Slack ResourceTemplate + Sms ResourceTemplate + Voice ResourceTemplate + Webhook ResourceTemplate + Wechat ResourceTemplate + type ResourceUnSystemTags struct + TagOwnerUid string + func NewResourceUnSystemTags(resourceType string, resourceId string, tagOwnerUid string, tags []string) *ResourceUnSystemTags + type ResourceUnTags struct + All bool + ResourceID []string + ResourceType string + Tags []string + func NewProjectUnTags(project string, tags []string) *ResourceUnTags + func NewResourceUnTags(resourceType string, resourceId string, tags []string) *ResourceUnTags + type ResourceUser struct + CountryCode string + Email []string + Enabled bool + Phone string + SmsEnabled bool + UserId string + UserName string + VoiceEnabled bool + type ResourceUserGroup struct + Enabled bool + Id string + Members []string + Name string + type ResourceWebhookHeader struct + Key string + Value string + type ResponseDashboardItem struct + DashboardName string + DisplayName string + type ResponseSavedSearchItem struct + DisplayName string + SavedSearchName string + type S3Source struct + AWSAccessKey string + AWSAccessKeySecret string + AWSRegion string + Bucket string + CompressionCodec string + Encoding string + Format interface{} + Pattern string + Prefix string + type SavedSearch struct + DisplayName string + Logstore string + SavedSearchName string + SearchQuery string + Topic string + type Schedule struct + CronExpression string + DayOfWeek int32 + Delay int32 + Hour int32 + Interval string + RunImmediately bool + TimeZone string + Type string + type ScheduledJob struct + Schedule *Schedule + ScheduleId string + Status string + type ScheduledSQL struct + Configuration *ScheduledSQLConfiguration + CreateTime int64 + Description string + DisplayName string + LastModifiedTime int64 + Name string + Schedule *Schedule + ScheduleId string + Status Status + Type JobType + type ScheduledSQLConfiguration struct + DataFormat DataFormat + DestEndpoint string + DestLogStore string + DestProject string + DestRoleArn string + FromTime int64 + FromTimeExpr string + MaxRetries int32 + MaxRunTimeInSeconds int32 + Parameters *ScheduledSQLParameters + ResourcePool ResourcePool + RoleArn string + Script string + SourceLogStore string + SqlType SqlType + ToTime int64 + ToTimeExpr string + func NewScheduledSQLConfiguration() *ScheduledSQLConfiguration + type ScheduledSQLJobInstance struct + CreateTimeInMillis int64 + Description string + DisplayName string + ErrorCode string + ErrorMessage string + InstanceId string + JobName string + JobScheduleId string + ScheduleTimeInMillis int64 + State ScheduledSQLState + Summary string + UpdateTimeInMillis int64 + type ScheduledSQLParameters struct + AddLabels string + HashLabels string + LabelKeys string + MetricKeys string + MetricName string + TimeKey string + type ScheduledSQLState string + const ScheduledSQL_FAILED + const ScheduledSQL_RUNNING + const ScheduledSQL_SUCCEEDED + type SensitiveKey struct + All bool + ConstString string + Key string + RegexBegin string + RegexContent string + Type string + type Severity int + const Critical + const High + const Low + const Medium + const Report + type SeverityConfiguration struct + EvalCondition ConditionConfiguration + Severity Severity + type Shard struct + CreateTime int + ExclusiveBeginKey string + InclusiveBeginKey string + ShardID int + Status string + type Shipper struct + RawTargetConfiguration json.RawMessage + ShipperName string + TargetConfiguration interface{} + TargetType string + func (s *Shipper) MarshalJSON() ([]byte, error) + func (s *Shipper) UnmarshalJSON(data []byte) error + type ShipperStorage struct + Detail interface{} + Format string + type Signer interface + Sign func(method, uriWithQuery string, headers map[string]string, body []byte) error + type SignerV0 struct + func NewSignerV0() *SignerV0 + func (s *SignerV0) Sign(method, uriWithQuery string, headers map[string]string, body []byte) error + type SignerV1 struct + func NewSignerV1(accessKeyID, accessKeySecret string) *SignerV1 + func (s *SignerV1) Sign(method, uri string, headers map[string]string, body []byte) error + type SignerV4 struct + func NewSignerV4(accessKeyID, accessKeySecret, region string) *SignerV4 + func (s *SignerV4) Sign(method, uri string, headers map[string]string, body []byte) error + type SingleHistogram struct + Count int64 + From int64 + Progress string + To int64 + type SinkAlerthubConfiguration struct + Enabled bool + type SinkCmsConfiguration struct + Enabled bool + type SinkEventStoreConfiguration struct + Enabled bool + Endpoint string + EventStore string + Project string + RoleArn string + type SlsLogPackage struct + Data []byte + UncompressSize *int32 + func (*SlsLogPackage) Descriptor() ([]byte, []int) + func (*SlsLogPackage) ProtoMessage() + func (x *SlsLogPackage) GetData() []byte + func (x *SlsLogPackage) GetUncompressSize() int32 + func (x *SlsLogPackage) ProtoReflect() protoreflect.Message + func (x *SlsLogPackage) Reset() + func (x *SlsLogPackage) String() string + type SlsLogPackageList struct + Packages []*SlsLogPackage + func (*SlsLogPackageList) Descriptor() ([]byte, []int) + func (*SlsLogPackageList) ProtoMessage() + func (x *SlsLogPackageList) GetPackages() []*SlsLogPackage + func (x *SlsLogPackageList) ProtoReflect() protoreflect.Message + func (x *SlsLogPackageList) Reset() + func (x *SlsLogPackageList) String() string + type SourceConfig struct + LogstoreName string + type SqlType string + const SEARCH_QUERY + const STANDARD + type StaticCredentialsProvider struct + Cred Credentials + func NewStaticCredentialsProvider(accessKeyID, accessKeySecret, securityToken string) *StaticCredentialsProvider + func (p *StaticCredentialsProvider) GetCredentials() (Credentials, error) + type Status string + const DISABLED + const ENABLED + type StoreView struct + Name string + StoreType string + Stores []*StoreViewStore + type StoreViewErrors struct + LogStore string + Message string + ProjectName string + Status string + type StoreViewIndex struct + Index Index + LogStore string + ProjectName string + type StoreViewStore struct + Project string + Query string + StoreName string + type StreamLogConfigInputDetail struct + Tag string + func ConvertToStreamLogConfigInputDetail(detail InputDetailInterface) (*StreamLogConfigInputDetail, bool) + type StructureDataFormat struct + TimeField string + type SubStore struct + Keys []SubStoreKey + Name string + SortedKeyCount int + TTL int + TimeIndex int + func NewSubStore(name string, ttl int, sortedKeyCount int, timeIndex int, keys []SubStoreKey) *SubStore + func (s *SubStore) IsValid() bool + type SubStoreKey struct + Name string + Type string + func (s *SubStoreKey) IsValid() bool + type Tag struct + Key string + Value string + type TemplateConfiguration struct + Annotations map[string]string + Id string + Lang string + Tokens map[string]string + Type string + Version string + type Token struct + Default string + DisplayName string + Hide bool + Name string + Required bool + Type string + type TokenAutoUpdateClient struct + func (c *TokenAutoUpdateClient) ApplyConfigToMachineGroup(project string, confName, groupName string) (err error) + func (c *TokenAutoUpdateClient) CheckConfigExist(project string, config string) (ok bool, err error) + func (c *TokenAutoUpdateClient) CheckLogstoreExist(project string, logstore string) (ok bool, err error) + func (c *TokenAutoUpdateClient) CheckMachineGroupExist(project string, machineGroup string) (ok bool, err error) + func (c *TokenAutoUpdateClient) CheckProjectExist(name string) (ok bool, err error) + func (c *TokenAutoUpdateClient) Close() error + func (c *TokenAutoUpdateClient) CreateAlert(project string, alert *Alert) (err error) + func (c *TokenAutoUpdateClient) CreateAlertString(project string, alert string) (err error) + func (c *TokenAutoUpdateClient) CreateChart(project, dashboardName string, chart Chart) (err error) + func (c *TokenAutoUpdateClient) CreateConfig(project string, config *LogConfig) (err error) + func (c *TokenAutoUpdateClient) CreateConfigString(project string, config string) (err error) + func (c *TokenAutoUpdateClient) CreateConsumerGroup(project, logstore string, cg ConsumerGroup) (err error) + func (c *TokenAutoUpdateClient) CreateDashboard(project string, dashboard Dashboard) (err error) + func (c *TokenAutoUpdateClient) CreateDashboardString(project string, dashboardStr string) (err error) + func (c *TokenAutoUpdateClient) CreateETL(project string, etljob ETL) (err error) + func (c *TokenAutoUpdateClient) CreateEtlMeta(project string, etlMeta *EtlMeta) (err error) + func (c *TokenAutoUpdateClient) CreateEventStore(project string, eventStore *LogStore) (err error) + func (c *TokenAutoUpdateClient) CreateExport(project string, export *Export) (err error) + func (c *TokenAutoUpdateClient) CreateIndex(project, logstore string, index Index) (err error) + func (c *TokenAutoUpdateClient) CreateIndexString(project, logstore string, index string) (err error) + func (c *TokenAutoUpdateClient) CreateIngestion(project string, ingestion *Ingestion) (err error) + func (c *TokenAutoUpdateClient) CreateLogStore(project string, logstore string, ttl, shardCnt int, autoSplit bool, ...) (err error) + func (c *TokenAutoUpdateClient) CreateLogStoreV2(project string, logstore *LogStore) (err error) + func (c *TokenAutoUpdateClient) CreateMachineGroup(project string, m *MachineGroup) (err error) + func (c *TokenAutoUpdateClient) CreateMetricStore(project string, metricStore *LogStore) (err error) + func (c *TokenAutoUpdateClient) CreateProject(name, description string) (prj *LogProject, err error) + func (c *TokenAutoUpdateClient) CreateProjectV2(name, description, dataRedundancyType string) (prj *LogProject, err error) + func (c *TokenAutoUpdateClient) CreateResource(resource *Resource) (err error) + func (c *TokenAutoUpdateClient) CreateResourceRecord(resourceName string, record *ResourceRecord) (err error) + func (c *TokenAutoUpdateClient) CreateResourceRecordString(resourceName, recordStr string) (err error) + func (c *TokenAutoUpdateClient) CreateResourceString(resourceStr string) (err error) + func (c *TokenAutoUpdateClient) CreateSavedSearch(project string, savedSearch *SavedSearch) (err error) + func (c *TokenAutoUpdateClient) CreateScheduledSQL(project string, scheduledsql *ScheduledSQL) (err error) + func (c *TokenAutoUpdateClient) CreateStoreView(project string, storeView *StoreView) (err error) + func (c *TokenAutoUpdateClient) DeleteAlert(project string, alertName string) (err error) + func (c *TokenAutoUpdateClient) DeleteChart(project, dashboardName, chartName string) (err error) + func (c *TokenAutoUpdateClient) DeleteConfig(project string, config string) (err error) + func (c *TokenAutoUpdateClient) DeleteConsumerGroup(project, logstore string, cgName string) (err error) + func (c *TokenAutoUpdateClient) DeleteDashboard(project, name string) (err error) + func (c *TokenAutoUpdateClient) DeleteETL(project string, etlName string) (err error) + func (c *TokenAutoUpdateClient) DeleteEtlMeta(project string, etlMetaName, etlMetaKey string) (err error) + func (c *TokenAutoUpdateClient) DeleteEventStore(project, name string) (err error) + func (c *TokenAutoUpdateClient) DeleteExport(project string, name string) (err error) + func (c *TokenAutoUpdateClient) DeleteIndex(project, logstore string) (err error) + func (c *TokenAutoUpdateClient) DeleteIngestion(project string, name string) (err error) + func (c *TokenAutoUpdateClient) DeleteLogStore(project string, logstore string) (err error) + func (c *TokenAutoUpdateClient) DeleteMachineGroup(project string, machineGroup string) (err error) + func (c *TokenAutoUpdateClient) DeleteMetricStore(project, name string) (err error) + func (c *TokenAutoUpdateClient) DeleteProject(name string) (err error) + func (c *TokenAutoUpdateClient) DeleteProjectPolicy(project string) (err error) + func (c *TokenAutoUpdateClient) DeleteResource(name string) (err error) + func (c *TokenAutoUpdateClient) DeleteResourceRecord(resourceName, recordId string) (err error) + func (c *TokenAutoUpdateClient) DeleteSavedSearch(project string, savedSearchName string) (err error) + func (c *TokenAutoUpdateClient) DeleteScheduledSQL(project string, name string) (err error) + func (c *TokenAutoUpdateClient) DeleteStoreView(project string, storeViewName string) (err error) + func (c *TokenAutoUpdateClient) DisableAlert(project string, alertName string) (err error) + func (c *TokenAutoUpdateClient) EnableAlert(project string, alertName string) (err error) + func (c *TokenAutoUpdateClient) GetAlert(project string, alertName string) (alert *Alert, err error) + func (c *TokenAutoUpdateClient) GetAlertString(project string, alertName string) (alert string, err error) + func (c *TokenAutoUpdateClient) GetAppliedConfigs(project string, groupName string) (confNames []string, err error) + func (c *TokenAutoUpdateClient) GetAppliedMachineGroups(project string, confName string) (groupNames []string, err error) + func (c *TokenAutoUpdateClient) GetChart(project, dashboardName, chartName string) (chart *Chart, err error) + func (c *TokenAutoUpdateClient) GetCheckpoint(project, logstore string, cgName string) (checkPointList []*ConsumerGroupCheckPoint, err error) + func (c *TokenAutoUpdateClient) GetConfig(project string, config string) (logConfig *LogConfig, err error) + func (c *TokenAutoUpdateClient) GetConfigString(project string, config string) (logConfig string, err error) + func (c *TokenAutoUpdateClient) GetCursor(project, logstore string, shardID int, from string) (cursor string, err error) + func (c *TokenAutoUpdateClient) GetCursorTime(project, logstore string, shardID int, cursor string) (cursorTime time.Time, err error) + func (c *TokenAutoUpdateClient) GetDashboard(project, name string) (dashboard *Dashboard, err error) + func (c *TokenAutoUpdateClient) GetDashboardString(project, name string) (dashboard string, err error) + func (c *TokenAutoUpdateClient) GetETL(project string, etlName string) (ETLJob *ETL, err error) + func (c *TokenAutoUpdateClient) GetEtlMeta(project string, etlMetaName, etlMetaKey string) (etlMeta *EtlMeta, err error) + func (c *TokenAutoUpdateClient) GetEventStore(project, name string) (eventStore *LogStore, err error) + func (c *TokenAutoUpdateClient) GetExport(project, name string) (export *Export, err error) + func (c *TokenAutoUpdateClient) GetHistograms(project, logstore string, topic string, from int64, to int64, queryExp string) (h *GetHistogramsResponse, err error) + func (c *TokenAutoUpdateClient) GetHistogramsToCompleted(project, logstore string, topic string, from int64, to int64, queryExp string) (h *GetHistogramsResponse, err error) + func (c *TokenAutoUpdateClient) GetHistogramsToCompletedV2(project, logstore string, ghr *GetHistogramRequest) (h *GetHistogramsResponse, err error) + func (c *TokenAutoUpdateClient) GetHistogramsV2(project, logstore string, ghr *GetHistogramRequest) (h *GetHistogramsResponse, err error) + func (c *TokenAutoUpdateClient) GetIndex(project, logstore string) (index *Index, err error) + func (c *TokenAutoUpdateClient) GetIndexString(project, logstore string) (index string, err error) + func (c *TokenAutoUpdateClient) GetIngestion(project string, name string) (ingestion *Ingestion, err error) + func (c *TokenAutoUpdateClient) GetLogLines(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (r *GetLogLinesResponse, err error) + func (c *TokenAutoUpdateClient) GetLogLinesByNano(project, logstore string, topic string, fromInNs int64, toInNS int64, ...) (r *GetLogLinesResponse, err error) + func (c *TokenAutoUpdateClient) GetLogLinesV2(project, logstore string, req *GetLogRequest) (r *GetLogLinesResponse, err error) + func (c *TokenAutoUpdateClient) GetLogStore(project string, logstore string) (logstoreRst *LogStore, err error) + func (c *TokenAutoUpdateClient) GetLogStoreMeteringMode(project string, logstore string) (res *GetMeteringModeResponse, err error) + func (c *TokenAutoUpdateClient) GetLogs(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (r *GetLogsResponse, err error) + func (c *TokenAutoUpdateClient) GetLogsByNano(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (r *GetLogsResponse, err error) + func (c *TokenAutoUpdateClient) GetLogsBytes(project, logstore string, shardID int, cursor, endCursor string, ...) (out []byte, nextCursor string, err error) + func (c *TokenAutoUpdateClient) GetLogsBytesV2(plr *PullLogRequest) (out []byte, nextCursor string, err error) + func (c *TokenAutoUpdateClient) GetLogsBytesWithQuery(plr *PullLogRequest) (out []byte, plm *PullLogMeta, err error) + func (c *TokenAutoUpdateClient) GetLogsToCompleted(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (r *GetLogsResponse, err error) + func (c *TokenAutoUpdateClient) GetLogsToCompletedV2(project, logstore string, req *GetLogRequest) (r *GetLogsResponse, err error) + func (c *TokenAutoUpdateClient) GetLogsToCompletedV3(project, logstore string, req *GetLogRequest) (r *GetLogsV3Response, err error) + func (c *TokenAutoUpdateClient) GetLogsV2(project, logstore string, req *GetLogRequest) (r *GetLogsResponse, err error) + func (c *TokenAutoUpdateClient) GetLogsV3(project, logstore string, req *GetLogRequest) (r *GetLogsV3Response, err error) + func (c *TokenAutoUpdateClient) GetMachineGroup(project string, machineGroup string) (m *MachineGroup, err error) + func (c *TokenAutoUpdateClient) GetMetricStore(project, name string) (metricStore *LogStore, err error) + func (c *TokenAutoUpdateClient) GetProject(name string) (prj *LogProject, err error) + func (c *TokenAutoUpdateClient) GetProjectPolicy(project string) (policy string, err error) + func (c *TokenAutoUpdateClient) GetResource(name string) (resource *Resource, err error) + func (c *TokenAutoUpdateClient) GetResourceRecord(resourceName, recordId string) (record *ResourceRecord, err error) + func (c *TokenAutoUpdateClient) GetResourceRecordString(resourceName, name string) (record string, err error) + func (c *TokenAutoUpdateClient) GetResourceString(name string) (resource string, err error) + func (c *TokenAutoUpdateClient) GetSavedSearch(project string, savedSearchName string) (savedSearch *SavedSearch, err error) + func (c *TokenAutoUpdateClient) GetScheduledSQL(project string, name string) (s *ScheduledSQL, err error) + func (c *TokenAutoUpdateClient) GetScheduledSQLJobInstance(projectName, jobName, instanceId string, result bool) (instance *ScheduledSQLJobInstance, err error) + func (c *TokenAutoUpdateClient) GetStoreView(project string, storeViewName string) (storeView *StoreView, err error) + func (c *TokenAutoUpdateClient) GetStoreViewIndex(project string, storeViewName string) (resp *GetStoreViewIndexResponse, err error) + func (c *TokenAutoUpdateClient) HeartBeat(project, logstore string, cgName, consumer string, heartBeatShardIDs []int) (shardIDs []int, err error) + func (c *TokenAutoUpdateClient) ListAlert(project string, alertName string, dashboard string, offset, size int) (alerts []*Alert, total int, count int, err error) + func (c *TokenAutoUpdateClient) ListConfig(project string, offset, size int) (cfgNames []string, total int, err error) + func (c *TokenAutoUpdateClient) ListConsumerGroup(project, logstore string) (cgList []*ConsumerGroup, err error) + func (c *TokenAutoUpdateClient) ListDashboard(project string, dashboardName string, offset, size int) (dashboardList []string, count, total int, err error) + func (c *TokenAutoUpdateClient) ListDashboardV2(project string, dashboardName string, offset, size int) (dashboardList []string, dashboardItems []ResponseDashboardItem, ...) + func (c *TokenAutoUpdateClient) ListETL(project string, offset int, size int) (ETLResponse *ListETLResponse, err error) + func (c *TokenAutoUpdateClient) ListEtlMeta(project string, etlMetaName string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + func (c *TokenAutoUpdateClient) ListEtlMetaName(project string, offset, size int) (total int, count int, etlMetaNameList []string, err error) + func (c *TokenAutoUpdateClient) ListEtlMetaWithTag(project string, etlMetaName, etlMetaTag string, offset, size int) (total int, count int, etlMetaList []*EtlMeta, err error) + func (c *TokenAutoUpdateClient) ListEventStore(project string, offset, size int) (eventStores []string, err error) + func (c *TokenAutoUpdateClient) ListExport(project, logstore, name, displayName string, offset, size int) (exports []*Export, total, count int, err error) + func (c *TokenAutoUpdateClient) ListIngestion(project, logstore, name, displayName string, offset, size int) (ingestions []*Ingestion, total, count int, err error) + func (c *TokenAutoUpdateClient) ListLogStore(project string) (logstoreList []string, err error) + func (c *TokenAutoUpdateClient) ListLogStoreV2(project string, offset, size int, telemetryType string) (logstoreList []string, err error) + func (c *TokenAutoUpdateClient) ListMachineGroup(project string, offset, size int) (m []string, total int, err error) + func (c *TokenAutoUpdateClient) ListMachines(project, machineGroupName string) (ms []*Machine, total int, err error) + func (c *TokenAutoUpdateClient) ListMachinesV2(project, machineGroupName string, offset, size int) (ms []*Machine, total int, err error) + func (c *TokenAutoUpdateClient) ListProject() (projectNames []string, err error) + func (c *TokenAutoUpdateClient) ListProjectV2(offset, size int) (projects []LogProject, count, total int, err error) + func (c *TokenAutoUpdateClient) ListResource(resourceType string, resourceName string, offset, size int) (resourceList []*Resource, count, total int, err error) + func (c *TokenAutoUpdateClient) ListResourceRecord(resourceName string, offset, size int) (recordList []*ResourceRecord, count, total int, err error) + func (c *TokenAutoUpdateClient) ListSavedSearch(project string, savedSearchName string, offset, size int) (savedSearches []string, total int, count int, err error) + func (c *TokenAutoUpdateClient) ListSavedSearchV2(project string, savedSearchName string, offset, size int) (savedSearches []string, savedsearchItems []ResponseSavedSearchItem, total int, ...) + func (c *TokenAutoUpdateClient) ListScheduledSQL(project, name, displayName string, offset, size int) (scheduledsqls []*ScheduledSQL, total, count int, err error) + func (c *TokenAutoUpdateClient) ListScheduledSQLJobInstances(projectName, jobName string, status *InstanceStatus) (instances []*ScheduledSQLJobInstance, total, count int64, err error) + func (c *TokenAutoUpdateClient) ListShards(project, logstore string) (shardIDs []*Shard, err error) + func (c *TokenAutoUpdateClient) ListStoreViews(project string, req *ListStoreViewsRequest) (resp *ListStoreViewsResponse, err error) + func (c *TokenAutoUpdateClient) ListSystemTagResources(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error) + func (c *TokenAutoUpdateClient) ListTagResources(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error) + func (c *TokenAutoUpdateClient) MergeShards(project, logstore string, shardID int) (shards []*Shard, err error) + func (c *TokenAutoUpdateClient) ModifyScheduledSQLJobInstanceState(projectName, jobName, instanceId string, state ScheduledSQLState) (err error) + func (c *TokenAutoUpdateClient) PostLogStoreLogs(project, logstore string, lg *LogGroup, hashKey *string) (err error) + func (c *TokenAutoUpdateClient) PostLogStoreLogsV2(project, logstore string, req *PostLogStoreLogsRequest) (err error) + func (c *TokenAutoUpdateClient) PostRawLogWithCompressType(project, logstore string, rawLogData []byte, compressType int, hashKey *string) (err error) + func (c *TokenAutoUpdateClient) PublishAlertEvent(project string, alertResult []byte) error + func (c *TokenAutoUpdateClient) PullLogs(project, logstore string, shardID int, cursor, endCursor string, ...) (gl *LogGroupList, nextCursor string, err error) + func (c *TokenAutoUpdateClient) PullLogsV2(plr *PullLogRequest) (gl *LogGroupList, nextCursor string, err error) + func (c *TokenAutoUpdateClient) PullLogsWithQuery(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error) + func (c *TokenAutoUpdateClient) PutLogs(project, logstore string, lg *LogGroup) (err error) + func (c *TokenAutoUpdateClient) PutLogsWithCompressType(project, logstore string, lg *LogGroup, compressType int) (err error) + func (c *TokenAutoUpdateClient) PutLogsWithMetricStoreURL(project, logstore string, lg *LogGroup) (err error) + func (c *TokenAutoUpdateClient) PutRawLogWithCompressType(project, logstore string, rawLogData []byte, compressType int) (err error) + func (c *TokenAutoUpdateClient) RemoveConfigFromMachineGroup(project string, confName, groupName string) (err error) + func (c *TokenAutoUpdateClient) ResetAccessKeyToken(accessKeyID, accessKeySecret, securityToken string) + func (c *TokenAutoUpdateClient) RestartETL(project string, etljob ETL) (err error) + func (c *TokenAutoUpdateClient) RestartExport(project string, export *Export) (err error) + func (c *TokenAutoUpdateClient) SetAuthVersion(version AuthVersionType) + func (c *TokenAutoUpdateClient) SetHTTPClient(client *http.Client) + func (c *TokenAutoUpdateClient) SetRegion(region string) + func (c *TokenAutoUpdateClient) SetRetryTimeout(timeout time.Duration) + func (c *TokenAutoUpdateClient) SetUserAgent(userAgent string) + func (c *TokenAutoUpdateClient) SplitNumShard(project, logstore string, shardID, shardNum int) (shards []*Shard, err error) + func (c *TokenAutoUpdateClient) SplitShard(project, logstore string, shardID int, splitKey string) (shards []*Shard, err error) + func (c *TokenAutoUpdateClient) StartETL(project string, name string) (err error) + func (c *TokenAutoUpdateClient) StopETL(project string, name string) (err error) + func (c *TokenAutoUpdateClient) TagResources(project string, tags *ResourceTags) (err error) + func (c *TokenAutoUpdateClient) TagResourcesSystemTags(project string, tags *ResourceSystemTags) (err error) + func (c *TokenAutoUpdateClient) UnTagResources(project string, tags *ResourceUnTags) (err error) + func (c *TokenAutoUpdateClient) UnTagResourcesSystemTags(project string, tags *ResourceUnSystemTags) (err error) + func (c *TokenAutoUpdateClient) UpdateAlert(project string, alert *Alert) (err error) + func (c *TokenAutoUpdateClient) UpdateAlertString(project string, alertName, alert string) (err error) + func (c *TokenAutoUpdateClient) UpdateChart(project, dashboardName string, chart Chart) (err error) + func (c *TokenAutoUpdateClient) UpdateCheckpoint(project, logstore string, cgName string, consumer string, shardID int, ...) (err error) + func (c *TokenAutoUpdateClient) UpdateConfig(project string, config *LogConfig) (err error) + func (c *TokenAutoUpdateClient) UpdateConfigString(project string, configName, configDetail string) (err error) + func (c *TokenAutoUpdateClient) UpdateConsumerGroup(project, logstore string, cg ConsumerGroup) (err error) + func (c *TokenAutoUpdateClient) UpdateDashboard(project string, dashboard Dashboard) (err error) + func (c *TokenAutoUpdateClient) UpdateDashboardString(project string, dashboardName, dashboardStr string) (err error) + func (c *TokenAutoUpdateClient) UpdateETL(project string, etljob ETL) (err error) + func (c *TokenAutoUpdateClient) UpdateEtlMeta(project string, etlMeta *EtlMeta) (err error) + func (c *TokenAutoUpdateClient) UpdateEventStore(project string, eventStore *LogStore) (err error) + func (c *TokenAutoUpdateClient) UpdateExport(project string, export *Export) (err error) + func (c *TokenAutoUpdateClient) UpdateIndex(project, logstore string, index Index) (err error) + func (c *TokenAutoUpdateClient) UpdateIndexString(project, logstore string, index string) (err error) + func (c *TokenAutoUpdateClient) UpdateIngestion(project string, ingestion *Ingestion) (err error) + func (c *TokenAutoUpdateClient) UpdateLogStore(project string, logstore string, ttl, shardCnt int) (err error) + func (c *TokenAutoUpdateClient) UpdateLogStoreMeteringMode(project string, logstore string, meteringMode string) (err error) + func (c *TokenAutoUpdateClient) UpdateLogStoreV2(project string, logstore *LogStore) (err error) + func (c *TokenAutoUpdateClient) UpdateMachineGroup(project string, m *MachineGroup) (err error) + func (c *TokenAutoUpdateClient) UpdateMetricStore(project string, metricStore *LogStore) (err error) + func (c *TokenAutoUpdateClient) UpdateProject(name, description string) (prj *LogProject, err error) + func (c *TokenAutoUpdateClient) UpdateProjectPolicy(project, policy string) (err error) + func (c *TokenAutoUpdateClient) UpdateResource(resource *Resource) (err error) + func (c *TokenAutoUpdateClient) UpdateResourceRecord(resourceName string, record *ResourceRecord) (err error) + func (c *TokenAutoUpdateClient) UpdateResourceRecordString(resourceName, recordStr string) (err error) + func (c *TokenAutoUpdateClient) UpdateResourceString(resourceName, resourceStr string) (err error) + func (c *TokenAutoUpdateClient) UpdateSavedSearch(project string, savedSearch *SavedSearch) (err error) + func (c *TokenAutoUpdateClient) UpdateScheduledSQL(project string, scheduledsql *ScheduledSQL) (err error) + func (c *TokenAutoUpdateClient) UpdateStoreView(project string, storeView *StoreView) (err error) + type TriggerConfig struct + MaxRetryTime int + RoleARN string + StartingPosition string + StartingUnixtime int64 + TriggerInterval int + type UpdateFuncProviderAdapter struct + func NewUpdateFuncProviderAdapter(updateFunc UpdateTokenFunction) *UpdateFuncProviderAdapter + func (adp *UpdateFuncProviderAdapter) GetCredentials() (Credentials, error) + type UpdateTokenFunction = util.UpdateTokenFunction + type WebhookIntegration struct + Headers []*ResourceWebhookHeader + Id string + Method string + Name string + Secret string + Type string + Url string + type ZstdCompressor struct + func NewZstdCompressor(level zstd.EncoderLevel) *ZstdCompressor + func (c *ZstdCompressor) Compress(src, dst []byte) ([]byte, error) + func (c *ZstdCompressor) Decompress(src, dst []byte) ([]byte, error)
Go to main page