sls

Nov 11, 2024

Changes in this version

type ResourceUnTags

+ All bool

Sep 5, 2024

Changes in this version

type CredentialsProvider

+ func NewEcsRamRoleCredentialsProvider(roleName string) CredentialsProvider

Jul 31, 2024

Changes in this version

+ func SetZstdCompressor(compressor LogCompressor) error

+ type LogCompressor interface

+ Compress func(src, dst []byte) ([]byte, error)

+ Decompress func(src, dst []byte) ([]byte, error)

type ResourceSystemTags

+ Scope string

+ type ZstdCompressor struct

+ func NewZstdCompressor(level zstd.EncoderLevel) *ZstdCompressor

+ func (c *ZstdCompressor) Compress(src, dst []byte) ([]byte, error)

+ func (c *ZstdCompressor) Decompress(src, dst []byte) ([]byte, error)

Jun 13, 2024

retracted

Changes in this version

+ const STORE_VIEW_STORE_TYPE_LOGSTORE

+ const STORE_VIEW_STORE_TYPE_METRICSTORE

type Client

+ func (c *Client) CreateStoreView(project string, storeView *StoreView) error

+ func (c *Client) DeleteStoreView(project string, storeViewName string) error

+ func (c *Client) GetStoreView(project string, storeViewName string) (*StoreView, error)

+ func (c *Client) GetStoreViewIndex(project string, storeViewName string) (*GetStoreViewIndexResponse, error)

+ func (c *Client) ListStoreViews(project string, req *ListStoreViewsRequest) (*ListStoreViewsResponse, error)

+ func (c *Client) UpdateStoreView(project string, storeView *StoreView) error

type ClientInterface

+ CreateStoreView func(project string, storeView *StoreView) error

+ DeleteStoreView func(project string, storeViewName string) error

+ GetStoreView func(project string, storeViewName string) (*StoreView, error)

+ GetStoreViewIndex func(project string, storeViewName string) (*GetStoreViewIndexResponse, error)

+ ListStoreViews func(project string, req *ListStoreViewsRequest) (*ListStoreViewsResponse, error)

+ UpdateStoreView func(project string, storeView *StoreView) error

+ type GetStoreViewIndexResponse struct

+ Indexes []*StoreViewIndex

+ StoreViewErrors []*StoreViewErrors

+ type ListStoreViewsRequest struct

+ Offset int

+ Size int

+ type ListStoreViewsResponse struct

+ Count int

+ StoreViews []string

+ Total int

+ type StoreView struct

+ Name string

+ StoreType string

+ Stores []*StoreViewStore

+ type StoreViewErrors struct

+ LogStore string

+ Message string

+ ProjectName string

+ Status string

+ type StoreViewIndex struct

+ Index Index

+ LogStore string

+ ProjectName string

+ type StoreViewStore struct

+ Project string

+ Query string

+ StoreName string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) CreateStoreView(project string, storeView *StoreView) (err error)

+ func (c *TokenAutoUpdateClient) DeleteStoreView(project string, storeViewName string) (err error)

+ func (c *TokenAutoUpdateClient) GetStoreView(project string, storeViewName string) (storeView *StoreView, err error)

+ func (c *TokenAutoUpdateClient) GetStoreViewIndex(project string, storeViewName string) (resp *GetStoreViewIndexResponse, err error)

+ func (c *TokenAutoUpdateClient) ListStoreViews(project string, req *ListStoreViewsRequest) (resp *ListStoreViewsResponse, err error)

+ func (c *TokenAutoUpdateClient) UpdateStoreView(project string, storeView *StoreView) (err error)

Jun 5, 2024

retracted

Changes in this version

type LogProject

+ Location string

May 24, 2024

retracted

Changes in this version

type PullLogMeta

+ DataCountBeforeQuery int

+ FailedLines int

+ Lines int

+ LinesBeforeQuery int

May 24, 2024

retracted

Changes in this version

+ const Compress_ZSTD

type Client

+ func (c *Client) PostLogStoreLogsV2(project, logstore string, req *PostLogStoreLogsRequest) (err error)

type ClientInterface

+ PostLogStoreLogsV2 func(project, logstore string, req *PostLogStoreLogsRequest) (err error)

+ type PostLogStoreLogsRequest struct

+ CompressType int

+ HashKey *string

+ LogGroup *LogGroup

type PullLogMeta

+ Netflow int

type PullLogRequest

+ CompressType int

+ QueryId string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) PostLogStoreLogsV2(project, logstore string, req *PostLogStoreLogsRequest) (err error)

Mar 27, 2024

retracted

Changes in this version

type Client

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

type ClientInterface

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

type TokenAutoUpdateClient

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

Jan 29, 2024

Changes in this version

+ const DataSourceS3

+ func ParseHeaderInt(r *http.Response, headerName string) (int, error)

type Client

+ func (c *Client) GetLogsBytesWithQuery(plr *PullLogRequest) (out []byte, plm *PullLogMeta, err error)

+ func (c *Client) PullLogsWithQuery(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error)

type ClientInterface

+ GetLogsBytesWithQuery func(plr *PullLogRequest) (out []byte, plm *PullLogMeta, err error)

+ PullLogsWithQuery func(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error)

type KafkaSource

+ VpcId string

type LogStore

+ func (s *LogStore) GetLogsBytesWithQuery(plr *PullLogRequest) (out []byte, pullLogMeta *PullLogMeta, err error)

+ func (s *LogStore) PullLogsWithQuery(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error)

+ type PullLogMeta struct

+ NextCursor string

+ RawDataCountBeforeQuery int

+ RawSize int

+ RawSizeBeforeQuery int

+ type S3Source struct

+ AWSAccessKey string

+ AWSAccessKeySecret string

+ AWSRegion string

+ Bucket string

+ CompressionCodec string

+ Encoding string

+ Format interface{}

+ Pattern string

+ Prefix string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetLogsBytesWithQuery(plr *PullLogRequest) (out []byte, plm *PullLogMeta, err error)

+ func (c *TokenAutoUpdateClient) PullLogsWithQuery(plr *PullLogRequest) (gl *LogGroupList, plm *PullLogMeta, err error)

Dec 5, 2023

Changes in this version

type KafkaSource

+ Communication string

+ NameResolutions string

Nov 20, 2023

Changes in this version

type Client

+ func (c *Client) SetRetryTimeout(timeout time.Duration)

type ClientInterface

+ SetRetryTimeout func(timeout time.Duration)

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) SetRetryTimeout(timeout time.Duration)

Oct 20, 2023

Changes in this version

type GetLogRequest

+ IsAccurate bool

Oct 12, 2023

Changes in this version

type Client

+ InnerHeaders map[string]string

type LogProject

+ InnerHeaders map[string]string

Oct 12, 2023

Changes in this version

type Client

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

+ func (c *Client) TagResourcesSystemTags(project string, tags *ResourceSystemTags) error

+ func (c *Client) UnTagResourcesSystemTags(project string, tags *ResourceUnSystemTags) error

type ClientInterface

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

+ TagResourcesSystemTags func(project string, tags *ResourceSystemTags) error

+ UnTagResourcesSystemTags func(project string, tags *ResourceUnSystemTags) error

+ type ResourceSystemTags struct

+ TagOwnerUid string

+ func NewResourceSystemTags(resourceType string, resourceId string, tagOwnerUid string, tags []ResourceTag) *ResourceSystemTags

+ type ResourceUnSystemTags struct

+ TagOwnerUid string

