sls

package module

Go to main page

Versions in this module

v0

v0.1.25

Jun 4, 2021

Changes in this version

+ var FunctionGetCurrentTime func() time.Time

v0.1.24

Jun 4, 2021

Changes in this version

type Client

+ FunctionGetCurrentTime func() time.Time

v0.1.23

Jun 4, 2021

Changes in this version

+ const ETLSinksType

+ const ETLType

+ const ETLVersion

+ const GetLogsQueryInfo

+ const HasSQLHeader

+ const LoggingURI

+ const MetricAggRulesPromQL

+ const MetricAggRulesSQL

+ const ScheduleTypeCron

+ const ScheduleTypeDaily

+ const ScheduleTypeDayRun

+ const ScheduleTypeFixedRate

+ const ScheduleTypeHourly

+ const ScheduleTypeResident

+ const ScheduleTypeWeekly

+ var GlobalDebugLevel = 0

+ var Logger = initDefaultSLSLogger()

+ var RetryOnServerErrorEnabled = true

+ func GenerateInnerLogger(logFileName, isJsonType, logMaxSize, logFileBackupCount, allowLogLevel string) log.Logger

+ func IsDebugLevelMatched(level int) bool

type Alert

+ Status string

type Client

+ RequestTimeOut time.Duration

+ RetryTimeOut time.Duration

+ func (c *Client) CreateAlertString(project string, alert string) error

+ func (c *Client) CreateETL(project string, etljob ETL) error

+ func (c *Client) CreateLogging(project string, detail *Logging) error

+ func (c *Client) CreateMetricAggRules(project string, aggRules *MetricAggRules) error

+ func (c *Client) CreateSubStore(project, logstore string, sss *SubStore) (err error)

+ func (c *Client) DeleteETL(project string, etlName string) error

+ func (c *Client) DeleteLogging(project string) error

+ func (c *Client) DeleteMetricAggRules(project string, ruleID string) error

+ func (c *Client) DeleteSubStore(project, logstore string, name string) (err error)

+ func (c *Client) GetAlertString(project string, alertName string) (string, error)

+ func (c *Client) GetETL(project string, etlName string) (ETLJob *ETL, err error)

+ func (c *Client) GetLogLines(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogLinesResponse, error)

+ func (c *Client) GetLogging(project string) (*Logging, error)

+ func (c *Client) GetMetricAggRules(project string, ruleID string) (*MetricAggRules, 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) 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) ListLogStoreV2(project string, offset, size int, telemetryType string) ([]string, error)

+ func (c *Client) ListMetricAggRules(project string, offset int, size int) ([]*MetricAggRules, error)

+ func (c *Client) ListSavedSearchV2(project string, savedSearchName string, offset, size int) (savedSearches []string, savedsearchItems []ResponseSavedSearchItem, total int, ...)

+ func (c *Client) ListSubStore(project, logstore string) (sortedSubStores []string, err error)

+ func (c *Client) ListTagResources(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, 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) UnTagResources(project string, tags *ResourceUnTags) error

+ func (c *Client) UpdateAlertString(project string, alertName, alert string) error

+ func (c *Client) UpdateETL(project string, etljob ETL) error

+ func (c *Client) UpdateLogging(project string, detail *Logging) error

+ func (c *Client) UpdateMetricAggRules(project string, aggRules *MetricAggRules) error

+ func (c *Client) UpdateSubStore(project, logstore string, sss *SubStore) (err error)

+ func (c *Client) UpdateSubStoreTTL(project, logstore string, ttl int) (err error)

type ClientInterface

+ CreateAlertString func(project string, alert string) error

+ CreateConsumerGroup func(project, logstore string, cg ConsumerGroup) (err error)

+ DeleteConsumerGroup func(project, logstore string, cgName string) (err error)

+ GetAlertString func(project string, alertName string) (string, error)

+ GetCheckpoint func(project, logstore string, cgName string) (checkPointList []*ConsumerGroupCheckPoint, err error)

+ GetCursorTime func(project, logstore string, shardID int, cursor string) (cursorTime time.Time, err error)

+ GetLogLines func(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogLinesResponse, error)

+ HeartBeat func(project, logstore string, cgName, consumer string, heartBeatShardIDs []int) (shardIDs []int, err error)

+ ListConsumerGroup func(project, logstore string) (cgList []*ConsumerGroup, err error)

