Versions in this module Expand all Collapse all v1 v1.7.0 May 28, 2021 v1.6.9 Apr 22, 2021 Changes in this version + var ErrIntOverflowStats = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling") + func CollectTrailer(ctx context.Context) grpc.CallOption + func GetMutex(ctx context.Context) (*sync.Mutex, error) + func JoinResults(ctx context.Context, res Result) error + func NewContext(ctx context.Context) context.Context + func SendAsTrailer(ctx context.Context, stream grpc.ServerStream) + type ChunkData struct + CompressedBytes int64 + DecompressedBytes int64 + DecompressedLines int64 + HeadChunkBytes int64 + HeadChunkLines int64 + TotalDuplicates int64 + func GetChunkData(ctx context.Context) *ChunkData + type Ingester struct + CompressedBytes int64 + DecompressedBytes int64 + DecompressedLines int64 + HeadChunkBytes int64 + HeadChunkLines int64 + TotalBatches int64 + TotalChunksMatched int64 + TotalDuplicates int64 + TotalLinesSent int64 + TotalReached int32 + func (*Ingester) Descriptor() ([]byte, []int) + func (*Ingester) ProtoMessage() + func (m *Ingester) GetCompressedBytes() int64 + func (m *Ingester) GetDecompressedBytes() int64 + func (m *Ingester) GetDecompressedLines() int64 + func (m *Ingester) GetHeadChunkBytes() int64 + func (m *Ingester) GetHeadChunkLines() int64 + func (m *Ingester) GetTotalBatches() int64 + func (m *Ingester) GetTotalChunksMatched() int64 + func (m *Ingester) GetTotalDuplicates() int64 + func (m *Ingester) GetTotalLinesSent() int64 + func (m *Ingester) GetTotalReached() int32 + func (m *Ingester) Marshal() (dAtA []byte, err error) + func (m *Ingester) MarshalTo(dAtA []byte) (int, error) + func (m *Ingester) Reset() + func (m *Ingester) Size() (n int) + func (m *Ingester) Unmarshal(dAtA []byte) error + func (m *Ingester) XXX_DiscardUnknown() + func (m *Ingester) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ingester) XXX_Merge(src proto.Message) + func (m *Ingester) XXX_Size() int + func (m *Ingester) XXX_Unmarshal(b []byte) error + func (this *Ingester) Equal(that interface{}) bool + func (this *Ingester) GoString() string + func (this *Ingester) String() string + type IngesterData struct + TotalBatches int64 + TotalChunksMatched int64 + TotalLinesSent int64 + func GetIngesterData(ctx context.Context) *IngesterData + type Result struct + Ingester Ingester + Store Store + Summary Summary + func GetResult(ctx context.Context) (*Result, error) + func Snapshot(ctx context.Context, execTime time.Duration) Result + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (m *Result) GetIngester() Ingester + func (m *Result) GetStore() Store + func (m *Result) GetSummary() Summary + func (m *Result) Marshal() (dAtA []byte, err error) + func (m *Result) MarshalTo(dAtA []byte) (int, error) + func (m *Result) Reset() + func (m *Result) Size() (n int) + func (m *Result) Unmarshal(dAtA []byte) error + func (m *Result) XXX_DiscardUnknown() + func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Result) XXX_Merge(src proto.Message) + func (m *Result) XXX_Size() int + func (m *Result) XXX_Unmarshal(b []byte) error + func (r *Result) ComputeSummary(execTime time.Duration) + func (r *Result) Merge(m Result) + func (r Result) Log(log log.Logger) + func (this *Result) Equal(that interface{}) bool + func (this *Result) GoString() string + func (this *Result) String() string + type Store struct + ChunksDownloadTime float64 + CompressedBytes int64 + DecompressedBytes int64 + DecompressedLines int64 + HeadChunkBytes int64 + HeadChunkLines int64 + TotalChunksDownloaded int64 + TotalChunksRef int64 + TotalDuplicates int64 + func (*Store) Descriptor() ([]byte, []int) + func (*Store) ProtoMessage() + func (m *Store) GetChunksDownloadTime() float64 + func (m *Store) GetCompressedBytes() int64 + func (m *Store) GetDecompressedBytes() int64 + func (m *Store) GetDecompressedLines() int64 + func (m *Store) GetHeadChunkBytes() int64 + func (m *Store) GetHeadChunkLines() int64 + func (m *Store) GetTotalChunksDownloaded() int64 + func (m *Store) GetTotalChunksRef() int64 + func (m *Store) GetTotalDuplicates() int64 + func (m *Store) Marshal() (dAtA []byte, err error) + func (m *Store) MarshalTo(dAtA []byte) (int, error) + func (m *Store) Reset() + func (m *Store) Size() (n int) + func (m *Store) Unmarshal(dAtA []byte) error + func (m *Store) XXX_DiscardUnknown() + func (m *Store) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Store) XXX_Merge(src proto.Message) + func (m *Store) XXX_Size() int + func (m *Store) XXX_Unmarshal(b []byte) error + func (this *Store) Equal(that interface{}) bool + func (this *Store) GoString() string + func (this *Store) String() string + type StoreData struct + ChunksDownloadTime time.Duration + TotalChunksDownloaded int64 + TotalChunksRef int64 + func GetStoreData(ctx context.Context) *StoreData + type Summary struct + BytesProcessedPerSecond int64 + ExecTime float64 + LinesProcessedPerSecond int64 + TotalBytesProcessed int64 + TotalLinesProcessed int64 + func (*Summary) Descriptor() ([]byte, []int) + func (*Summary) ProtoMessage() + func (m *Summary) GetBytesProcessedPerSecond() int64 + func (m *Summary) GetExecTime() float64 + func (m *Summary) GetLinesProcessedPerSecond() int64 + func (m *Summary) GetTotalBytesProcessed() int64 + func (m *Summary) GetTotalLinesProcessed() int64 + func (m *Summary) Marshal() (dAtA []byte, err error) + func (m *Summary) MarshalTo(dAtA []byte) (int, error) + func (m *Summary) Reset() + func (m *Summary) Size() (n int) + func (m *Summary) Unmarshal(dAtA []byte) error + func (m *Summary) XXX_DiscardUnknown() + func (m *Summary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Summary) XXX_Merge(src proto.Message) + func (m *Summary) XXX_Size() int + func (m *Summary) XXX_Unmarshal(b []byte) error + func (s Summary) Log(log log.Logger) + func (this *Summary) Equal(that interface{}) bool + func (this *Summary) GoString() string + func (this *Summary) String() string