+ func NewResourceUnSystemTags(resourceType string, resourceId string, tagOwnerUid string, tags []string) *ResourceUnSystemTags

type TokenAutoUpdateClient

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

+ func (c *TokenAutoUpdateClient) TagResourcesSystemTags(project string, tags *ResourceSystemTags) (err error)

+ func (c *TokenAutoUpdateClient) UnTagResourcesSystemTags(project string, tags *ResourceUnSystemTags) (err error)

Oct 11, 2023

Changes in this version

type AuthVersionType

+ const AuthV0

type Client

+ KeyProvider string

type LogProject

+ KeyProvider string

+ type SignerV0 struct

+ func NewSignerV0() *SignerV0

+ func (s *SignerV0) Sign(method, uriWithQuery string, headers map[string]string, body []byte) error

Sep 15, 2023

Changes in this version

type GetLogRequest

+ NeedHighlight bool

Sep 11, 2023

Changes in this version

+ const CHARGE_BY_DATA_INGEST

+ const CHARGE_BY_FUNCTION

+ const NOT_SUPPORTED

type Client

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

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

type ClientInterface

+ GetLogStoreMeteringMode func(project string, logstore string) (*GetMeteringModeResponse, error)

+ UpdateLogStoreMeteringMode func(project string, logstore string, meteringMode string) error

+ type GetMeteringModeResponse struct

+ MeteringMode string

type LogStore

+ func (s *LogStore) GetMeteringMode() (*GetMeteringModeResponse, error)

+ func (s *LogStore) UpdateMeteringMode(meteringMode string) error

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetLogStoreMeteringMode(project string, logstore string) (res *GetMeteringModeResponse, err error)

+ func (c *TokenAutoUpdateClient) UpdateLogStoreMeteringMode(project string, logstore string, meteringMode string) (err error)

Aug 30, 2023

Changes in this version

type Client

+ func (c *Client) GetLogsToCompletedV3(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error)

type ClientInterface

+ GetLogsToCompletedV3 func(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error)

type GetLogsV3Response

+ func (resp *GetLogsV3Response) IsComplete() bool

type LogStore

+ func (s *LogStore) GetLogsToCompletedV3(req *GetLogRequest) (*GetLogsV3Response, error)

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetLogsToCompletedV3(project, logstore string, req *GetLogRequest) (r *GetLogsV3Response, err error)

Aug 29, 2023

Changes in this version

+ const AggQuery

+ const CRED_TIME_FORMAT

+ const CpuCores

+ const CpuSec

+ const DEFAULT_EXPIRED_FACTOR

+ const ECS_RAM_ROLE_RETRY_TIMES

+ const ECS_RAM_ROLE_URL_PREFIX

+ const ElapsedMillisecond

+ const InsertedSql

+ const PROJECT_DATA_REDUNDANCY_TYPE_LRS

+ const PROJECT_DATA_REDUNDANCY_TYPE_UNKNOWN

+ const PROJECT_DATA_REDUNDANCY_TYPE_ZRS

+ const PowerSql

+ const ProcessedBytes

+ const ProcessedRows

+ const TelemetryType

+ const UPDATE_FUNC_FETCH_ADVANCED_DURATION

+ const UPDATE_FUNC_RETRY_TIMES

+ const WhereQuery

+ func BoolPtrToStringNum(b *bool) string

+ func BoolToInt64(b bool) int64

+ func Int64PtrToString(i *int64) string

type Client

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

+ func (c *Client) WithCredentialsProvider(provider CredentialsProvider) *Client

type ClientInterface

+ func CreateNormalInterfaceV2(endpoint string, credentialsProvider CredentialsProvider) ClientInterface

+ CreateProjectV2 func(name, description, dataRedundancyType string) (*LogProject, error)

+ type Credentials struct

+ AccessKeyID string

+ AccessKeySecret string

+ SecurityToken string

+ type CredentialsFetcher = func() (*TempCredentials, error)

+ func NewCredentialsFetcher(builder CredentialsRequestBuilder, parser CredentialsRespParser, ...) CredentialsFetcher

+ func NewEcsRamRoleFetcher(urlPrefix, ramRole string, customClient *http.Client) CredentialsFetcher

+ type CredentialsProvider interface

+ GetCredentials func() (Credentials, error)

+ type CredentialsRequestBuilder = func() (*http.Request, error)

+ type CredentialsRespParser = func(*http.Response) (*TempCredentials, error)

+ type EcsRamRoleHttpResp struct

+ AccessKeyID string

+ AccessKeySecret string

+ Code string

+ Expiration int64

+ LastUpdated int64

+ SecurityToken string

type GetLogsV3ResponseMeta

+ ColumnTypes []string

+ Highlights []map[string]string

+ InsertedSql string

+ IsAccurate *bool

+ Keys []string

+ Marker *string

+ Mode *int

+ PhraseQueryInfo *PhraseQueryInfoV3

+ PowerSql bool

+ ProcessedBytes int64

+ ScanBytes *int64

+ Shard *int

+ TelemetryType string

+ Terms []MetaTerm

type LogProject

+ DataRedundancyType string

+ func NewLogProjectV2(name, endpoint string, provider CredentialsProvider) (p *LogProject, err error)

+ func (p *LogProject) WithCredentialsProvider(provider CredentialsProvider) *LogProject

+ type MetaTerm struct

+ Key string

+ Term string

+ type PhraseQueryInfoV2 struct

+ BeginOffset string

+ EndOffset string

+ EndTime string

+ ScanAll string

+ type PhraseQueryInfoV3 struct

+ BeginOffset *int64

+ EndOffset *int64

+ EndTime *int64

+ ScanAll *bool

+ type QueryInfoV2 struct

+ ColumnTypes []string

+ Highlights []map[string]string

+ IsAccurate *int64

+ Keys []string

+ Limited string

+ Marker *string

+ Mode *int

+ PhraseQueryInfo *PhraseQueryInfoV2

+ ScanBytes *int64

+ Shard *int

+ Terms [][]string

+ type StaticCredentialsProvider struct

+ Cred Credentials

+ func NewStaticCredentialsProvider(accessKeyID, accessKeySecret, securityToken string) *StaticCredentialsProvider

+ func (p *StaticCredentialsProvider) GetCredentials() (Credentials, error)

+ type TempCredentials struct

+ func NewTempCredentials(accessKeyId, accessKeySecret, securityToken string, ...) *TempCredentials

+ func (t *TempCredentials) HasExpired() bool

+ func (t *TempCredentials) ShouldRefresh() bool

+ func (t *TempCredentials) WithExpiredFactor(factor float64) *TempCredentials

type TokenAutoUpdateClient

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

+ type UpdateFuncProviderAdapter struct

+ func NewUpdateFuncProviderAdapter(updateFunc UpdateTokenFunction) *UpdateFuncProviderAdapter

+ func (adp *UpdateFuncProviderAdapter) GetCredentials() (Credentials, error)

Aug 15, 2023

Changes in this version

type Client

+ func (c *Client) GetLogsBytesV2(plr *PullLogRequest) (out []byte, nextCursor string, err error)

+ func (c *Client) PullLogsV2(plr *PullLogRequest) (gl *LogGroupList, nextCursor string, err error)

type ClientInterface

+ GetLogsBytesV2 func(plr *PullLogRequest) (out []byte, nextCursor string, err error)

+ PullLogsV2 func(plr *PullLogRequest) (gl *LogGroupList, nextCursor string, err error)

type LogStore