+ ListDashboardV2 func(project string, dashboardName string, offset, size int) (dashboardList []string, dashboardItems []ResponseDashboardItem, ...)

+ ListSavedSearchV2 func(project string, savedSearchName string, offset, size int) (savedSearches []string, savedsearchItems []ResponseSavedSearchItem, total int, ...)

+ ListTagResources func(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error)

+ TagResources func(project string, tags *ResourceTags) error

+ UnTagResources func(project string, tags *ResourceUnTags) error

+ UpdateAlertString func(project string, alertName, alert string) error

+ UpdateCheckpoint func(project, logstore string, cgName string, consumer string, shardID int, ...) (err error)

+ UpdateConsumerGroup func(project, logstore string, cg ConsumerGroup) (err error)

+ UpdateProject func(name, description string) (*LogProject, error)

+ 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 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 GetContextLogsResponse struct

+ BackLines int64

+ ForwardLines int64

+ Logs []map[string]string

+ Progress string

+ TotalLines int64

+ func (resp *GetContextLogsResponse) IsComplete() bool

+ type GetLogLinesResponse struct

+ Lines []json.RawMessage

type GetLogsResponse

+ Contents string

+ HasSQL bool

+ func (resp *GetLogsResponse) GetKeys() (error, []string)

type IndexKey

+ JsonKeys map[string]*JsonKey

+ type JsonKey struct

+ Alias string

+ DocValue bool

+ Type string

+ type ListETLResponse struct

+ Count int

+ Results []*ETL

+ Total int

type LogProject

+ func (p *LogProject) CreateLogging(detail *Logging) (err error)

+ func (p *LogProject) DeleteLogging() (err error)

+ func (p *LogProject) GetLogging() (c *Logging, err error)

+ func (p *LogProject) ListLogStoreV2(offset, size int, telemetryType string) ([]string, error)

+ func (p *LogProject) RawRequest(method, uri string, headers map[string]string, body []byte) (*http.Response, error)

+ func (p *LogProject) UpdateLogging(detail *Logging) (err error)

type LogStore

+ ArchiveSecons int

+ EncryptConf *EncryptConf

+ TelemetryType string

+ func (s *LogStore) GetContextLogs(backLines int32, forwardLines int32, packID string, packMeta string) (*GetContextLogsResponse, error)

+ func (s *LogStore) GetLogLines(topic string, from int64, to int64, queryExp string, maxLineNum int64, ...) (*GetLogLinesResponse, error)

+ func (s *LogStore) ListShipper() ([]string, error)

+ type Logging struct

+ LoggingDetails []*LoggingDetail

+ Project string

+ type LoggingDetail struct

+ Logstore string

+ Type string

type Machine

+ LastHeartBeatTime int

+ 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 Notification

+ Headers map[string]string

type OSSShipperConfig

+ Storage ShipperStorage

+ 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 ParquetConfig struct

+ Name string

+ Type string

+ type ResourceFilterTag struct

+ Key *string

+ Value *string

+ 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

+ type ResourceUnTags struct

+ ResourceID []string

+ ResourceType string

+ Tags []string

+ func NewProjectUnTags(project string, tags []string) *ResourceUnTags

+ type ResponseDashboardItem struct

+ DashboardName string

+ DisplayName string

+ type ResponseSavedSearchItem struct

+ DisplayName string

+ SavedSearchName string

type Schedule

+ CronExpression string

+ DayOfWeek int32

+ Delay int32

+ Hour int32

+ type ShipperStorage struct

+ Detail interface{}

+ Format 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 TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) CreateAlertString(project string, alert string) (err error)

+ func (c *TokenAutoUpdateClient) CreateConsumerGroup(project, logstore string, cg ConsumerGroup) (err error)

+ func (c *TokenAutoUpdateClient) DeleteConsumerGroup(project, logstore string, cgName string) (err error)

+ func (c *TokenAutoUpdateClient) GetAlertString(project string, alertName string) (alert string, err error)

+ func (c *TokenAutoUpdateClient) GetCheckpoint(project, logstore string, cgName string) (checkPointList []*ConsumerGroupCheckPoint, err error)

+ func (c *TokenAutoUpdateClient) GetCursorTime(project, logstore string, shardID int, cursor string) (cursorTime time.Time, err error)

