Versions in this module Expand all Collapse all v0 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, ...)