+ func (s *LogStore) GetLogsBytesV2(plr *PullLogRequest) (out []byte, nextCursor string, err error)

+ func (s *LogStore) PullLogsV2(plr *PullLogRequest) (gl *LogGroupList, nextCursor string, err error)

+ type PullLogRequest struct

+ Cursor string

+ EndCursor string

+ LogGroupMaxCount int

+ Logstore string

+ Project string

+ PullMode string

+ Query string

+ ShardID int

+ func (plr *PullLogRequest) ToURLParams() url.Values

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetLogsBytesV2(plr *PullLogRequest) (out []byte, nextCursor string, err error)

+ func (c *TokenAutoUpdateClient) PullLogsV2(plr *PullLogRequest) (gl *LogGroupList, nextCursor string, err error)

Aug 11, 2023

Changes in this version

type Client

+ CommonHeaders map[string]string

type LogProject

+ CommonHeaders map[string]string

Jul 27, 2023

Changes in this version

type Client

+ func (c *Client) ListMachinesV2(project, machineGroupName string, offset, size int) (ms []*Machine, total int, err error)

+ func (c *Client) PostRawLogWithCompressType(project, logstore string, rawLogData []byte, compressType int, hashKey *string) (err error)

type ClientInterface

+ ListMachinesV2 func(project, machineGroupName string, offset, size int) (ms []*Machine, total int, err error)

+ PostRawLogWithCompressType func(project, logstore string, rawLogData []byte, compressType int, hashKey *string) (err error)

type LogStore

+ func (s *LogStore) PostRawLogs(body []byte, hashKey *string) (err error)

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) ListMachinesV2(project, machineGroupName string, offset, size int) (ms []*Machine, total int, err error)

+ func (c *TokenAutoUpdateClient) PostRawLogWithCompressType(project, logstore string, rawLogData []byte, compressType int, hashKey *string) (err error)

Jun 30, 2023

Changes in this version

+ var ErrUnexpectedEndOfGroupLog = fmt.Errorf("proto: unexpected end of group")

type Client

+ func (c *Client) GetLogLinesByNano(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogLinesResponse, error)

+ func (c *Client) GetLogsByNano(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogsResponse, error)

type ClientInterface

+ GetLogLinesByNano func(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogLinesResponse, error)

+ GetLogsByNano func(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (*GetLogsResponse, error)

type GetLogRequest

+ FromNsPart int32

+ ToNsPart int32

type Log

+ TimeNs *uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (m *Log) GetTimeNs() uint32

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

+ func (m *Log) XXX_DiscardUnknown()

+ func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Log) XXX_Merge(src proto.Message)

+ func (m *Log) XXX_Size() int

+ func (m *Log) XXX_Unmarshal(b []byte) error

type LogContent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ func (m *LogContent) XXX_DiscardUnknown()

+ func (m *LogContent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogContent) XXX_Merge(src proto.Message)

+ func (m *LogContent) XXX_Size() int

+ func (m *LogContent) XXX_Unmarshal(b []byte) error

type LogGroup

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ func (m *LogGroup) XXX_DiscardUnknown()

+ func (m *LogGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogGroup) XXX_Merge(src proto.Message)

+ func (m *LogGroup) XXX_Size() int

+ func (m *LogGroup) XXX_Unmarshal(b []byte) error

type LogGroupList

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ func (m *LogGroupList) XXX_DiscardUnknown()

+ func (m *LogGroupList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogGroupList) XXX_Merge(src proto.Message)

+ func (m *LogGroupList) XXX_Size() int

+ func (m *LogGroupList) XXX_Unmarshal(b []byte) error

type LogStore

+ func (s *LogStore) GetLogLinesByNano(topic string, fromInNS int64, toInNs int64, queryExp string, maxLineNum int64, ...) (*GetLogLinesResponse, error)

+ func (s *LogStore) GetLogsByNano(topic string, fromInNS int64, toInNs int64, queryExp string, maxLineNum int64, ...) (*GetLogsResponse, error)

type LogTag

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ func (m *LogTag) XXX_DiscardUnknown()

+ func (m *LogTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogTag) XXX_Merge(src proto.Message)

+ func (m *LogTag) XXX_Size() int

+ func (m *LogTag) XXX_Unmarshal(b []byte) error

type SlsLogPackage

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ func (m *SlsLogPackage) XXX_DiscardUnknown()

+ func (m *SlsLogPackage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SlsLogPackage) XXX_Merge(src proto.Message)

+ func (m *SlsLogPackage) XXX_Size() int

+ func (m *SlsLogPackage) XXX_Unmarshal(b []byte) error

type SlsLogPackageList

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ func (m *SlsLogPackageList) XXX_DiscardUnknown()

+ func (m *SlsLogPackageList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SlsLogPackageList) XXX_Merge(src proto.Message)

+ func (m *SlsLogPackageList) XXX_Size() int

+ func (m *SlsLogPackageList) XXX_Unmarshal(b []byte) error

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetLogLinesByNano(project, logstore string, topic string, fromInNs int64, toInNS int64, ...) (r *GetLogLinesResponse, err error)

+ func (c *TokenAutoUpdateClient) GetLogsByNano(project, logstore string, topic string, fromInNs int64, toInNs int64, ...) (r *GetLogsResponse, err error)

Jun 6, 2023

Changes in this version

+ const EventStoreIndex

+ const EventStoreTelemetryType

type AlertConfiguration

+ SinkAlerthub *SinkAlerthubConfiguration

+ SinkCms *SinkCmsConfiguration

+ SinkEventStore *SinkEventStoreConfiguration

type Client

+ func (c *Client) CreateEventStore(project string, eventStore *LogStore) error

+ func (c *Client) DeleteEventStore(project, name string) error

+ func (c *Client) GetEventStore(project, name string) (*LogStore, error)

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

+ func (c *Client) UpdateEventStore(project string, eventStore *LogStore) error

type ClientInterface

+ CreateEventStore func(project string, eventStore *LogStore) error

+ DeleteEventStore func(project, name string) error

+ GetEventStore func(project, name string) (*LogStore, error)

+ ListEventStore func(project string, offset, size int) ([]string, error)

+ UpdateEventStore func(project string, eventStore *LogStore) error

+ type SinkAlerthubConfiguration struct

+ Enabled bool

+ type SinkCmsConfiguration struct

+ Enabled bool

+ type SinkEventStoreConfiguration struct

+ Enabled bool

+ Endpoint string

+ EventStore string

+ Project string

+ RoleArn string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) CreateEventStore(project string, eventStore *LogStore) (err error)

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

+ func (c *TokenAutoUpdateClient) GetEventStore(project, name string) (eventStore *LogStore, err error)

+ func (c *TokenAutoUpdateClient) ListEventStore(project string, offset, size int) (eventStores []string, err error)

+ func (c *TokenAutoUpdateClient) UpdateEventStore(project string, eventStore *LogStore) (err error)

May 29, 2023

Changes in this version

+ func GenResourceId(project string, subResourceId string) string

type ResourceTags

+ func NewResourceTags(resourceType string, resourceId string, tags []ResourceTag) *ResourceTags

type ResourceUnTags

+ func NewResourceUnTags(resourceType string, resourceId string, tags []string) *ResourceUnTags

May 16, 2023

Changes in this version

+ const BodyRawSize

type Client

+ func (c *Client) GetLogsV3(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error)

type ClientInterface

+ GetLogsV3 func(project, logstore string, req *GetLogRequest) (*GetLogsV3Response, error)