+ func (c *TokenAutoUpdateClient) GetLogLines(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (r *GetLogLinesResponse, err error)

+ func (c *TokenAutoUpdateClient) HeartBeat(project, logstore string, cgName, consumer string, heartBeatShardIDs []int) (shardIDs []int, err error)

+ func (c *TokenAutoUpdateClient) ListConsumerGroup(project, logstore string) (cgList []*ConsumerGroup, err error)

+ func (c *TokenAutoUpdateClient) ListDashboardV2(project string, dashboardName string, offset, size int) (dashboardList []string, dashboardItems []ResponseDashboardItem, ...)

+ func (c *TokenAutoUpdateClient) ListSavedSearchV2(project string, savedSearchName string, offset, size int) (savedSearches []string, savedsearchItems []ResponseSavedSearchItem, total int, ...)

+ func (c *TokenAutoUpdateClient) ListTagResources(project string, resourceType string, resourceIDs []string, ...) (respTags []*ResourceTagResponse, respNextToken string, err error)

+ func (c *TokenAutoUpdateClient) TagResources(project string, tags *ResourceTags) (err error)

+ func (c *TokenAutoUpdateClient) UnTagResources(project string, tags *ResourceUnTags) (err error)

+ func (c *TokenAutoUpdateClient) UpdateAlertString(project string, alertName, alert string) (err error)

+ func (c *TokenAutoUpdateClient) UpdateCheckpoint(project, logstore string, cgName string, consumer string, shardID int, ...) (err error)

+ func (c *TokenAutoUpdateClient) UpdateConsumerGroup(project, logstore string, cg ConsumerGroup) (err error)

+ func (c *TokenAutoUpdateClient) UpdateProject(name, description string) (prj *LogProject, err error)

v0.1.4

Jul 23, 2019

Changes in this version

+ const BAD_REQUEST

+ const CONFIG_ALREADY_EXIST

+ const CONFIG_NOT_EXIST

+ const Compress_LZ4

+ const Compress_Max

+ const Compress_None

+ const EtlMetaAllTagMatch

+ const EtlMetaNameURI

+ const EtlMetaURI

+ const GROUP_ALREADY_EXIST

+ const GROUP_NOT_EXIST

+ const GetLogsCountHeader

+ 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 InputTypeFile

+ const InputTypePlugin

+ const InputTypeStreamlog

+ const InputTypeSyslog

+ 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 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 NotificationTypeDingTalk

+ const NotificationTypeEmail

+ const NotificationTypeMessageCenter

+ const NotificationTypeSMS

+ const NotificationTypeWebhook

+ 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_FORBIDDEN

+ const PROJECT_NOT_EXIST

+ const PROJECT_QUOTA_EXCEED

+ const PluginInputTypeDockerStdout

+ const ProgressHeader

+ const READ_QUOTA_EXCEED

+ const REQUEST_TIME_TOO_SKEWED

+ const RequestIDHeader

+ 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 TopicFormatMachineGroup

+ const TopicFormatNone

+ const UN_AUTHORIZED

+ const WRITE_QUOTA_EXCEED

+ var ErrIntOverflowLog = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthLog = fmt.Errorf("proto: negative length found during unmarshaling")

+ var GlobalForceUsingHTTP = false

+ var InvalidCompressError = errors.New("Invalid Compress Type")

+ var InvalidTypeError = errors.New("invalid config type")

+ var NoConfigFieldError = errors.New("no this config field")

+ 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 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 IsTokenError(err error) bool

+ func IsValidInputType(inputType string) bool

+ 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 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

+ func (alert *Alert) MarshalJSON() ([]byte, error)

+ type AlertConfiguration struct

+ Condition string

+ Dashboard string

+ MuteUntil int64

+ NotificationList []*Notification

+ NotifyThreshold int32

+ QueryList []*AlertQuery

+ Throttling string

+ type AlertQuery struct

+ ChartTitle string

+ End string

+ LogStore string

+ Query string

+ Start string

+ TimeSpanType string

+ type ApsaraLogConfigInputDetail struct

+ LogBeginRegex string

+ func ConvertToApsaraLogConfigInputDetail(detail InputDetailInterface) (*ApsaraLogConfigInputDetail, bool)

+ 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 Chart struct

+ Display ChartDisplay

+ Search ChartSearch

+ Title string

+ Type string

+ type ChartDisplay struct

+ DisplayName string

+ Height int

+ Width int

+ XAxisKeys []string

+ XPosition int

+ YAxisKeys []string

+ YPosition int

+ type ChartSearch struct

+ End string

+ Logstore string

+ Query string

+ Start string

+ Topic string

+ type Client struct

+ AccessKeyID string

+ AccessKeySecret string

+ Endpoint string

+ 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) 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) CreateEtlMeta(project string, etlMeta *EtlMeta) (err error)

