Versions in this module Expand all Collapse all v1 v1.2.0 Feb 29, 2024 Changes in this version + const CONTENT + const Complete + const Count + const Cursor + const DefaultAggLogQueryTimeout + const DefaultChunkSize + const DefaultDebugRequestsInterval + const DefaultInnerChunkSize + const DefaultLogLimit + const DefaultLogQueryTimeout + const DefaultMaxLogStoreAnalyzeResponseNum + const EmptyValue + const ErrParsingQuery + const ErrShardGroupNotFound + const ErrShardNotFound + const ErrSyntax + const Explain + const From + const Group + const Highlight + const Http + const Https + const InComplete + const IncAggLogQueryRetryCount + const IncIterNumCacheSize + const IsOverflow + const IsTruncate + const JSON + const JSONV2 + const Limit + const LogProxy + const LogReqErr + const LogRetryTag + const LogStream + const MaxChunkSize + const MaxDebugRequestsInterval + const MaxInnerChunkSize + const MaxLogLimit + const MaxQueryLen + const MaxRequestBodyLength + const MaxRowLen + const MaxScrollIdLen + const MaxSplitCharLen + const MaxTimeoutMs + const MaxToValue + const MaxTtl + const MinFromValue + const MinLogLimit + const MinScrollIdLen + const MinTimeoutMs + const NewlineLen + const PermanentSaveTtl + const Query + const QueryLogAggResponseEntrySize + const QueryMetaCacheTTL + const Repository + const Reverse + const ScannerBufferSize + const Scroll + const ScrollId + const Select + const Sql + const TAGS + const TIME + const Tag + const TagsSplitterChar + const TimeoutMs + const Timestamp + const To + const UnixTimestampMaxMs + const UnixTimestampMinMs + const XContentLength + var ErrBearerAuthDisabled = errors.New("bearer auth disabld") + var ErrInvalidLogStreamName = errors.New("invalid logstream name") + var ErrInvalidRepoName = errors.New("invalid repository name") + var ErrInvalidWriteNode = errors.New("this data node is not used for writing") + var ErrLogRepoEmpty = errors.New("repository name should not be none") + var ErrLogStreamDeleted = errors.New("logstrem being deleted") + var ErrLogStreamEmpty = errors.New("logstream name should not be none") + var ErrLogStreamInvalid = errors.New("logstrem invalid in retentionPolicy") + var LogMax = 1000 + var QueryAggResultCache = cache.NewCache(IncIterNumCacheSize, QueryMetaCacheTTL) + func ErrorResponse(msg string, errCode string) []byte + func GetGzipReader(r io.Reader) (*gzip.Reader, error) + func GetMSByScrollID(id string) (int64, error) + func IncQuerySkippingError(err error) bool + func NewResponseLogger(w http.ResponseWriter) http.ResponseWriter + func ParseCredentials(r *http.Request) (*credentials, error) + func Points2Rows(points []models.Point) ([]influx.Row, error) + func PutGzipReader(zr *gzip.Reader) + func QuerySkippingError(err string) bool + func ReadRequestToInfluxQuery(req *prompb.ReadRequest) (string, error) + func TagsConverterRemoveInfluxSystemTag(tags map[string]string) models.Tags + func TransYaccSyntaxErr(errorInfo string) string + func ValidateLogStream(streamName string) error + func ValidateRepoAndLogStream(repoName, streamName string) error + func ValidateRepository(repoName string) error + type AuthenticationMethod int + const BearerAuthentication + const UserAuthentication + type Fragment struct + Length int + Offset int + type GzipWriterPool struct + func NewGzipWriterPool() *GzipWriterPool + func (p *GzipWriterPool) Get() *gzip.Writer + func (p *GzipWriterPool) Put(gz *gzip.Writer) + type Handler struct + BuildType string + CLFLogger *zap.Logger + Config *config.Config + ExtSysCtrl interface{ ... } + Logger *logger.Logger + MetaClient interface{ ... } + Monitor interface{} + PointsWriter interface{ ... } + QueryAuthorizer interface{ ... } + QueryExecutor *query2.Executor + RecordWriter interface{ ... } + StatisticsPusher *statisticsPusher.StatisticsPusher + Version string + WriteAuthorizer interface{ ... } + func NewHandler(c config.Config) *Handler + func (h *Handler) AddRoutes(routes ...Route) + func (h *Handler) Close() + func (h *Handler) IsWriteNode() bool + func (h *Handler) Open() + func (h *Handler) ResponseAggLogQuery(w http.ResponseWriter, para *QueryParam, now time.Time, hist []Histograms, ...) (b []byte, finished bool) + func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (h *Handler) ValidateAndCheckLogStreamExists(repoName, streamName string) error + type HighlightFragment struct + Fragment string + Highlight bool + type Histograms struct + Count int64 + From int64 + To int64 + func GenZeroHistogram(opt query2.ProcessorOptions, start, end int64, ascending bool) []Histograms + type JsonMapping struct + type LogDataType uint8 + type LogResponse struct + ErrorCode string + ErrorMsg string + type LogWriteRequest struct + type QueryAggRequest struct + Explain bool + From int64 + IncQuery bool + Query string + Scroll string + Scroll_id string + Sql bool + Timeout int + To int64 + type QueryLogAggResponse struct + Code string + Count int64 + Explain string + Histograms []Histograms + Message string + Progress string + Request_id string + Scroll_id string + Success bool + Took_ms int64 + type QueryLogAggResponseEntry struct + func NewQueryLogAggResponse(query string) *QueryLogAggResponseEntry + func (e *QueryLogAggResponseEntry) GetKey() string + func (e *QueryLogAggResponseEntry) GetTime() time.Time + func (e *QueryLogAggResponseEntry) GetValue() interface{} + func (e *QueryLogAggResponseEntry) SetTime(time time.Time) + func (e *QueryLogAggResponseEntry) SetValue(value interface{}) + func (e *QueryLogAggResponseEntry) Size() int64 + type QueryLogAnalyticsResponse struct + Code string + Count int64 + Dataset [][]string + GroupInfo []string + Message string + Progress string + Request_id string + Scroll_id string + Success bool + Took_ms int64 + type QueryLogRequest struct + Explain bool + From int64 + Highlight bool + IsTruncate bool + Limit int + Query string + Reverse bool + Scroll string + Scroll_id string + Sql bool + Timeout int + To int64 + type QueryLogResponse struct + Code string + Complete_progress float64 + Count int64 + Cursor_time int64 + Explain string + Logs []map[string]interface{} + Message string + Progress string + Request_id string + Scroll_id string + Success bool + Took_ms int64 + type QueryParam struct + Ascending bool + Explain bool + GroupBytInterval time.Duration + Highlight bool + IncQuery bool + IterID int32 + Limit int + Process float64 + Query string + QueryID string + Scroll string + Scroll_id string + SeqID int64 + TimeRange TimeRange + Timeout int + Truncate bool + func NewQueryPara(query string, ascending bool, highlight bool, timeout, limit int, ...) *QueryParam + func NewQueryParam(queryPara interface{}) *QueryParam + type Response struct + Err error + Results []*query.Result + func (r *Response) Error() error + func (r *Response) UnmarshalJSON(b []byte) error + func (r Response) MarshalJSON() ([]byte, error) + type ResponseWriter interface + WriteResponse func(resp Response) (int, error) + func NewResponseWriter(w http.ResponseWriter, r *http.Request) ResponseWriter + type Route struct + Gzipped bool + HandlerFunc interface{} + LoggingEnabled bool + Method string + Name string + Pattern string + type Service struct + Handler *Handler + Ln []net.Listener + Logger *zap.Logger + func NewService(c config.Config) *Service + func (s *Service) Addr() net.Addr + func (s *Service) BoundHTTPAddr() string + func (s *Service) Close() error + func (s *Service) Err() <-chan error + func (s *Service) Open() error + func (s *Service) Openlistener(addr string) error + type SubscriberManager interface + Send func(db, rp string, lineProtocol []byte) + type Throttler struct + EnqueueTimeout time.Duration + Logger *zap.Logger + func NewThrottler(concurrentN, maxEnqueueN int, rateValue int) *Throttler + func (t *Throttler) Handler(h http.Handler) http.Handler + type TimeRange struct