+ type GetLogsV3Response struct

+ Logs []map[string]string

+ Meta GetLogsV3ResponseMeta

+ type GetLogsV3ResponseMeta struct

+ AggQuery string

+ Count int64

+ CpuCores float64

+ CpuSec float64

+ ElapsedMillisecond int64

+ HasSQL bool

+ Limited int64

+ ProcessedRows int64

+ Progress string

+ WhereQuery string

type LogStore

+ func (s *LogStore) GetLogsV3(req *GetLogRequest) (*GetLogsV3Response, error)

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetLogsV3(project, logstore string, req *GetLogRequest) (r *GetLogsV3Response, err error)

Apr 25, 2023

Changes in this version

type ConsumerGroup

+ func (cg *ConsumerGroup) String() string

type OutputDetail

+ CompressType string

Dec 28, 2022

Changes in this version

type Client

+ func (c *Client) PublishAlertEvent(project string, alertResult []byte) error

type ClientInterface

+ PublishAlertEvent func(project string, alertResult []byte) error

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) PublishAlertEvent(project string, alertResult []byte) error

Dec 8, 2022

Changes in this version

+ const HTTPHeaderAPIVersion

+ const HTTPHeaderAcsSecurityToken

+ const HTTPHeaderAuthorization

+ const HTTPHeaderBodyRawSize

+ const HTTPHeaderContentLength

+ const HTTPHeaderContentMD5

+ const HTTPHeaderContentType

+ const HTTPHeaderDate

+ const HTTPHeaderHost

+ const HTTPHeaderLogContentSha256

+ const HTTPHeaderLogDate

+ const HTTPHeaderSignatureMethod

+ const HTTPHeaderUserAgent

+ const ISO8601

+ type AuthVersionType string

+ const AuthV1

+ const AuthV4

type Client

+ AuthVersion AuthVersionType

+ Region string

+ func (c *Client) SetAuthVersion(version AuthVersionType)

+ func (c *Client) SetRegion(region string)

type ClientInterface

+ SetAuthVersion func(version AuthVersionType)

+ SetRegion func(region string)

type LogProject

+ AuthVersion AuthVersionType

+ type Signer interface

+ Sign func(method, uriWithQuery string, headers map[string]string, body []byte) error

+ type SignerV1 struct

+ func NewSignerV1(accessKeyID, accessKeySecret string) *SignerV1

+ func (s *SignerV1) Sign(method, uri string, headers map[string]string, body []byte) error

+ type SignerV4 struct

+ func NewSignerV4(accessKeyID, accessKeySecret, region string) *SignerV4

+ func (s *SignerV4) Sign(method, uri string, headers map[string]string, body []byte) error

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) SetAuthVersion(version AuthVersionType)

+ func (c *TokenAutoUpdateClient) SetRegion(region string)

Nov 23, 2022

Changes in this version

+ var MaxCompletedRetryCount = 20

+ var MaxCompletedRetryLatency = 5 * time.Minute

type Client

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

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

+ func (c *Client) GetLogsToCompletedV2(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error)

type ClientInterface

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

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

+ GetLogsToCompletedV2 func(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error)

type GetLogsResponse

+ Header http.Header

type LogStore

+ func (s *LogStore) GetHistogramsToCompleted(topic string, from int64, to int64, queryExp string) (*GetHistogramsResponse, error)

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

+ func (s *LogStore) GetLogsToCompletedV2(req *GetLogRequest) (*GetLogsResponse, error)

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetHistogramsToCompleted(project, logstore string, topic string, from int64, to int64, queryExp string) (h *GetHistogramsResponse, err error)

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

+ func (c *TokenAutoUpdateClient) GetLogsToCompletedV2(project, logstore string, req *GetLogRequest) (r *GetLogsResponse, err error)

Nov 7, 2022

Changes in this version

type Index

+ LogReduce bool

+ LogReduceBlackListDict []string

+ LogReduceWhiteListDict []string

+ MaxTextLen uint32

+ Ttl uint32

Oct 27, 2022

Changes in this version

type Client

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

+ func (c *Client) GetProjectPolicy(project string) (policy string, err error)

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

+ func (c *Client) UpdateProjectPolicy(project string, policy string) error

type ClientInterface

+ CreateETL func(project string, etljob ETL) error

+ DeleteETL func(project string, etlName string) error

+ DeleteProjectPolicy func(project string) error

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

+ GetProjectPolicy func(project string) (string, error)

+ ListETL func(project string, offset int, size int) (*ListETLResponse, error)

+ RestartETL func(project string, etljob ETL) error

+ StartETL func(project, name string) error

+ StopETL func(project, name string) error

+ UpdateETL func(project string, etljob ETL) error

+ UpdateProjectPolicy func(project string, policy string) error

type LogStore

+ ProductType string

type TokenAutoUpdateClient

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

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

+ func (c *TokenAutoUpdateClient) DeleteProjectPolicy(project string) (err error)

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

+ func (c *TokenAutoUpdateClient) GetProjectPolicy(project string) (policy string, err error)

+ func (c *TokenAutoUpdateClient) ListETL(project string, offset int, size int) (ETLResponse *ListETLResponse, err error)

+ func (c *TokenAutoUpdateClient) RestartETL(project string, etljob ETL) (err error)

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

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

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

+ func (c *TokenAutoUpdateClient) UpdateProjectPolicy(project, policy string) (err error)

Sep 20, 2022

Changes in this version

type AlertConfiguration

+ Tags []string

type Client

+ func (c *Client) RestartExport(project string, export *Export) error

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

type ClientInterface

+ RestartExport func(project string, export *Export) error

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

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) RestartExport(project string, export *Export) (err error)

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

Jun 29, 2022

Changes in this version

type Client

+ func (c *Client) CreateMetricStore(project string, metricStore *LogStore) error

+ func (c *Client) DeleteMetricStore(project, name string) error

+ func (c *Client) GetMetricStore(project, name string) (*LogStore, error)

+ func (c *Client) UpdateMetricStore(project string, metricStore *LogStore) error

type ClientInterface

+ CreateMetricStore func(project string, metricStore *LogStore) error

+ DeleteMetricStore func(project, name string) error

+ GetMetricStore func(project, name string) (*LogStore, error)

+ UpdateMetricStore func(project string, metricStore *LogStore) error

type LogStore

+ Mode string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) CreateMetricStore(project string, metricStore *LogStore) (err error)

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

+ func (c *TokenAutoUpdateClient) GetMetricStore(project, name string) (metricStore *LogStore, err error)

+ func (c *TokenAutoUpdateClient) UpdateMetricStore(project string, metricStore *LogStore) (err error)

type WebhookIntegration

+ Secret string

May 26, 2022

Changes in this version

type TriggerConfig

+ StartingPosition string

+ StartingUnixtime int64

May 16, 2022

Changes in this version

+ const DefaultLogUserAgent

May 14, 2022

Changes in this version

type Client

+ func (c *Client) SetUserAgent(userAgent string)

type ClientInterface

+ SetUserAgent func(userAgent string)

type FunctionConfig

+ RoleARN string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) SetUserAgent(userAgent string)

Apr 27, 2022

Changes in this version

type Client

+ HTTPClient *http.Client

+ func (c *Client) SetHTTPClient(client *http.Client)

type ClientInterface

+ SetHTTPClient func(client *http.Client)

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) SetHTTPClient(client *http.Client)

Apr 22, 2022