+ func (c *Client) CreateIndex(project, logstore string, index Index) error

+ func (c *Client) CreateIndexString(project, logstore string, index string) 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) CreateMachineGroup(project string, m *MachineGroup) error

+ func (c *Client) CreateProject(name, description string) (*LogProject, error)

+ func (c *Client) CreateSavedSearch(project string, savedSearch *SavedSearch) 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) DeleteEtlMeta(project string, etlMetaName, etlMetaKey string) (err error)

+ func (c *Client) DeleteIndex(project, logstore string) error

+ func (c *Client) DeleteLogStore(project string, logstore string) (err error)

+ func (c *Client) DeleteMachineGroup(project string, machineGroup string) (err error)

+ func (c *Client) DeleteProject(name string) error

+ func (c *Client) DeleteSavedSearch(project string, savedSearchName string) 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) 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) GetEtlMeta(project string, etlMetaName, etlMetaKey string) (etlMeta *EtlMeta, err error)

+ func (c *Client) GetHistograms(project, logstore string, topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error)

+ func (c *Client) GetIndex(project, logstore string) (*Index, error)

+ func (c *Client) GetIndexString(project, logstore string) (string, error)

+ func (c *Client) GetLogStore(project string, logstore string) (*LogStore, error)

+ func (c *Client) GetLogs(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogsResponse, error)

+ func (c *Client) GetLogsBytes(project, logstore string, shardID int, cursor, endCursor string, ...) (out []byte, nextCursor string, err error)

+ func (c *Client) GetMachineGroup(project string, machineGroup string) (m *MachineGroup, err 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) GetSavedSearch(project string, savedSearchName string) (*SavedSearch, 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) 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) ListLogStore(project 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) ListProject() (projectNames []string, err error)

+ func (c *Client) ListProjectV2(offset, size int) (projects []LogProject, 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) ListShards(project, logstore string) (shardIDs []*Shard, err error)

+ func (c *Client) MergeShards(project, logstore string, shardID int) (shards []*Shard, err error)

+ func (c *Client) PostLogStoreLogs(project, logstore string, lg *LogGroup, hashKey *string) (err error)

+ func (c *Client) PullLogs(project, logstore string, shardID int, cursor, endCursor string, ...) (gl *LogGroupList, nextCursor string, 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) 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) SplitShard(project, logstore string, shardID int, splitKey string) (shards []*Shard, err error)

+ func (c *Client) UpdateAlert(project string, alert *Alert) 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) UpdateEtlMeta(project string, etlMeta *EtlMeta) (err error)

+ func (c *Client) UpdateIndex(project, logstore string, index Index) error

+ func (c *Client) UpdateIndexString(project, logstore string, index string) error

+ func (c *Client) UpdateLogStore(project string, logstore string, ttl, shardCnt int) (err error)

+ func (c *Client) UpdateLogStoreV2(project string, logstore *LogStore) (err error)

+ func (c *Client) UpdateMachineGroup(project string, m *MachineGroup) (err error)

+ func (c *Client) UpdateProject(name, description string) (*LogProject, error)

+ func (c *Client) UpdateSavedSearch(project string, savedSearch *SavedSearch) error

+ 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

+ CreateChart func(project, dashboardName string, chart Chart) error

+ CreateConfig func(project string, config *LogConfig) (err error)

+ CreateConfigString func(project string, config string) (err error)

+ CreateDashboard func(project string, dashboard Dashboard) error

+ CreateDashboardString func(project string, dashboardStr string) error

+ CreateEtlMeta func(project string, etlMeta *EtlMeta) (err error)

+ CreateIndex func(project, logstore string, index Index) error

+ CreateIndexString func(project, logstore string, indexStr string) 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

+ CreateProject func(name, description string) (*LogProject, error)

+ CreateSavedSearch func(project string, savedSearch *SavedSearch) error

+ DeleteAlert func(project string, alertName string) error

