query

Documentation

Overview

Package query is a generated GoMock package.

Index

• Variables
• func NewListIterator(list ...Data) storekit.Iterator
• type Data
• type ListIterator
  • func (it *ListIterator) Close() error
  • func (it *ListIterator) Error() error
  • func (it *ListIterator) First() bool
  • func (it *ListIterator) Last() bool
  • func (it *ListIterator) Next() bool
  • func (it *ListIterator) Prev() bool
  • func (it *ListIterator) Value() Data
• type MockStorage
  • func NewMockStorage(ctrl *gomock.Controller) *MockStorage
  • func (m *MockStorage) Count(ctx context.Context, traceId string) int64
  • func (m *MockStorage) EXPECT() *MockStorageMockRecorder
  • func (m *MockStorage) Iterator(ctx context.Context, sel *storage.Selector) (storekit.Iterator, error)
  • func (m *MockStorage) NewWriter(ctx context.Context) (storekit.BatchWriter, error)
• type MockStorageMockRecorder
  • func (mr *MockStorageMockRecorder) Count(ctx, traceId interface{}) *gomock.Call
  • func (mr *MockStorageMockRecorder) Iterator(ctx, sel interface{}) *gomock.Call
  • func (mr *MockStorageMockRecorder) NewWriter(ctx interface{}) *gomock.Call
• type Spans
  • func (s Spans) Len() int
  • func (s Spans) Less(i, j int) bool
  • func (s Spans) Swap(i, j int)
• type TraceService
  • func (s *TraceService) CreateTraceDebug(ctx context.Context, req *pb.CreateTraceDebugRequest) (*pb.CreateTraceDebugResponse, error)
  • func (s *TraceService) GetSpanCount(ctx context.Context, traceID string) (int64, error)
  • func (s *TraceService) GetSpanDashboards(ctx context.Context, req *pb.GetSpanDashboardsRequest) (*pb.GetSpanDashboardsResponse, error)
  • func (s *TraceService) GetSpanEvents(ctx context.Context, req *pb.SpanEventRequest) (*pb.SpanEventResponse, error)
  • func (s *TraceService) GetSpans(ctx context.Context, req *pb.GetSpansRequest) (*pb.GetSpansResponse, error)
  • func (s *TraceService) GetTraceDebugByRequestID(ctx context.Context, req *pb.GetTraceDebugRequest) (*pb.GetTraceDebugResponse, error)
  • func (s *TraceService) GetTraceDebugHistories(ctx context.Context, req *pb.GetTraceDebugHistoriesRequest) (*pb.GetTraceDebugHistoriesResponse, error)
  • func (s *TraceService) GetTraceDebugHistoryStatusByRequestID(ctx context.Context, req *pb.GetTraceDebugStatusByRequestIDRequest) (*pb.GetTraceDebugStatusByRequestIDResponse, error)
  • func (s *TraceService) GetTraceQueryConditions(ctx context.Context, req *pb.GetTraceQueryConditionsRequest) (*pb.GetTraceQueryConditionsResponse, error)
  • func (s *TraceService) GetTraceReqDistribution(ctx context.Context, model custom.Model) ([]*source.TraceDistributionItem, error)
  • func (s *TraceService) GetTraces(ctx context.Context, req *pb.GetTracesRequest) (*pb.GetTracesResponse, error)
  • func (s *TraceService) GetTracesCount(ctx context.Context, startTime, endTime int64, ...) (int64, error)
  • func (s *TraceService) StopTraceDebug(ctx context.Context, req *pb.StopTraceDebugRequest) (*pb.StopTraceDebugResponse, error)

Variables

var EventFieldSet = set.NewSet("error", "stack", "event", "message", "error_kind", "error_object")

Functions

func NewListIterator

func NewListIterator(list ...Data) storekit.Iterator

NewListIterator .

Types

type Data

type Data = interface{}

Data .

type ListIterator

type ListIterator struct {
	// contains filtered or unexported fields
}

ListIterator .

func (*ListIterator) Close

func (it *ListIterator) Close() error

Close .

func (*ListIterator) Error

func (it *ListIterator) Error() error

Error .

func (*ListIterator) First

func (it *ListIterator) First() bool

First .

func (*ListIterator) Last

func (it *ListIterator) Last() bool

Last .

func (*ListIterator) Next

func (it *ListIterator) Next() bool

Next .

func (*ListIterator) Prev

func (it *ListIterator) Prev() bool

Prev .

func (*ListIterator) Value

func (it *ListIterator) Value() Data

Value .

type MockStorage

type MockStorage struct {
	// contains filtered or unexported fields
}