Changes in this version

+ const DataSinkADB

+ const DataSinkGENERAL

+ const DataSinkLOG

+ const DataSinkODPS

+ const DataSinkOSS

+ const DataSinkTSDB

+ const ExportVersion2

+ const OSSCompressionTypeGzip

+ const OSSCompressionTypeNone

+ const OSSCompressionTypeSnappy

+ const OSSCompressionTypeZstd

+ const OSSContentDetailTypeCSV

+ const OSSContentDetailTypeJSON

+ const OSSContentDetailTypeORC

+ const OSSContentDetailTypeParquet

type AlertConfiguration

+ AutoAnnotation bool

type AlertQuery

+ PowerSqlMode PowerSqlMode

+ type AliyunGeneralSink struct

+ Fields map[string]interface{}

+ Type DataSinkType

+ func (_ *AliyunGeneralSink) DataSinkType() DataSinkType

+ type AliyunODPSSink struct

+ Fields []string

+ OdpsAccessKeyId string

+ OdpsAccessSecret string

+ OdpsEndpoint string

+ OdpsProject string

+ OdpsRolearn string

+ OdpsTable string

+ OdpsTunnelEndpoint string

+ PartitionColumn []string

+ PartitionTimeFormat string

+ TimeZone string

+ Type DataSinkType

+ func (_ *AliyunODPSSink) DataSinkType() DataSinkType

+ type AliyunOSSSink struct

+ Bucket string

+ BufferInterval int64

+ BufferSize int64

+ CompressionType OSSCompressionType

+ ContentDetail string

+ ContentType OSSContentType

+ PathFormat string

+ PathFormatType string

+ Prefix string

+ RoleArn string

+ Suffix string

+ TimeZone string

+ Type DataSinkType

+ func (_ *AliyunOSSSink) DataSinkType() DataSinkType

type Client

+ func (c *Client) CreateExport(project string, export *Export) error

+ func (c *Client) DeleteExport(project string, name string) error

+ func (c *Client) GetExport(project, name string) (*Export, error)

+ func (c *Client) ListExport(project, logstore, name, displayName string, offset, size int) (exports []*Export, total, count int, error error)

+ func (c *Client) UpdateExport(project string, export *Export) error

type ClientInterface

+ CreateExport func(project string, export *Export) error

+ DeleteExport func(project string, name string) error

+ GetExport func(project, name string) (*Export, error)

+ ListExport func(project, logstore, name, displayName string, offset, size int) (exports []*Export, total, count int, error error)

+ UpdateExport func(project string, export *Export) error

+ type Column struct

+ Name string

+ Type string

+ type ColumnStorageContentDetail struct

+ Columns []Column

+ type CsvContentDetail struct

+ ColumnNames []string

+ Delimiter string

+ Escape string

+ Header bool

+ LineFeed string

+ Null string

+ Quote string

+ type DataSink interface

+ DataSinkType func() DataSinkType

+ type DataSinkType string

+ type Export struct

+ ExportConfiguration *ExportConfiguration

+ type ExportConfiguration struct

+ DataSink DataSink

+ FromTime int64

+ LogStore string

+ Parameters map[string]string

+ RoleArn string

+ ToTime int64

+ Version ExportVersion

+ func (e *ExportConfiguration) UnmarshalJSON(data []byte) error

+ type ExportVersion string

+ type JsonContentDetail struct

+ EnableTag bool

+ type OSSCompressionType string

+ type OSSContentType string

+ type OrcContentDetail ColumnStorageContentDetail

+ type ParquetContentDetail ColumnStorageContentDetail

+ type PowerSqlMode string

+ const PowerSqlModeAuto

+ const PowerSqlModeDisable

+ const PowerSqlModeEnable

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) CreateExport(project string, export *Export) (err error)

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

+ func (c *TokenAutoUpdateClient) GetExport(project, name string) (export *Export, err error)

+ func (c *TokenAutoUpdateClient) ListExport(project, logstore, name, displayName string, offset, size int) (exports []*Export, total, count int, err error)

+ func (c *TokenAutoUpdateClient) UpdateExport(project string, export *Export) (err error)

Feb 11, 2022

Changes in this version

+ const DataSourceBSS

+ const DataSourceCMS

+ const DataSourceGeneral

+ const DataSourceJDBC

+ const DataSourceKafka

+ const DataSourceMaxCompute

+ const DataSourceOSS

+ const KafkaPositionEarliest

+ const KafkaPositionGroupOffsets

+ const KafkaPositionLatest

+ const KafkaPositionTimeStamp

+ const KafkaValueTypeJSON

+ const KafkaValueTypeText

+ const OSSDataFormatTypeDelimitedText

+ const OSSDataFormatTypeJSON

+ const OSSDataFormatTypeLine

+ const OSSDataFormatTypeMultiline

+ const OSSDataFormatTypeParquet

+ type AliyunBssSource struct

+ HistoryMonth int64

+ RoleArn string

+ type AliyunCloudMonitorSource struct

+ AccessKeyID string

+ AccessKeySecret string

+ DelayTime int64

+ Namespaces []string

+ OutputType string

+ StartTime int64

+ type AliyunMaxComputeSource struct

+ AccessKeyID string

+ AccessKeySecret string

+ Endpoint string

+ PartitionSpec string

+ Project string

+ Table string

+ TimeField string

+ TimeFormat string

+ TimeZone string

+ TunnelEndpoint string

+ type AliyunOSSSource struct

+ Bucket string

+ CompressionCodec string

+ Encoding string

+ Endpoint string

+ Format interface{}

+ LastModifyTimeAsLogTime bool

+ Pattern string

+ Prefix string

+ RestoreObjectEnable bool

+ RoleArn string

+ type BaseJob struct

+ CreateTime int64

+ Description string

+ DisplayName string

+ LastModifyTime int64

+ Name string

+ Recyclable bool

+ Type JobType

type Client

+ func (c *Client) CreateIngestion(project string, ingestion *Ingestion) error

+ func (c *Client) DeleteIngestion(project string, name string) error

+ func (c *Client) GetIngestion(project string, name string) (*Ingestion, error)

+ func (c *Client) ListIngestion(project, logstore, name, displayName string, offset, size int) (ingestions []*Ingestion, total, count int, error error)

+ func (c *Client) UpdateIngestion(project string, ingestion *Ingestion) error

type ClientInterface

+ CreateIngestion func(project string, ingestion *Ingestion) error

+ DeleteIngestion func(project string, name string) error

+ GetIngestion func(project string, name string) (*Ingestion, error)

+ ListIngestion func(project, logstore, name, displayName string, offset, size int) (ingestions []*Ingestion, total, count int, error error)

+ UpdateIngestion func(project string, ingestion *Ingestion) error

+ type DataSource struct

+ DataSourceType DataSourceType

+ type DataSourceType string

+ type DelimitedTextFormat struct

+ EscapeChar string

+ FieldDelimiter string

+ FieldNames []string

+ FirstRowAsHeader bool

+ MaxLines int64

+ QuoteChar string

+ SkipLeadingRows int64

+ type Ingestion struct

+ IngestionConfiguration *IngestionConfiguration

+ type IngestionConfiguration struct

+ DataSource interface{}

+ LogStore string

+ NumberOfInstance int32

+ Version string

+ type IngestionGeneralSource struct

+ Fields map[string]interface{}

+ type JSONFormat struct

+ SkipInvalidRows bool

+ type KafkaPosition string

+ type KafkaSource struct