+ DeleteChart func(project, dashboardName, chartName string) error

+ DeleteConfig func(project string, config string) (err error)

+ DeleteDashboard func(project, name string) error

+ DeleteEtlMeta func(project string, etlMetaName, etlMetaKey string) (err error)

+ DeleteIndex func(project, logstore string) error

+ DeleteLogStore func(project string, logstore string) (err error)

+ DeleteMachineGroup func(project string, machineGroup string) (err error)

+ DeleteProject func(name string) error

+ DeleteSavedSearch func(project string, savedSearchName string) error

+ DisableAlert func(project string, alertName string) error

+ EnableAlert func(project string, alertName string) error

+ GetAlert func(project string, alertName string) (*Alert, 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)

+ 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)

+ GetDashboard func(project, name string) (dashboard *Dashboard, err error)

+ GetDashboardString func(project, name string) (dashboard string, err error)

+ GetEtlMeta func(project string, etlMetaName, etlMetaKey string) (etlMeta *EtlMeta, err error)

+ GetHistograms func(project, logstore string, topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error)

+ GetIndex func(project, logstore string) (*Index, error)

+ GetIndexString func(project, logstore string) (string, error)

+ GetLogStore func(project string, logstore string) (*LogStore, error)

+ GetLogs func(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (*GetLogsResponse, error)

+ GetLogsBytes func(project, logstore string, shardID int, cursor, endCursor string, ...) (out []byte, nextCursor string, err error)

+ GetMachineGroup func(project string, machineGroup string) (m *MachineGroup, err error)

+ GetProject func(name string) (*LogProject, error)

+ GetSavedSearch func(project string, savedSearchName string) (*SavedSearch, 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)

+ ListDashboard func(project string, dashboardName string, offset, size int) (dashboardList []string, count, total int, err 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)

+ ListLogStore func(project 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)

+ ListProject func() (projectNames []string, err error)

+ ListProjectV2 func(offset, size int) (projects []LogProject, count, total int, err error)

+ ListSavedSearch func(project string, savedSearchName string, offset, size int) (savedSearches []string, total int, count int, err error)

+ ListShards func(project, logstore string) (shards []*Shard, err error)

+ MergeShards func(project, logstore string, shardID int) (shards []*Shard, err error)

+ PostLogStoreLogs func(project, logstore string, lg *LogGroup, hashKey *string) (err error)

+ PullLogs func(project, logstore string, shardID int, cursor, endCursor string, ...) (gl *LogGroupList, nextCursor string, err error)

+ PutLogs func(project, logstore string, lg *LogGroup) (err error)

+ PutLogsWithCompressType func(project, logstore string, lg *LogGroup, compressType int) (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)

+ SplitShard func(project, logstore string, shardID int, splitKey string) (shards []*Shard, err error)

+ UpdateAlert func(project string, alert *Alert) error

+ UpdateChart func(project, dashboardName string, chart Chart) error

+ UpdateConfig func(project string, config *LogConfig) (err error)

+ UpdateConfigString func(project string, configName, configDetail string) (err error)

+ UpdateDashboard func(project string, dashboard Dashboard) error

+ UpdateDashboardString func(project string, dashboardName, dashboardStr string) error

+ UpdateEtlMeta func(project string, etlMeta *EtlMeta) (err error)

+ UpdateIndex func(project, logstore string, index Index) error

+ UpdateIndexString func(project, logstore string, indexStr string) error

+ UpdateLogStore func(project string, logstore string, ttl, shardCnt int) (err error)

+ UpdateLogStoreV2 func(project string, logstore *LogStore) error

+ UpdateMachineGroup func(project string, m *MachineGroup) (err error)

+ UpdateSavedSearch func(project string, savedSearch *SavedSearch) error

+ func CreateNormalInterface(endpoint, accessKeyID, accessKeySecret, securityToken string) ClientInterface

+ func CreateTokenAutoUpdateClient(endpoint string, tokenUpdateFunc UpdateTokenFunction, shutdown <-chan struct{}) (client ClientInterface, err error)

+ 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 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

+ type ConsumerGroupCheckPoint struct

+ CheckPoint string

+ Consumer string

+ ShardID int

+ UpdateTime int

+ type Dashboard struct

+ ChartList []Chart

+ DashboardName string

+ Description string

+ DisplayName string

+ type DelimiterConfigInputDetail struct

+ AutoExtend bool

+ Key []string

+ Quote string

+ Separator string

+ TimeKey string

+ func ConvertToDelimiterConfigInputDetail(detail InputDetailInterface) (*DelimiterConfigInputDetail, bool)

+ 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 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 FunctionConfig struct

+ AccountID string

+ Endpoint string

+ FunctionName string

+ FunctionProvider string

+ RegionName string

+ ServiceName string

+ type GetHistogramsResponse struct

+ Count int64

+ Histograms []SingleHistogram

+ Progress string

+ func (resp *GetHistogramsResponse) IsComplete() bool

+ type GetLogsResponse struct

+ Count int64

+ Logs []map[string]string

+ Progress string

+ func (resp *GetLogsResponse) IsComplete() bool

+ type Index struct

+ Keys map[string]IndexKey

+ Line *IndexLine

+ func CreateDefaultIndex() *Index

+ type IndexKey struct

+ Alias string

+ CaseSensitive bool

+ Chn bool

+ DocValue bool

+ Token []string

+ Type string

+ type IndexLine struct

+ CaseSensitive bool

+ Chn bool

+ ExcludeKeys []string

+ IncludeKeys []string

+ Token []string

+ 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 JSONConfigInputDetail struct

+ TimeKey string

+ func ConvertToJSONConfigInputDetail(detail InputDetailInterface) (*JSONConfigInputDetail, bool)

+ type JobLogConfig struct

+ Endpoint string

+ LogstoreName string

+ ProjectName string

+ type LocalFileConfigInputDetail struct

+ 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

+ Preserve bool

+ PreserveDepth int

+ TailExisted bool

+ TimeFormat string

+ TopicFormat string

+ type Log struct

+ Contents []*LogContent

+ Time *uint32

+ XXX_unrecognized []byte

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

+ func (m *Log) GetContents() []*LogContent

+ func (m *Log) GetTime() uint32

+ func (m *Log) Marshal() (dAtA []byte, err error)

+ func (m *Log) MarshalTo(dAtA []byte) (int, error)

+ func (m *Log) Reset()

+ func (m *Log) Size() (n int)

+ func (m *Log) String() string

+ func (m *Log) Unmarshal(dAtA []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

+ XXX_unrecognized []byte

+ func (*LogContent) Descriptor() ([]byte, []int)

+ func (*LogContent) ProtoMessage()

+ func (m *LogContent) GetKey() string

+ func (m *LogContent) GetValue() string

+ func (m *LogContent) Marshal() (dAtA []byte, err error)

+ func (m *LogContent) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogContent) Reset()

+ func (m *LogContent) Size() (n int)

+ func (m *LogContent) String() string

+ func (m *LogContent) Unmarshal(dAtA []byte) error

+ type LogGroup struct

+ Category *string

+ LogTags []*LogTag

+ Logs []*Log

+ MachineUUID *string

+ Source *string

+ Topic *string

+ XXX_unrecognized []byte

+ func (*LogGroup) Descriptor() ([]byte, []int)

+ func (*LogGroup) ProtoMessage()

+ func (m *LogGroup) GetCategory() string

+ func (m *LogGroup) GetLogTags() []*LogTag

+ func (m *LogGroup) GetLogs() []*Log

+ func (m *LogGroup) GetMachineUUID() string

+ func (m *LogGroup) GetSource() string

+ func (m *LogGroup) GetTopic() string

+ func (m *LogGroup) Marshal() (dAtA []byte, err error)

+ func (m *LogGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogGroup) Reset()

+ func (m *LogGroup) Size() (n int)

+ func (m *LogGroup) String() string

+ func (m *LogGroup) Unmarshal(dAtA []byte) error

+ type LogGroupList struct

+ LogGroups []*LogGroup

+ XXX_unrecognized []byte

+ func LogsBytesDecode(data []byte) (gl *LogGroupList, err error)

+ func (*LogGroupList) Descriptor() ([]byte, []int)

+ func (*LogGroupList) ProtoMessage()

+ func (m *LogGroupList) GetLogGroups() []*LogGroup

+ func (m *LogGroupList) Marshal() (dAtA []byte, err error)

+ func (m *LogGroupList) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogGroupList) Reset()