MockStorage is a mock of Storage interface.

func NewMockStorage

func NewMockStorage(ctrl *gomock.Controller) *MockStorage

NewMockStorage creates a new mock instance.

func (*MockStorage) Count

func (m *MockStorage) Count(ctx context.Context, traceId string) int64

Count mocks base method.

func (*MockStorage) EXPECT

func (m *MockStorage) EXPECT() *MockStorageMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStorage) Iterator

func (m *MockStorage) Iterator(ctx context.Context, sel *storage.Selector) (storekit.Iterator, error)

Iterator mocks base method.

func (*MockStorage) NewWriter

func (m *MockStorage) NewWriter(ctx context.Context) (storekit.BatchWriter, error)

NewWriter mocks base method.

type MockStorageMockRecorder

type MockStorageMockRecorder struct {
	// contains filtered or unexported fields
}

MockStorageMockRecorder is the mock recorder for MockStorage.

func (*MockStorageMockRecorder) Count

func (mr *MockStorageMockRecorder) Count(ctx, traceId interface{}) *gomock.Call

Count indicates an expected call of Count.

func (*MockStorageMockRecorder) Iterator

func (mr *MockStorageMockRecorder) Iterator(ctx, sel interface{}) *gomock.Call

Iterator indicates an expected call of Iterator.

func (*MockStorageMockRecorder) NewWriter

func (mr *MockStorageMockRecorder) NewWriter(ctx interface{}) *gomock.Call

NewWriter indicates an expected call of NewWriter.

type Spans

type Spans []*pb.Span

func (Spans) Len

func (s Spans) Len() int

func (Spans) Less

func (s Spans) Less(i, j int) bool

func (Spans) Swap

func (s Spans) Swap(i, j int)

type TraceService

type TraceService struct {
	Source           source.TraceSource
	CompatibleSource source.TraceSource
	// contains filtered or unexported fields
}

func (*TraceService) CreateTraceDebug

func (s *TraceService) CreateTraceDebug(ctx context.Context, req *pb.CreateTraceDebugRequest) (*pb.CreateTraceDebugResponse, error)

func (*TraceService) GetSpanCount

func (s *TraceService) GetSpanCount(ctx context.Context, traceID string) (int64, error)

func (*TraceService) GetSpanDashboards

func (s *TraceService) GetSpanDashboards(ctx context.Context, req *pb.GetSpanDashboardsRequest) (*pb.GetSpanDashboardsResponse, error)

func (*TraceService) GetSpanEvents

func (s *TraceService) GetSpanEvents(ctx context.Context, req *pb.SpanEventRequest) (*pb.SpanEventResponse, error)

func (*TraceService) GetSpans

func (s *TraceService) GetSpans(ctx context.Context, req *pb.GetSpansRequest) (*pb.GetSpansResponse, error)

func (*TraceService) GetTraceDebugByRequestID

func (s *TraceService) GetTraceDebugByRequestID(ctx context.Context, req *pb.GetTraceDebugRequest) (*pb.GetTraceDebugResponse, error)

func (*TraceService) GetTraceDebugHistories

func (s *TraceService) GetTraceDebugHistories(ctx context.Context, req *pb.GetTraceDebugHistoriesRequest) (*pb.GetTraceDebugHistoriesResponse, error)

func (*TraceService) GetTraceDebugHistoryStatusByRequestID

func (s *TraceService) GetTraceDebugHistoryStatusByRequestID(ctx context.Context, req *pb.GetTraceDebugStatusByRequestIDRequest) (*pb.GetTraceDebugStatusByRequestIDResponse, error)

func (*TraceService) GetTraceQueryConditions

func (s *TraceService) GetTraceQueryConditions(ctx context.Context, req *pb.GetTraceQueryConditionsRequest) (*pb.GetTraceQueryConditionsResponse, error)

func (*TraceService) GetTraceReqDistribution

func (s *TraceService) GetTraceReqDistribution(ctx context.Context, model custom.Model) ([]*source.TraceDistributionItem, error)

func (*TraceService) GetTraces

func (s *TraceService) GetTraces(ctx context.Context, req *pb.GetTracesRequest) (*pb.GetTracesResponse, error)

func (*TraceService) GetTracesCount

func (s *TraceService) GetTracesCount(ctx context.Context, startTime, endTime int64, params map[string]*structpb.Value, statement string) (int64, error)

func (*TraceService) StopTraceDebug

func (s *TraceService) StopTraceDebug(ctx context.Context, req *pb.StopTraceDebugRequest) (*pb.StopTraceDebugResponse, error)