+ AdditionalProps map[string]string

+ BootStrapServers string

+ FromPosition KafkaPosition

+ FromTimeStamp int64

+ TimeField string

+ TimeFormat string

+ TimePattern string

+ TimeZone string

+ ToTimeStamp int64

+ Topics string

+ ValueType KafkaValueType

+ type KafkaValueType string

+ type LineFormat struct

+ TimePattern string

+ type MultiLineFormat struct

+ FlushPattern string

+ Match string

+ MaxLines int64

+ Negate bool

+ Pattern string

+ type OSSDataFormat struct

+ TimeFormat string

+ TimeZone string

+ Type OSSDataFormatType

+ type OSSDataFormatType string

+ type ParquetFormat struct

type Schedule

+ RunImmediately bool

+ TimeZone string

+ type ScheduledJob struct

+ Schedule *Schedule

+ ScheduleId string

+ Status string

+ type StructureDataFormat struct

+ TimeField string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) CreateIngestion(project string, ingestion *Ingestion) (err error)

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

+ func (c *TokenAutoUpdateClient) GetIngestion(project string, name string) (ingestion *Ingestion, err error)

+ func (c *TokenAutoUpdateClient) ListIngestion(project, logstore, name, displayName string, offset, size int) (ingestions []*Ingestion, total, count int, err error)

+ func (c *TokenAutoUpdateClient) UpdateIngestion(project string, ingestion *Ingestion) (err error)

Nov 18, 2021

Changes in this version

+ type Advanced struct

+ BlackList map[string][]string

+ ForceMultiConfig bool

+ Others string

type DelimiterConfigInputDetail

+ AcceptNoEnoughKeys bool

type LocalFileConfigInputDetail

+ Advanced Advanced

+ PluginDetail string

type RegexConfigInputDetail

+ CustomizedFields string

Nov 5, 2021

Changes in this version

type Client

+ func (c *Client) GetLogLinesV2(project, logstore string, req *GetLogRequest) (*GetLogLinesResponse, error)

+ func (c *Client) GetLogsV2(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error)

type ClientInterface

+ GetLogLinesV2 func(project, logstore string, req *GetLogRequest) (*GetLogLinesResponse, error)

+ GetLogsV2 func(project, logstore string, req *GetLogRequest) (*GetLogsResponse, error)

+ type GetLogRequest struct

+ From int64

+ Lines int64

+ Offset int64

+ PowerSQL bool

+ Query string

+ Reverse bool

+ To int64

+ Topic string

+ func (glr *GetLogRequest) ToURLParams() url.Values

type LogStore

+ func (s *LogStore) GetLogLinesV2(req *GetLogRequest) (*GetLogLinesResponse, error)

+ func (s *LogStore) GetLogsV2(req *GetLogRequest) (*GetLogsResponse, error)

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) GetLogLinesV2(project, logstore string, req *GetLogRequest) (r *GetLogLinesResponse, err error)

+ func (c *TokenAutoUpdateClient) GetLogsV2(project, logstore string, req *GetLogRequest) (r *GetLogsResponse, err error)

Nov 5, 2021

Changes in this version

type LogStore

+ HotTTL int

Aug 30, 2021

Changes in this version

+ const CountConditionKey

+ const GroupTypeCustom

+ const GroupTypeLabelsAuto

+ const GroupTypeNoGroup

+ const JoinTypeConcat

+ const JoinTypeCross

+ const JoinTypeFull

+ const JoinTypeInner

+ const JoinTypeLeft

+ const JoinTypeLeftExclude

+ const JoinTypeNo

+ const JoinTypeRight

+ const JoinTypeRightExclude

+ const ResourceNameActionPolicy

+ const ResourceNameAlertPolicy

+ const ResourceNameContentTemplate

+ const ResourceNameGlobalConfig

+ const ResourceNameUser

+ const ResourceNameUserGroup

+ const ResourceNameWebhookIntegration

+ const ResourceTypeUserDefine

+ const StoreTypeLog

+ const StoreTypeMeta

+ const StoreTypeMetric

+ func JsonMarshal(v interface{}) string

type AlertConfiguration

+ Annotations []*Tag

+ GroupConfiguration GroupConfiguration

+ JoinConfigurations []*JoinConfiguration

+ Labels []*Tag

+ NoDataFire bool

+ NoDataSeverity Severity

+ PolicyConfiguration PolicyConfiguration

+ SendResolved bool

+ SeverityConfigurations []*SeverityConfiguration

+ TemplateConfiguration *TemplateConfiguration

+ Threshold int

+ Type string

+ Version string

type AlertQuery

+ DashboardId string

+ Project string

+ Region string

+ RoleArn string

+ Store string

+ StoreType string

type Client

+ func (c *Client) CreateResource(resource *Resource) error

+ func (c *Client) CreateResourceRecord(resourceName string, record *ResourceRecord) error

+ func (c *Client) CreateResourceRecordString(resourceName, recordStr string) error

+ func (c *Client) CreateResourceString(resourceStr string) error

+ func (c *Client) CreateScheduledSQL(project string, scheduledsql *ScheduledSQL) error

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

+ func (c *Client) DeleteResourceRecord(resourceName, recordId string) error

+ func (c *Client) DeleteScheduledSQL(project string, name string) error

+ func (c *Client) GetResource(name string) (resource *Resource, err error)

+ func (c *Client) GetResourceRecord(resourceName, recordId string) (record *ResourceRecord, err error)

+ func (c *Client) GetResourceRecordString(resourceName, recordId string) (recordStr string, err error)

+ func (c *Client) GetResourceString(name string) (resource string, err error)

+ func (c *Client) GetScheduledSQL(project string, name string) (*ScheduledSQL, error)

+ func (c *Client) GetScheduledSQLJobInstance(projectName, jobName, instanceId string, result bool) (*ScheduledSQLJobInstance, error)

+ func (c *Client) ListResource(resourceType string, resourceName string, offset, size int) (resourceList []*Resource, count, total int, err error)

+ func (c *Client) ListResourceRecord(resourceName string, offset, size int) (recordList []*ResourceRecord, count, total int, err error)

+ func (c *Client) ListScheduledSQL(project, name, displayName string, offset, size int) (scheduledsqls []*ScheduledSQL, total, count int, error error)

+ func (c *Client) ListScheduledSQLJobInstances(projectName, jobName string, status *InstanceStatus) (instances []*ScheduledSQLJobInstance, total, count int64, err error)

+ func (c *Client) ModifyScheduledSQLJobInstanceState(projectName, jobName, instanceId string, state ScheduledSQLState) error

+ func (c *Client) UpdateResource(resource *Resource) error

+ func (c *Client) UpdateResourceRecord(resourceName string, record *ResourceRecord) error

+ func (c *Client) UpdateResourceRecordString(resourceName, recordStr string) error

+ func (c *Client) UpdateResourceString(resourceName, resourceStr string) error

+ func (c *Client) UpdateScheduledSQL(project string, scheduledsql *ScheduledSQL) error

type ClientInterface

+ CreateResource func(resource *Resource) error

+ CreateResourceRecord func(resourceName string, record *ResourceRecord) error

+ CreateResourceRecordString func(resourceName, recordStr string) error

+ CreateResourceString func(resourceStr string) error

+ CreateScheduledSQL func(project string, scheduledsql *ScheduledSQL) error

+ DeleteResource func(name string) error

+ DeleteResourceRecord func(resourceName, recordId string) error

+ DeleteScheduledSQL func(project string, name string) error