+ func (m *LogGroupList) Size() (n int)

+ func (m *LogGroupList) String() string

+ func (m *LogGroupList) Unmarshal(dAtA []byte) error

+ type LogProject struct

+ AccessKeyID string

+ AccessKeySecret string

+ CreateTime string

+ Description string

+ Endpoint string

+ LastModifyTime 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 (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) 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) 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) 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) ListMachineGroup(offset, size int) (m []string, total int, err 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) UpdateMachineGroup(m *MachineGroup) (err error)

+ 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

+ LastModifyTime uint32

+ MaxSplitShard int

+ Name string

+ ShardCount int

+ TTL int

+ 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) 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) GetIndex() (*Index, error)

+ func (s *LogStore) GetIndexString() (string, error)

+ func (s *LogStore) GetLogs(topic string, from int64, to 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) GetShipper(shipperName string) (*Shipper, error)

+ func (s *LogStore) ListShards() (shardIDs []*Shard, err error)

+ func (s *LogStore) PostLogStoreLogs(lg *LogGroup, hashKey *string) (err error)

+ func (s *LogStore) PullLogs(shardID int, cursor, endCursor string, logGroupMaxCount int) (gl *LogGroupList, nextCursor string, 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) UpdateShipper(shipper *Shipper) error

+ type LogTag struct