+ GetResource func(name string) (resource *Resource, err error)

+ GetResourceRecord func(resourceName, recordId string) (record *ResourceRecord, err error)

+ GetResourceRecordString func(resourceName, name string) (record string, err error)

+ GetResourceString func(name string) (resource string, err error)

+ GetScheduledSQL func(project string, name string) (*ScheduledSQL, error)

+ GetScheduledSQLJobInstance func(projectName, jobName, instanceId string, result bool) (instance *ScheduledSQLJobInstance, err error)

+ ListResource func(resourceType string, resourceName string, offset, size int) (resourceList []*Resource, count, total int, err error)

+ ListResourceRecord func(resourceName string, offset, size int) (recordList []*ResourceRecord, count, total int, err error)

+ ListScheduledSQL func(project, name, displayName string, offset, size int) ([]*ScheduledSQL, int, int, error)

+ ListScheduledSQLJobInstances func(projectName, jobName string, status *InstanceStatus) (instances []*ScheduledSQLJobInstance, total, count int64, err error)

+ ModifyScheduledSQLJobInstanceState func(projectName, jobName, instanceId string, state ScheduledSQLState) error

+ UpdateResource func(resource *Resource) error

+ UpdateResourceRecord func(resourceName string, record *ResourceRecord) error

+ UpdateResourceRecordString func(resourceName, recordStr string) error

+ UpdateResourceString func(resourceName, resourceStr string) error

+ UpdateScheduledSQL func(project string, scheduledsql *ScheduledSQL) error

+ type ConditionConfiguration struct

+ Condition string

+ CountCondition string

+ type DataFormat string

+ const LOG_TO_LOG

+ const LOG_TO_METRIC

+ const METRIC_TO_metric

+ type GlobalConfig struct

+ ConfigDetail struct{ ... }

+ ConfigId string

+ ConfigName string

+ type GroupConfiguration struct

+ Fields []string

+ Type string

+ type InstanceStatus struct

+ FromTime int64

+ Offset int64

+ Size int64

+ State ScheduledSQLState

+ ToTime int64

+ type JobType string

+ const ALERT_JOB

+ const AUDIT_JOB_JOB

+ const ETL_JOB

+ const EXPORT_JOB

+ const INGESTION_JOB

+ const REBUILD_INDEX_JOB

+ const REPORT_JOB

+ const SCHEDULED_SQL_JOB

+ type JoinConfiguration struct

+ Condition string

+ Type string

+ type PolicyConfiguration struct

+ ActionPolicyId string

+ AlertPolicyId string

+ RepeatInterval string

+ UseDefault bool

+ type Resource struct

+ CreateTime int64

+ Description string

+ ExtInfo string

+ LastModifyTime int64

+ Name string

+ Schema string

+ Type string

+ type ResourceActionPolicy struct

+ ActionPolicyId string

+ ActionPolicyName string

+ EscalationEnabled bool

+ EscalationInprogressEnabled bool

+ EscalationInprogressTimeout string

+ EscalationStartEnabled bool

+ EscalationStartTimeout string

+ EscalationTimeout string

+ IsDefault bool

+ Labels map[string]string

+ PrimaryPolicyScript string

+ SecondaryPolicyScript string

+ type ResourceAlertPolicy struct

+ GroupPolicy string

+ InhibitPolicy string

+ IsDefault bool

+ Parent string

+ PolicyId string

+ PolicyName string

+ SilencePolicy string

+ type ResourceContentTemplate struct

+ IsDefault bool

+ TemplateId string

+ TemplateName string

+ Templates ResourceTemplates

+ type ResourcePool string

+ const DEFAULT

+ const ENHANCED

+ type ResourceRecord struct

+ CreateTime int64

+ Id string

+ LastModifyTime int64

+ Tag string

+ Value string

+ type ResourceSchema struct

+ Schema []*ResourceSchemaItem

+ func (rs *ResourceSchema) FromJsonString(schema string) error

+ func (rs *ResourceSchema) ToString() string

+ type ResourceSchemaItem struct

+ Column string

+ Desc string

+ ExtInfo interface{}

+ Required bool

+ Type string

+ type ResourceTemplate struct

+ Content string

+ Limit int

+ Locale string

+ SendType string

+ Subject string

+ Title string

+ type ResourceTemplates struct

+ Dingtalk ResourceTemplate

+ Email ResourceTemplate

+ Lark ResourceTemplate

+ MessageCenter ResourceTemplate

+ Slack ResourceTemplate

+ Sms ResourceTemplate

+ Voice ResourceTemplate

+ Webhook ResourceTemplate

+ Wechat ResourceTemplate

+ type ResourceUser struct

+ CountryCode string

+ Email []string

+ Enabled bool

+ Phone string

+ SmsEnabled bool

+ UserId string

+ UserName string

+ VoiceEnabled bool

+ type ResourceUserGroup struct

+ Enabled bool

+ Id string

+ Members []string

+ Name string

+ type ResourceWebhookHeader struct

+ Key string

+ Value string

+ type ScheduledSQL struct

+ Configuration *ScheduledSQLConfiguration

+ CreateTime int64

+ Description string

+ DisplayName string

+ LastModifiedTime int64

+ Name string

+ Schedule *Schedule

+ ScheduleId string

+ Status Status

+ Type JobType

+ type ScheduledSQLConfiguration struct

+ DataFormat DataFormat

+ DestEndpoint string

+ DestLogStore string

+ DestProject string

+ DestRoleArn string

+ FromTime int64

+ FromTimeExpr string

+ MaxRetries int32

+ MaxRunTimeInSeconds int32

+ Parameters *ScheduledSQLParameters

+ ResourcePool ResourcePool

+ RoleArn string

+ Script string

+ SourceLogStore string

+ SqlType SqlType

+ ToTime int64

+ ToTimeExpr string

+ func NewScheduledSQLConfiguration() *ScheduledSQLConfiguration

+ type ScheduledSQLJobInstance struct

+ CreateTimeInMillis int64

+ Description string

+ DisplayName string

+ ErrorCode string

+ ErrorMessage string

+ InstanceId string

+ JobName string

+ JobScheduleId string

+ ScheduleTimeInMillis int64

+ State ScheduledSQLState

+ Summary string

+ UpdateTimeInMillis int64

+ type ScheduledSQLParameters struct

+ AddLabels string

+ HashLabels string

+ LabelKeys string

+ MetricKeys string

+ MetricName string

+ TimeKey string

+ type ScheduledSQLState string

+ const ScheduledSQL_FAILED

+ const ScheduledSQL_RUNNING

+ const ScheduledSQL_SUCCEEDED

+ type Severity int

+ const Critical

+ const High

+ const Low

+ const Medium

+ const Report

+ type SeverityConfiguration struct

+ EvalCondition ConditionConfiguration

+ Severity Severity

+ type SqlType string

+ const SEARCH_QUERY

+ const STANDARD

+ type Status string

+ const DISABLED

+ const ENABLED

+ type Tag struct

+ Key string

+ Value string

+ type TemplateConfiguration struct

+ Annotations map[string]string

+ Id string

+ Lang string

+ Tokens map[string]string

+ Type string

+ Version string

+ type Token struct

+ Default string

+ DisplayName string

+ Hide bool

+ Name string

+ Required bool

+ Type string

type TokenAutoUpdateClient

+ func (c *TokenAutoUpdateClient) CreateResource(resource *Resource) (err error)

+ func (c *TokenAutoUpdateClient) CreateResourceRecord(resourceName string, record *ResourceRecord) (err error)

+ func (c *TokenAutoUpdateClient) CreateResourceRecordString(resourceName, recordStr string) (err error)

+ func (c *TokenAutoUpdateClient) CreateResourceString(resourceStr string) (err error)

+ func (c *TokenAutoUpdateClient) CreateScheduledSQL(project string, scheduledsql *ScheduledSQL) (err error)

+ func (c *TokenAutoUpdateClient) DeleteResource(name string) (err error)

+ func (c *TokenAutoUpdateClient) DeleteResourceRecord(resourceName, recordId string) (err error)

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

+ func (c *TokenAutoUpdateClient) GetResource(name string) (resource *Resource, err error)

+ func (c *TokenAutoUpdateClient) GetResourceRecord(resourceName, recordId string) (record *ResourceRecord, err error)

+ func (c *TokenAutoUpdateClient) GetResourceRecordString(resourceName, name string) (record string, err error)

+ func (c *TokenAutoUpdateClient) GetResourceString(name string) (resource string, err error)

+ func (c *TokenAutoUpdateClient) GetScheduledSQL(project string, name string) (s *ScheduledSQL, err error)

+ func (c *TokenAutoUpdateClient) GetScheduledSQLJobInstance(projectName, jobName, instanceId string, result bool) (instance *ScheduledSQLJobInstance, err error)

+ func (c *TokenAutoUpdateClient) ListResource(resourceType string, resourceName string, offset, size int) (resourceList []*Resource, count, total int, err error)

+ func (c *TokenAutoUpdateClient) ListResourceRecord(resourceName string, offset, size int) (recordList []*ResourceRecord, count, total int, err error)

+ func (c *TokenAutoUpdateClient) ListScheduledSQL(project, name, displayName string, offset, size int) (scheduledsqls []*ScheduledSQL, total, count int, err error)

+ func (c *TokenAutoUpdateClient) ListScheduledSQLJobInstances(projectName, jobName string, status *InstanceStatus) (instances []*ScheduledSQLJobInstance, total, count int64, err error)

+ func (c *TokenAutoUpdateClient) ModifyScheduledSQLJobInstanceState(projectName, jobName, instanceId string, state ScheduledSQLState) (err error)

+ func (c *TokenAutoUpdateClient) UpdateResource(resource *Resource) (err error)

+ func (c *TokenAutoUpdateClient) UpdateResourceRecord(resourceName string, record *ResourceRecord) (err error)

+ func (c *TokenAutoUpdateClient) UpdateResourceRecordString(resourceName, recordStr string) (err error)

+ func (c *TokenAutoUpdateClient) UpdateResourceString(resourceName, resourceStr string) (err error)

+ func (c *TokenAutoUpdateClient) UpdateScheduledSQL(project string, scheduledsql *ScheduledSQL) (err error)

+ type WebhookIntegration struct

+ Headers []*ResourceWebhookHeader

+ Id string

+ Method string

+ Name string

+ Type string

+ Url string

May 18, 2021

Changes in this version

+ type EncryptConf struct

+ Enable bool

+ EncryptType string

+ UserCmkInfo *EncryptUserCmkConf

+ type EncryptUserCmkConf struct

+ Arn string

+ CmkKeyId string

+ RegionId string

type LogStore

+ EncryptConf *EncryptConf

Mar 26, 2021

Changes in this version

+ 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

Feb 28, 2021

Changes in this version

+ const MetricAggRulesPromQL

+ const MetricAggRulesSQL

type Client

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

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

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

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

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

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

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

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

type ClientInterface

+ CreateAlertString func(project string, alert string) error

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

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

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

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

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

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

Jan 11, 2021

Changes in this version

type ClientInterface

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

type TokenAutoUpdateClient

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

Nov 11, 2020

Changes in this version

+ const ETLSinksType

+ const ETLType

+ const ETLVersion

type Client

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

type ClientInterface

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

type ETLSink

+ Type string

+ type GetLogLinesResponse struct

+ Lines []json.RawMessage

type LogStore

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

type TokenAutoUpdateClient

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

Nov 3, 2020

Changes in this version

type Client

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

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

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

+ func (c *Client) ListETL(project string, offset int, size int) (*ListETLResponse, error)

+ func (c *Client) StartETL(project, name string) error

+ func (c *Client) StopETL(project, name string) error

+ func (c *Client) UpdateETL(project string, etljob ETL) 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 ListETLResponse struct

+ Count int

+ Results []*ETL

+ Total int

Oct 26, 2020

Changes in this version

type Notification

+ Headers map[string]string

Oct 15, 2020

Changes in this version

type Client

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

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

type ClientInterface

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

type LogStore

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

type OSSShipperConfig

+ Storage ShipperStorage

+ type OssStorageJsonDetail struct

+ EnableTag bool

+ type ResponseDashboardItem struct

+ DashboardName string

+ DisplayName string

+ type ResponseSavedSearchItem struct

+ DisplayName string

+ SavedSearchName string

+ type ShipperStorage struct

+ Detail interface{}

+ Format string

type TokenAutoUpdateClient

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

Sep 9, 2020

Changes in this version

+ const ScheduleTypeCron

+ const ScheduleTypeDaily

+ const ScheduleTypeDayRun

+ const ScheduleTypeFixedRate

+ const ScheduleTypeHourly

+ const ScheduleTypeResident

+ const ScheduleTypeWeekly

type Alert

+ Status string

type Client

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

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

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

type ClientInterface

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

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

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

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

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

+ 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

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

+ CronExpression string

+ DayOfWeek int32

+ Delay int32

+ Hour int32

type TokenAutoUpdateClient

+ 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) GetCheckpoint(project, logstore string, cgName string) (checkPointList []*ConsumerGroupCheckPoint, 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) 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) 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)

Jun 6, 2020

Changes in this version

type Client

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

+ func (c *Client) DeleteSubStore(project, logstore string, name string) (err 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) ListLogStoreV2(project string, offset, size int, telemetryType string) ([]string, error)

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

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

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

type LogProject

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

type LogStore

+ ArchiveSecons int

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

Apr 13, 2020

Changes in this version

+ const HasSQLHeader

type GetLogsResponse

+ HasSQL bool

type Machine

+ LastHeartBeatTime int

Apr 8, 2020

Changes in this version

+ const LoggingURI

type Client

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

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

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

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

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) UpdateLogging(detail *Logging) (err error)

+ type Logging struct

+ LoggingDetails []*LoggingDetail

+ Project string

+ type LoggingDetail struct

+ Logstore string

+ Type string

Feb 26, 2020

Changes in this version

+ var GlobalDebugLevel = 0

+ var Logger = initDefaultSLSLogger()

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

+ func IsDebugLevelMatched(level int) bool

+ type GetContextLogsResponse struct

+ BackLines int64

+ ForwardLines int64

+ Logs []map[string]string

+ Progress string

+ TotalLines int64

+ func (resp *GetContextLogsResponse) IsComplete() bool

type IndexKey

+ JsonKeys map[string]*JsonKey

+ type JsonKey struct

+ Alias string

+ DocValue bool

+ Type string

type LogProject

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

type LogStore

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

Sep 24, 2019

Changes in this version

+ const GetLogsQueryInfo

+ var RetryOnServerErrorEnabled = true

type Client

+ RequestTimeOut time.Duration

+ RetryTimeOut time.Duration

type GetLogsResponse

+ Contents string

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

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, ...)