+ Key *string

+ Value *string

+ XXX_unrecognized []byte

+ func (*LogTag) Descriptor() ([]byte, []int)

+ func (*LogTag) ProtoMessage()

+ func (m *LogTag) GetKey() string

+ func (m *LogTag) GetValue() string

+ func (m *LogTag) Marshal() (dAtA []byte, err error)

+ func (m *LogTag) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogTag) Reset()

+ func (m *LogTag) Size() (n int)

+ func (m *LogTag) String() string

+ func (m *LogTag) Unmarshal(dAtA []byte) error

+ type MachinGroupAttribute struct

+ ExternalName string

+ TopicName string

+ type Machine struct

+ IP string

+ 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 Notification struct

+ Content string

+ EmailList []string

+ Method string

+ MobileList []string

+ ServiceUri string

+ Type string

+ type OSSShipperConfig struct

+ BufferInterval int

+ BufferSize int

+ CompressType string

+ Format string

+ OssBucket string

+ OssPrefix string

+ PathFormat string

+ RoleArn string

+ type OutputDetail struct

+ LogStoreName string

+ ProjectName string

+ 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 RegexConfigInputDetail struct

+ Key []string

+ LogBeginRegex string

+ Regex string

+ func ConvertToRegexConfigInputDetail(detail InputDetailInterface) (*RegexConfigInputDetail, bool)

+ type SavedSearch struct

+ DisplayName string

+ Logstore string

+ SavedSearchName string

+ SearchQuery string

+ Topic string

+ type Schedule struct

+ Interval string

+ Type string

+ type SensitiveKey struct

+ All bool

+ ConstString string

+ Key string

+ RegexBegin string

+ RegexContent string

+ Type string

+ 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 SingleHistogram struct

+ Count int64

+ From int64

+ Progress string

+ To int64

+ type SlsLogPackage struct

+ Data []byte

+ UncompressSize *int32

+ XXX_unrecognized []byte

+ func (*SlsLogPackage) Descriptor() ([]byte, []int)

+ func (*SlsLogPackage) ProtoMessage()

+ func (m *SlsLogPackage) GetData() []byte

+ func (m *SlsLogPackage) GetUncompressSize() int32

+ func (m *SlsLogPackage) Marshal() (dAtA []byte, err error)

+ func (m *SlsLogPackage) MarshalTo(dAtA []byte) (int, error)

+ func (m *SlsLogPackage) Reset()

+ func (m *SlsLogPackage) Size() (n int)

+ func (m *SlsLogPackage) String() string

+ func (m *SlsLogPackage) Unmarshal(dAtA []byte) error

+ type SlsLogPackageList struct

+ Packages []*SlsLogPackage

+ XXX_unrecognized []byte

+ func (*SlsLogPackageList) Descriptor() ([]byte, []int)

+ func (*SlsLogPackageList) ProtoMessage()

+ func (m *SlsLogPackageList) GetPackages() []*SlsLogPackage

+ func (m *SlsLogPackageList) Marshal() (dAtA []byte, err error)

+ func (m *SlsLogPackageList) MarshalTo(dAtA []byte) (int, error)

+ func (m *SlsLogPackageList) Reset()

+ func (m *SlsLogPackageList) Size() (n int)

+ func (m *SlsLogPackageList) String() string

+ func (m *SlsLogPackageList) Unmarshal(dAtA []byte) error

+ type SourceConfig struct

+ LogstoreName string

+ type StreamLogConfigInputDetail struct

+ Tag string

+ func ConvertToStreamLogConfigInputDetail(detail InputDetailInterface) (*StreamLogConfigInputDetail, bool)

+ 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) 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) CreateDashboard(project string, dashboard Dashboard) (err error)

+ func (c *TokenAutoUpdateClient) CreateDashboardString(project string, dashboardStr string) (err error)

+ func (c *TokenAutoUpdateClient) CreateEtlMeta(project string, etlMeta *EtlMeta) (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) 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) CreateProject(name, description string) (prj *LogProject, err error)

+ func (c *TokenAutoUpdateClient) CreateSavedSearch(project string, savedSearch *SavedSearch) (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) DeleteDashboard(project, name string) (err error)

+ func (c *TokenAutoUpdateClient) DeleteEtlMeta(project string, etlMetaName, etlMetaKey string) (err error)

+ func (c *TokenAutoUpdateClient) DeleteIndex(project, logstore 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) DeleteProject(name string) (err error)

+ func (c *TokenAutoUpdateClient) DeleteSavedSearch(project string, savedSearchName 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) 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) 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) GetDashboard(project, name string) (dashboard *Dashboard, err error)

+ func (c *TokenAutoUpdateClient) GetDashboardString(project, name string) (dashboard string, err error)

+ func (c *TokenAutoUpdateClient) GetEtlMeta(project string, etlMetaName, etlMetaKey string) (etlMeta *EtlMeta, err error)

+ func (c *TokenAutoUpdateClient) GetHistograms(project, logstore string, topic string, from int64, to int64, queryExp string) (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) GetLogStore(project string, logstore string) (logstoreRst *LogStore, err error)

+ func (c *TokenAutoUpdateClient) GetLogs(project, logstore string, topic string, from int64, to int64, queryExp string, ...) (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) GetMachineGroup(project string, machineGroup string) (m *MachineGroup, err error)

+ func (c *TokenAutoUpdateClient) GetProject(name string) (prj *LogProject, err error)

+ func (c *TokenAutoUpdateClient) GetSavedSearch(project string, savedSearchName string) (savedSearch *SavedSearch, 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) ListDashboard(project string, dashboardName string, offset, size int) (dashboardList []string, count, total int, 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) ListLogStore(project 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) ListProject() (projectNames []string, err error)

+ func (c *TokenAutoUpdateClient) ListProjectV2(offset, size int) (projects []LogProject, 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) ListShards(project, logstore string) (shardIDs []*Shard, err error)

+ func (c *TokenAutoUpdateClient) MergeShards(project, logstore string, shardID int) (shards []*Shard, err error)

+ func (c *TokenAutoUpdateClient) PostLogStoreLogs(project, logstore string, lg *LogGroup, hashKey *string) (err error)

+ func (c *TokenAutoUpdateClient) PullLogs(project, logstore string, shardID int, cursor, endCursor string, ...) (gl *LogGroupList, nextCursor string, 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) 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) SplitShard(project, logstore string, shardID int, splitKey string) (shards []*Shard, err error)

+ func (c *TokenAutoUpdateClient) UpdateAlert(project string, alert *Alert) (err error)

+ func (c *TokenAutoUpdateClient) UpdateChart(project, dashboardName string, chart Chart) (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) UpdateDashboard(project string, dashboard Dashboard) (err error)

+ func (c *TokenAutoUpdateClient) UpdateDashboardString(project string, dashboardName, dashboardStr string) (err error)

+ func (c *TokenAutoUpdateClient) UpdateEtlMeta(project string, etlMeta *EtlMeta) (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) UpdateLogStore(project string, logstore string, ttl, shardCnt int) (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) UpdateSavedSearch(project string, savedSearch *SavedSearch) (err error)

+ type TriggerConfig struct

+ MaxRetryTime int

+ RoleARN string

+ TriggerInterval int

+ type UpdateTokenFunction func() (accessKeyID, accessKeySecret, securityToken string, expireTime time.Time, ...)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL