deeppb

package
v0.0.0-...-39c03fc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 5, 2024 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_deep_proto protoreflect.FileDescriptor
View Source 
var IngesterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "deeppb.IngesterService",
	HandlerType: (*IngesterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushBytes",
			Handler:    _IngesterService_PushBytes_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "deep.proto",
}

IngesterService_ServiceDesc is the grpc.ServiceDesc for IngesterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var MetricsGenerator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "deeppb.MetricsGenerator",
	HandlerType: (*MetricsGeneratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushSnapshot",
			Handler:    _MetricsGenerator_PushSnapshot_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "deep.proto",
}

MetricsGenerator_ServiceDesc is the grpc.ServiceDesc for MetricsGenerator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var QuerierService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "deeppb.QuerierService",
	HandlerType: (*QuerierServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FindSnapshotByID",
			Handler:    _QuerierService_FindSnapshotByID_Handler,
		},
		{
			MethodName: "SearchRecent",
			Handler:    _QuerierService_SearchRecent_Handler,
		},
		{
			MethodName: "SearchBlock",
			Handler:    _QuerierService_SearchBlock_Handler,
		},
		{
			MethodName: "SearchTags",
			Handler:    _QuerierService_SearchTags_Handler,
		},
		{
			MethodName: "SearchTagValues",
			Handler:    _QuerierService_SearchTagValues_Handler,
		},
		{
			MethodName: "SearchTagValuesV2",
			Handler:    _QuerierService_SearchTagValuesV2_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "deep.proto",
}

QuerierService_ServiceDesc is the grpc.ServiceDesc for QuerierService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TracepointConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "deeppb.TracepointConfigService",
	HandlerType: (*TracepointConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LoadTracepoints",
			Handler:    _TracepointConfigService_LoadTracepoints_Handler,
		},
		{
			MethodName: "CreateTracepoint",
			Handler:    _TracepointConfigService_CreateTracepoint_Handler,
		},
		{
			MethodName: "DeleteTracepoint",
			Handler:    _TracepointConfigService_DeleteTracepoint_Handler,
		},
		{
			MethodName: "ExecuteDeepQl",
			Handler:    _TracepointConfigService_ExecuteDeepQl_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "deep.proto",
}

TracepointConfigService_ServiceDesc is the grpc.ServiceDesc for TracepointConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterIngesterServiceServer 

func RegisterIngesterServiceServer(s grpc.ServiceRegistrar, srv IngesterServiceServer)

func RegisterMetricsGeneratorServer 

func RegisterMetricsGeneratorServer(s grpc.ServiceRegistrar, srv MetricsGeneratorServer)

func RegisterQuerierServiceServer 

func RegisterQuerierServiceServer(s grpc.ServiceRegistrar, srv QuerierServiceServer)

func RegisterTracepointConfigServiceServer 

func RegisterTracepointConfigServiceServer(s grpc.ServiceRegistrar, srv TracepointConfigServiceServer)

Types

type CreateTracepointRequest 

type CreateTracepointRequest struct {
	Tracepoint *v1.TracePointConfig `protobuf:"bytes,1,opt,name=tracepoint,proto3" json:"tracepoint,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTracepointRequest) Descriptor deprecated 

func (*CreateTracepointRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTracepointRequest.ProtoReflect.Descriptor instead.

func (*CreateTracepointRequest) GetTracepoint 

func (x *CreateTracepointRequest) GetTracepoint() *v1.TracePointConfig

func (*CreateTracepointRequest) ProtoMessage 

func (*CreateTracepointRequest) ProtoMessage()

func (*CreateTracepointRequest) ProtoReflect 

func (x *CreateTracepointRequest) ProtoReflect() protoreflect.Message

func (*CreateTracepointRequest) Reset 

func (x *CreateTracepointRequest) Reset()

func (*CreateTracepointRequest) String 

func (x *CreateTracepointRequest) String() string

type CreateTracepointResponse 

type CreateTracepointResponse struct {
	Created *v1.TracePointConfig `protobuf:"bytes,1,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTracepointResponse) Descriptor deprecated 

func (*CreateTracepointResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateTracepointResponse.ProtoReflect.Descriptor instead.

func (*CreateTracepointResponse) GetCreated 

func (x *CreateTracepointResponse) GetCreated() *v1.TracePointConfig

func (*CreateTracepointResponse) ProtoMessage 

func (*CreateTracepointResponse) ProtoMessage()

func (*CreateTracepointResponse) ProtoReflect 

func (x *CreateTracepointResponse) ProtoReflect() protoreflect.Message

func (*CreateTracepointResponse) Reset 

func (x *CreateTracepointResponse) Reset()

func (*CreateTracepointResponse) String 

func (x *CreateTracepointResponse) String() string

type DeepQlRequest 

type DeepQlRequest struct {
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*DeepQlRequest) Descriptor deprecated 

func (*DeepQlRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeepQlRequest.ProtoReflect.Descriptor instead.

func (*DeepQlRequest) GetQuery 

func (x *DeepQlRequest) GetQuery() string

func (*DeepQlRequest) ProtoMessage 

func (*DeepQlRequest) ProtoMessage()

func (*DeepQlRequest) ProtoReflect 

func (x *DeepQlRequest) ProtoReflect() protoreflect.Message

func (*DeepQlRequest) Reset 

func (x *DeepQlRequest) Reset()

func (*DeepQlRequest) String 

func (x *DeepQlRequest) String() string

type DeepQlResponse 

type DeepQlResponse struct {
	All      []*v1.TracePointConfig `protobuf:"bytes,1,rep,name=all,proto3" json:"all,omitempty"`
	Affected []*v1.TracePointConfig `protobuf:"bytes,2,rep,name=affected,proto3" json:"affected,omitempty"`
	Type     string                 `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DeepQlResponse) Descriptor deprecated 

func (*DeepQlResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeepQlResponse.ProtoReflect.Descriptor instead.

func (*DeepQlResponse) GetAffected 

func (x *DeepQlResponse) GetAffected() []*v1.TracePointConfig

func (*DeepQlResponse) GetAll 

func (x *DeepQlResponse) GetAll() []*v1.TracePointConfig

func (*DeepQlResponse) GetType 

func (x *DeepQlResponse) GetType() string

func (*DeepQlResponse) ProtoMessage 

func (*DeepQlResponse) ProtoMessage()

func (*DeepQlResponse) ProtoReflect 

func (x *DeepQlResponse) ProtoReflect() protoreflect.Message

func (*DeepQlResponse) Reset 

func (x *DeepQlResponse) Reset()

func (*DeepQlResponse) String 

func (x *DeepQlResponse) String() string

type DeleteTracepointRequest 

type DeleteTracepointRequest struct {
	TracepointID string `protobuf:"bytes,1,opt,name=tracepointID,proto3" json:"tracepointID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTracepointRequest) Descriptor deprecated 

func (*DeleteTracepointRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTracepointRequest.ProtoReflect.Descriptor instead.

func (*DeleteTracepointRequest) GetTracepointID 

func (x *DeleteTracepointRequest) GetTracepointID() string

func (*DeleteTracepointRequest) ProtoMessage 

func (*DeleteTracepointRequest) ProtoMessage()

func (*DeleteTracepointRequest) ProtoReflect 

func (x *DeleteTracepointRequest) ProtoReflect() protoreflect.Message

func (*DeleteTracepointRequest) Reset 

func (x *DeleteTracepointRequest) Reset()

func (*DeleteTracepointRequest) String 

func (x *DeleteTracepointRequest) String() string

type DeleteTracepointResponse 

type DeleteTracepointResponse struct {
	Deleted *v1.TracePointConfig `protobuf:"bytes,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTracepointResponse) Descriptor deprecated 

func (*DeleteTracepointResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTracepointResponse.ProtoReflect.Descriptor instead.

func (*DeleteTracepointResponse) GetDeleted 

func (x *DeleteTracepointResponse) GetDeleted() *v1.TracePointConfig

func (*DeleteTracepointResponse) ProtoMessage 

func (*DeleteTracepointResponse) ProtoMessage()

func (*DeleteTracepointResponse) ProtoReflect 

func (x *DeleteTracepointResponse) ProtoReflect() protoreflect.Message

func (*DeleteTracepointResponse) Reset 

func (x *DeleteTracepointResponse) Reset()

func (*DeleteTracepointResponse) String 

func (x *DeleteTracepointResponse) String() string

type IngesterServiceClient 

type IngesterServiceClient interface {
	PushBytes(ctx context.Context, in *PushBytesRequest, opts ...grpc.CallOption) (*PushBytesResponse, error)
}

IngesterServiceClient is the client API for IngesterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIngesterServiceClient 

func NewIngesterServiceClient(cc grpc.ClientConnInterface) IngesterServiceClient

type IngesterServiceServer 

type IngesterServiceServer interface {
	PushBytes(context.Context, *PushBytesRequest) (*PushBytesResponse, error)
	// contains filtered or unexported methods
}

IngesterServiceServer is the server API for IngesterService service. All implementations must embed UnimplementedIngesterServiceServer for forward compatibility

type LoadTracepointRequest 

type LoadTracepointRequest struct {
	Request *v11.PollRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadTracepointRequest) Descriptor deprecated 

func (*LoadTracepointRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadTracepointRequest.ProtoReflect.Descriptor instead.

func (*LoadTracepointRequest) GetRequest 

func (x *LoadTracepointRequest) GetRequest() *v11.PollRequest

func (*LoadTracepointRequest) ProtoMessage 

func (*LoadTracepointRequest) ProtoMessage()

func (*LoadTracepointRequest) ProtoReflect 

func (x *LoadTracepointRequest) ProtoReflect() protoreflect.Message

func (*LoadTracepointRequest) Reset 

func (x *LoadTracepointRequest) Reset()

func (*LoadTracepointRequest) String 

func (x *LoadTracepointRequest) String() string

type LoadTracepointResponse 

type LoadTracepointResponse struct {
	Response *v11.PollResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadTracepointResponse) Descriptor deprecated 

func (*LoadTracepointResponse) Descriptor() ([]byte, []int)

Deprecated: Use LoadTracepointResponse.ProtoReflect.Descriptor instead.

func (*LoadTracepointResponse) GetResponse 

func (x *LoadTracepointResponse) GetResponse() *v11.PollResponse

func (*LoadTracepointResponse) ProtoMessage 

func (*LoadTracepointResponse) ProtoMessage()

func (*LoadTracepointResponse) ProtoReflect 

func (x *LoadTracepointResponse) ProtoReflect() protoreflect.Message

func (*LoadTracepointResponse) Reset 

func (x *LoadTracepointResponse) Reset()

func (*LoadTracepointResponse) String 

func (x *LoadTracepointResponse) String() string

type MetricsGeneratorClient 

type MetricsGeneratorClient interface {
	PushSnapshot(ctx context.Context, in *PushSnapshotRequest, opts ...grpc.CallOption) (*PushSnapshotResponse, error)
}

MetricsGeneratorClient is the client API for MetricsGenerator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMetricsGeneratorClient 

func NewMetricsGeneratorClient(cc grpc.ClientConnInterface) MetricsGeneratorClient

type MetricsGeneratorServer 

type MetricsGeneratorServer interface {
	PushSnapshot(context.Context, *PushSnapshotRequest) (*PushSnapshotResponse, error)
	// contains filtered or unexported methods
}

MetricsGeneratorServer is the server API for MetricsGenerator service. All implementations must embed UnimplementedMetricsGeneratorServer for forward compatibility

type PushBytesRequest 

type PushBytesRequest struct {
	Snapshot []byte `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	ID       []byte `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBytesRequest) Descriptor deprecated 

func (*PushBytesRequest) Descriptor() ([]byte, []int)

Deprecated: Use PushBytesRequest.ProtoReflect.Descriptor instead.

func (*PushBytesRequest) GetID 

func (x *PushBytesRequest) GetID() []byte

func (*PushBytesRequest) GetSnapshot 

func (x *PushBytesRequest) GetSnapshot() []byte

func (*PushBytesRequest) ProtoMessage 

func (*PushBytesRequest) ProtoMessage()

func (*PushBytesRequest) ProtoReflect 

func (x *PushBytesRequest) ProtoReflect() protoreflect.Message

func (*PushBytesRequest) Reset 

func (x *PushBytesRequest) Reset()

func (*PushBytesRequest) String 

func (x *PushBytesRequest) String() string

type PushBytesResponse 

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

func (*PushBytesResponse) Descriptor deprecated 

func (*PushBytesResponse) Descriptor() ([]byte, []int)

Deprecated: Use PushBytesResponse.ProtoReflect.Descriptor instead.

func (*PushBytesResponse) ProtoMessage 

func (*PushBytesResponse) ProtoMessage()

func (*PushBytesResponse) ProtoReflect 

func (x *PushBytesResponse) ProtoReflect() protoreflect.Message

func (*PushBytesResponse) Reset 

func (x *PushBytesResponse) Reset()

func (*PushBytesResponse) String 

func (x *PushBytesResponse) String() string

type PushSnapshotRequest 

type PushSnapshotRequest struct {
	Snapshot *v1.Snapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*PushSnapshotRequest) Descriptor deprecated 

func (*PushSnapshotRequest) Descriptor() ([]byte, []int)

Deprecated: Use PushSnapshotRequest.ProtoReflect.Descriptor instead.

func (*PushSnapshotRequest) GetSnapshot 

func (x *PushSnapshotRequest) GetSnapshot() *v1.Snapshot

func (*PushSnapshotRequest) ProtoMessage 

func (*PushSnapshotRequest) ProtoMessage()

func (*PushSnapshotRequest) ProtoReflect 

func (x *PushSnapshotRequest) ProtoReflect() protoreflect.Message

func (*PushSnapshotRequest) Reset 

func (x *PushSnapshotRequest) Reset()

func (*PushSnapshotRequest) String 

func (x *PushSnapshotRequest) String() string

type PushSnapshotResponse 

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

Write

func (*PushSnapshotResponse) Descriptor deprecated 

func (*PushSnapshotResponse) Descriptor() ([]byte, []int)

Deprecated: Use PushSnapshotResponse.ProtoReflect.Descriptor instead.

func (*PushSnapshotResponse) ProtoMessage 

func (*PushSnapshotResponse) ProtoMessage()

func (*PushSnapshotResponse) ProtoReflect 

func (x *PushSnapshotResponse) ProtoReflect() protoreflect.Message

func (*PushSnapshotResponse) Reset 

func (x *PushSnapshotResponse) Reset()

func (*PushSnapshotResponse) String 

func (x *PushSnapshotResponse) String() string

type QuerierServiceClient 

type QuerierServiceClient interface {
	FindSnapshotByID(ctx context.Context, in *SnapshotByIDRequest, opts ...grpc.CallOption) (*SnapshotByIDResponse, error)
	SearchRecent(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	SearchBlock(ctx context.Context, in *SearchBlockRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	SearchTags(ctx context.Context, in *SearchTagsRequest, opts ...grpc.CallOption) (*SearchTagsResponse, error)
	SearchTagValues(ctx context.Context, in *SearchTagValuesRequest, opts ...grpc.CallOption) (*SearchTagValuesResponse, error)
	SearchTagValuesV2(ctx context.Context, in *SearchTagValuesRequest, opts ...grpc.CallOption) (*SearchTagValuesV2Response, error)
}

QuerierServiceClient is the client API for QuerierService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQuerierServiceClient 

func NewQuerierServiceClient(cc grpc.ClientConnInterface) QuerierServiceClient

type QuerierServiceServer 

type QuerierServiceServer interface {
	FindSnapshotByID(context.Context, *SnapshotByIDRequest) (*SnapshotByIDResponse, error)
	SearchRecent(context.Context, *SearchRequest) (*SearchResponse, error)
	SearchBlock(context.Context, *SearchBlockRequest) (*SearchResponse, error)
	SearchTags(context.Context, *SearchTagsRequest) (*SearchTagsResponse, error)
	SearchTagValues(context.Context, *SearchTagValuesRequest) (*SearchTagValuesResponse, error)
	SearchTagValuesV2(context.Context, *SearchTagValuesRequest) (*SearchTagValuesV2Response, error)
	// contains filtered or unexported methods
}

QuerierServiceServer is the server API for QuerierService service. All implementations must embed UnimplementedQuerierServiceServer for forward compatibility

type SearchBlockRequest 

type SearchBlockRequest struct {
	SearchReq     *SearchRequest `protobuf:"bytes,1,opt,name=searchReq,proto3" json:"searchReq,omitempty"`
	BlockID       string         `protobuf:"bytes,2,opt,name=blockID,proto3" json:"blockID,omitempty"`
	StartPage     uint32         `protobuf:"varint,3,opt,name=startPage,proto3" json:"startPage,omitempty"`
	PagesToSearch uint32         `protobuf:"varint,4,opt,name=pagesToSearch,proto3" json:"pagesToSearch,omitempty"`
	Encoding      string         `protobuf:"bytes,5,opt,name=encoding,proto3" json:"encoding,omitempty"`
	IndexPageSize uint32         `protobuf:"varint,6,opt,name=indexPageSize,proto3" json:"indexPageSize,omitempty"`
	TotalRecords  uint32         `protobuf:"varint,7,opt,name=totalRecords,proto3" json:"totalRecords,omitempty"`
	DataEncoding  string         `protobuf:"bytes,8,opt,name=dataEncoding,proto3" json:"dataEncoding,omitempty"`
	Version       string         `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	Size          uint64         `protobuf:"varint,10,opt,name=size,proto3" json:"size,omitempty"`             // total size of data file
	FooterSize    uint32         `protobuf:"varint,11,opt,name=footerSize,proto3" json:"footerSize,omitempty"` // size of file footer (parquet)
	// contains filtered or unexported fields
}

SearchBlockRequest takes SearchRequest parameters as well as all information necessary to search a block in the backend.

func (*SearchBlockRequest) Descriptor deprecated 

func (*SearchBlockRequest) Descriptor() ([]byte, []int)

Deprecated: Use SearchBlockRequest.ProtoReflect.Descriptor instead.

func (*SearchBlockRequest) GetBlockID 

func (x *SearchBlockRequest) GetBlockID() string

func (*SearchBlockRequest) GetDataEncoding 

func (x *SearchBlockRequest) GetDataEncoding() string

func (*SearchBlockRequest) GetEncoding 

func (x *SearchBlockRequest) GetEncoding() string

func (*SearchBlockRequest) GetFooterSize 

func (x *SearchBlockRequest) GetFooterSize() uint32

func (*SearchBlockRequest) GetIndexPageSize 

func (x *SearchBlockRequest) GetIndexPageSize() uint32

func (*SearchBlockRequest) GetPagesToSearch 

func (x *SearchBlockRequest) GetPagesToSearch() uint32

func (*SearchBlockRequest) GetSearchReq 

func (x *SearchBlockRequest) GetSearchReq() *SearchRequest

func (*SearchBlockRequest) GetSize 

func (x *SearchBlockRequest) GetSize() uint64

func (*SearchBlockRequest) GetStartPage 

func (x *SearchBlockRequest) GetStartPage() uint32

func (*SearchBlockRequest) GetTotalRecords 

func (x *SearchBlockRequest) GetTotalRecords() uint32

func (*SearchBlockRequest) GetVersion 

func (x *SearchBlockRequest) GetVersion() string

func (*SearchBlockRequest) ProtoMessage 

func (*SearchBlockRequest) ProtoMessage()

func (*SearchBlockRequest) ProtoReflect 

func (x *SearchBlockRequest) ProtoReflect() protoreflect.Message

func (*SearchBlockRequest) Reset 

func (x *SearchBlockRequest) Reset()

func (*SearchBlockRequest) String 

func (x *SearchBlockRequest) String() string

type SearchMetrics 

type SearchMetrics struct {
	InspectedSnapshots uint32 `protobuf:"varint,1,opt,name=inspectedSnapshots,proto3" json:"inspectedSnapshots,omitempty"`
	InspectedBytes     uint64 `protobuf:"varint,2,opt,name=inspectedBytes,proto3" json:"inspectedBytes,omitempty"`
	InspectedBlocks    uint32 `protobuf:"varint,3,opt,name=inspectedBlocks,proto3" json:"inspectedBlocks,omitempty"`
	SkippedBlocks      uint32 `protobuf:"varint,4,opt,name=skippedBlocks,proto3" json:"skippedBlocks,omitempty"`
	SkippedSnapshots   uint32 `protobuf:"varint,5,opt,name=skippedSnapshots,proto3" json:"skippedSnapshots,omitempty"`
	TotalBlockBytes    uint64 `protobuf:"varint,6,opt,name=totalBlockBytes,proto3" json:"totalBlockBytes,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchMetrics) Descriptor deprecated 

func (*SearchMetrics) Descriptor() ([]byte, []int)

Deprecated: Use SearchMetrics.ProtoReflect.Descriptor instead.

func (*SearchMetrics) GetInspectedBlocks 

func (x *SearchMetrics) GetInspectedBlocks() uint32

func (*SearchMetrics) GetInspectedBytes 

func (x *SearchMetrics) GetInspectedBytes() uint64

func (*SearchMetrics) GetInspectedSnapshots 

func (x *SearchMetrics) GetInspectedSnapshots() uint32

func (*SearchMetrics) GetSkippedBlocks 

func (x *SearchMetrics) GetSkippedBlocks() uint32

func (*SearchMetrics) GetSkippedSnapshots 

func (x *SearchMetrics) GetSkippedSnapshots() uint32

func (*SearchMetrics) GetTotalBlockBytes 

func (x *SearchMetrics) GetTotalBlockBytes() uint64

func (*SearchMetrics) ProtoMessage 

func (*SearchMetrics) ProtoMessage()

func (*SearchMetrics) ProtoReflect 

func (x *SearchMetrics) ProtoReflect() protoreflect.Message

func (*SearchMetrics) Reset 

func (x *SearchMetrics) Reset()

func (*SearchMetrics) String 

func (x *SearchMetrics) String() string

type SearchRequest 

type SearchRequest struct {

	// case insensitive partial match
	Tags          map[string]string `` /* 149-byte string literal not displayed */
	MinDurationMs uint32            `protobuf:"varint,2,opt,name=MinDurationMs,proto3" json:"MinDurationMs,omitempty"`
	MaxDurationMs uint32            `protobuf:"varint,3,opt,name=MaxDurationMs,proto3" json:"MaxDurationMs,omitempty"`
	Limit         uint32            `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	Start         uint32            `protobuf:"varint,5,opt,name=start,proto3" json:"start,omitempty"`
	End           uint32            `protobuf:"varint,6,opt,name=end,proto3" json:"end,omitempty"`
	// DeepQL query
	Query string `protobuf:"bytes,8,opt,name=Query,proto3" json:"Query,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

func (*SearchRequest) Descriptor() ([]byte, []int)

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetEnd 

func (x *SearchRequest) GetEnd() uint32

func (*SearchRequest) GetLimit 

func (x *SearchRequest) GetLimit() uint32

func (*SearchRequest) GetMaxDurationMs 

func (x *SearchRequest) GetMaxDurationMs() uint32

func (*SearchRequest) GetMinDurationMs 

func (x *SearchRequest) GetMinDurationMs() uint32

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) GetStart 

func (x *SearchRequest) GetStart() uint32

func (*SearchRequest) GetTags 

func (x *SearchRequest) GetTags() map[string]string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

func (x *SearchRequest) ProtoReflect() protoreflect.Message

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SearchResponse 

type SearchResponse struct {
	Snapshots []*SnapshotSearchMetadata `protobuf:"bytes,1,rep,name=snapshots,proto3" json:"snapshots,omitempty"`
	Metrics   *SearchMetrics            `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse) Descriptor deprecated 

func (*SearchResponse) Descriptor() ([]byte, []int)

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetMetrics 

func (x *SearchResponse) GetMetrics() *SearchMetrics

func (*SearchResponse) GetSnapshots 

func (x *SearchResponse) GetSnapshots() []*SnapshotSearchMetadata

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

func (x *SearchResponse) ProtoReflect() protoreflect.Message

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) String 

func (x *SearchResponse) String() string

type SearchTagValuesRequest 

type SearchTagValuesRequest struct {
	TagName string `protobuf:"bytes,1,opt,name=tagName,proto3" json:"tagName,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagValuesRequest) Descriptor deprecated 

func (*SearchTagValuesRequest) Descriptor() ([]byte, []int)

Deprecated: Use SearchTagValuesRequest.ProtoReflect.Descriptor instead.

func (*SearchTagValuesRequest) GetTagName 

func (x *SearchTagValuesRequest) GetTagName() string

func (*SearchTagValuesRequest) ProtoMessage 

func (*SearchTagValuesRequest) ProtoMessage()

func (*SearchTagValuesRequest) ProtoReflect 

func (x *SearchTagValuesRequest) ProtoReflect() protoreflect.Message

func (*SearchTagValuesRequest) Reset 

func (x *SearchTagValuesRequest) Reset()

func (*SearchTagValuesRequest) String 

func (x *SearchTagValuesRequest) String() string

type SearchTagValuesResponse 

type SearchTagValuesResponse struct {
	TagValues []string `protobuf:"bytes,1,rep,name=tagValues,proto3" json:"tagValues,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagValuesResponse) Descriptor deprecated 

func (*SearchTagValuesResponse) Descriptor() ([]byte, []int)

Deprecated: Use SearchTagValuesResponse.ProtoReflect.Descriptor instead.

func (*SearchTagValuesResponse) GetTagValues 

func (x *SearchTagValuesResponse) GetTagValues() []string

func (*SearchTagValuesResponse) ProtoMessage 

func (*SearchTagValuesResponse) ProtoMessage()

func (*SearchTagValuesResponse) ProtoReflect 

func (x *SearchTagValuesResponse) ProtoReflect() protoreflect.Message

func (*SearchTagValuesResponse) Reset 

func (x *SearchTagValuesResponse) Reset()

func (*SearchTagValuesResponse) String 

func (x *SearchTagValuesResponse) String() string

type SearchTagValuesV2Response 

type SearchTagValuesV2Response struct {
	TagValues []*TagValue `protobuf:"bytes,1,rep,name=tagValues,proto3" json:"tagValues,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagValuesV2Response) Descriptor deprecated 

func (*SearchTagValuesV2Response) Descriptor() ([]byte, []int)

Deprecated: Use SearchTagValuesV2Response.ProtoReflect.Descriptor instead.

func (*SearchTagValuesV2Response) GetTagValues 

func (x *SearchTagValuesV2Response) GetTagValues() []*TagValue

func (*SearchTagValuesV2Response) ProtoMessage 

func (*SearchTagValuesV2Response) ProtoMessage()

func (*SearchTagValuesV2Response) ProtoReflect 

func (x *SearchTagValuesV2Response) ProtoReflect() protoreflect.Message

func (*SearchTagValuesV2Response) Reset 

func (x *SearchTagValuesV2Response) Reset()

func (*SearchTagValuesV2Response) String 

func (x *SearchTagValuesV2Response) String() string

type SearchTagsRequest 

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

func (*SearchTagsRequest) Descriptor deprecated 

func (*SearchTagsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SearchTagsRequest.ProtoReflect.Descriptor instead.

func (*SearchTagsRequest) ProtoMessage 

func (*SearchTagsRequest) ProtoMessage()

func (*SearchTagsRequest) ProtoReflect 

func (x *SearchTagsRequest) ProtoReflect() protoreflect.Message

func (*SearchTagsRequest) Reset 

func (x *SearchTagsRequest) Reset()

func (*SearchTagsRequest) String 

func (x *SearchTagsRequest) String() string

type SearchTagsResponse 

type SearchTagsResponse struct {
	TagNames []string `protobuf:"bytes,1,rep,name=tagNames,proto3" json:"tagNames,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchTagsResponse) Descriptor deprecated 

func (*SearchTagsResponse) Descriptor() ([]byte, []int)

Deprecated: Use SearchTagsResponse.ProtoReflect.Descriptor instead.

func (*SearchTagsResponse) GetTagNames 

func (x *SearchTagsResponse) GetTagNames() []string

func (*SearchTagsResponse) ProtoMessage 

func (*SearchTagsResponse) ProtoMessage()

func (*SearchTagsResponse) ProtoReflect 

func (x *SearchTagsResponse) ProtoReflect() protoreflect.Message

func (*SearchTagsResponse) Reset 

func (x *SearchTagsResponse) Reset()

func (*SearchTagsResponse) String 

func (x *SearchTagsResponse) String() string

type SnapshotByIDMetrics 

type SnapshotByIDMetrics struct {
	FailedBlocks uint32 `protobuf:"varint,1,opt,name=failedBlocks,proto3" json:"failedBlocks,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotByIDMetrics) Descriptor deprecated 

func (*SnapshotByIDMetrics) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotByIDMetrics.ProtoReflect.Descriptor instead.

func (*SnapshotByIDMetrics) GetFailedBlocks 

func (x *SnapshotByIDMetrics) GetFailedBlocks() uint32

func (*SnapshotByIDMetrics) ProtoMessage 

func (*SnapshotByIDMetrics) ProtoMessage()

func (*SnapshotByIDMetrics) ProtoReflect 

func (x *SnapshotByIDMetrics) ProtoReflect() protoreflect.Message

func (*SnapshotByIDMetrics) Reset 

func (x *SnapshotByIDMetrics) Reset()

func (*SnapshotByIDMetrics) String 

func (x *SnapshotByIDMetrics) String() string

type SnapshotByIDRequest 

type SnapshotByIDRequest struct {
	ID         []byte `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	BlockStart string `protobuf:"bytes,2,opt,name=blockStart,proto3" json:"blockStart,omitempty"`
	BlockEnd   string `protobuf:"bytes,3,opt,name=blockEnd,proto3" json:"blockEnd,omitempty"`
	QueryMode  string `protobuf:"bytes,5,opt,name=queryMode,proto3" json:"queryMode,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotByIDRequest) Descriptor deprecated 

func (*SnapshotByIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotByIDRequest.ProtoReflect.Descriptor instead.

func (*SnapshotByIDRequest) GetBlockEnd 

func (x *SnapshotByIDRequest) GetBlockEnd() string

func (*SnapshotByIDRequest) GetBlockStart 

func (x *SnapshotByIDRequest) GetBlockStart() string

func (*SnapshotByIDRequest) GetID 

func (x *SnapshotByIDRequest) GetID() []byte

func (*SnapshotByIDRequest) GetQueryMode 

func (x *SnapshotByIDRequest) GetQueryMode() string

func (*SnapshotByIDRequest) ProtoMessage 

func (*SnapshotByIDRequest) ProtoMessage()

func (*SnapshotByIDRequest) ProtoReflect 

func (x *SnapshotByIDRequest) ProtoReflect() protoreflect.Message

func (*SnapshotByIDRequest) Reset 

func (x *SnapshotByIDRequest) Reset()

func (*SnapshotByIDRequest) String 

func (x *SnapshotByIDRequest) String() string

type SnapshotByIDResponse 

type SnapshotByIDResponse struct {
	Snapshot *v1.Snapshot         `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	Metrics  *SnapshotByIDMetrics `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotByIDResponse) Descriptor deprecated 

func (*SnapshotByIDResponse) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotByIDResponse.ProtoReflect.Descriptor instead.

func (*SnapshotByIDResponse) GetMetrics 

func (x *SnapshotByIDResponse) GetMetrics() *SnapshotByIDMetrics

func (*SnapshotByIDResponse) GetSnapshot 

func (x *SnapshotByIDResponse) GetSnapshot() *v1.Snapshot

func (*SnapshotByIDResponse) ProtoMessage 

func (*SnapshotByIDResponse) ProtoMessage()

func (*SnapshotByIDResponse) ProtoReflect 

func (x *SnapshotByIDResponse) ProtoReflect() protoreflect.Message

func (*SnapshotByIDResponse) Reset 

func (x *SnapshotByIDResponse) Reset()

func (*SnapshotByIDResponse) String 

func (x *SnapshotByIDResponse) String() string

type SnapshotSearchMetadata 

type SnapshotSearchMetadata struct {
	SnapshotID        string `protobuf:"bytes,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"`
	ServiceName       string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	FilePath          string `protobuf:"bytes,3,opt,name=filePath,proto3" json:"filePath,omitempty"`
	LineNo            uint32 `protobuf:"varint,4,opt,name=lineNo,proto3" json:"lineNo,omitempty"`
	StartTimeUnixNano uint64 `protobuf:"varint,5,opt,name=startTimeUnixNano,proto3" json:"startTimeUnixNano,omitempty"`
	DurationNano      uint64 `protobuf:"varint,6,opt,name=durationNano,proto3" json:"durationNano,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotSearchMetadata) Descriptor deprecated 

func (*SnapshotSearchMetadata) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotSearchMetadata.ProtoReflect.Descriptor instead.

func (*SnapshotSearchMetadata) GetDurationNano 

func (x *SnapshotSearchMetadata) GetDurationNano() uint64

func (*SnapshotSearchMetadata) GetFilePath 

func (x *SnapshotSearchMetadata) GetFilePath() string

func (*SnapshotSearchMetadata) GetLineNo 

func (x *SnapshotSearchMetadata) GetLineNo() uint32

func (*SnapshotSearchMetadata) GetServiceName 

func (x *SnapshotSearchMetadata) GetServiceName() string

func (*SnapshotSearchMetadata) GetSnapshotID 

func (x *SnapshotSearchMetadata) GetSnapshotID() string

func (*SnapshotSearchMetadata) GetStartTimeUnixNano 

func (x *SnapshotSearchMetadata) GetStartTimeUnixNano() uint64

func (*SnapshotSearchMetadata) ProtoMessage 

func (*SnapshotSearchMetadata) ProtoMessage()

func (*SnapshotSearchMetadata) ProtoReflect 

func (x *SnapshotSearchMetadata) ProtoReflect() protoreflect.Message

func (*SnapshotSearchMetadata) Reset 

func (x *SnapshotSearchMetadata) Reset()

func (*SnapshotSearchMetadata) String 

func (x *SnapshotSearchMetadata) String() string

type TagValue 

type TagValue struct {
	Type  string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TagValue) Descriptor deprecated 

func (*TagValue) Descriptor() ([]byte, []int)

Deprecated: Use TagValue.ProtoReflect.Descriptor instead.

func (*TagValue) GetType 

func (x *TagValue) GetType() string

func (*TagValue) GetValue 

func (x *TagValue) GetValue() string

func (*TagValue) ProtoMessage 

func (*TagValue) ProtoMessage()

func (*TagValue) ProtoReflect 

func (x *TagValue) ProtoReflect() protoreflect.Message

func (*TagValue) Reset 

func (x *TagValue) Reset()

func (*TagValue) String 

func (x *TagValue) String() string

type TracepointConfigServiceClient 

type TracepointConfigServiceClient interface {
	LoadTracepoints(ctx context.Context, in *LoadTracepointRequest, opts ...grpc.CallOption) (*LoadTracepointResponse, error)
	CreateTracepoint(ctx context.Context, in *CreateTracepointRequest, opts ...grpc.CallOption) (*CreateTracepointResponse, error)
	DeleteTracepoint(ctx context.Context, in *DeleteTracepointRequest, opts ...grpc.CallOption) (*DeleteTracepointResponse, error)
	ExecuteDeepQl(ctx context.Context, in *DeepQlRequest, opts ...grpc.CallOption) (*DeepQlResponse, error)
}

TracepointConfigServiceClient is the client API for TracepointConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTracepointConfigServiceClient 

func NewTracepointConfigServiceClient(cc grpc.ClientConnInterface) TracepointConfigServiceClient

type TracepointConfigServiceServer 

type TracepointConfigServiceServer interface {
	LoadTracepoints(context.Context, *LoadTracepointRequest) (*LoadTracepointResponse, error)
	CreateTracepoint(context.Context, *CreateTracepointRequest) (*CreateTracepointResponse, error)
	DeleteTracepoint(context.Context, *DeleteTracepointRequest) (*DeleteTracepointResponse, error)
	ExecuteDeepQl(context.Context, *DeepQlRequest) (*DeepQlResponse, error)
	// contains filtered or unexported methods
}

TracepointConfigServiceServer is the server API for TracepointConfigService service. All implementations must embed UnimplementedTracepointConfigServiceServer for forward compatibility

type UnimplementedIngesterServiceServer 

type UnimplementedIngesterServiceServer struct {
}

UnimplementedIngesterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedIngesterServiceServer) PushBytes 

func (UnimplementedIngesterServiceServer) PushBytes(context.Context, *PushBytesRequest) (*PushBytesResponse, error)

type UnimplementedMetricsGeneratorServer 

type UnimplementedMetricsGeneratorServer struct {
}

UnimplementedMetricsGeneratorServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsGeneratorServer) PushSnapshot 

func (UnimplementedMetricsGeneratorServer) PushSnapshot(context.Context, *PushSnapshotRequest) (*PushSnapshotResponse, error)

type UnimplementedQuerierServiceServer 

type UnimplementedQuerierServiceServer struct {
}

UnimplementedQuerierServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedQuerierServiceServer) FindSnapshotByID 

func (UnimplementedQuerierServiceServer) FindSnapshotByID(context.Context, *SnapshotByIDRequest) (*SnapshotByIDResponse, error)

func (UnimplementedQuerierServiceServer) SearchBlock 

func (UnimplementedQuerierServiceServer) SearchBlock(context.Context, *SearchBlockRequest) (*SearchResponse, error)

func (UnimplementedQuerierServiceServer) SearchRecent 

func (UnimplementedQuerierServiceServer) SearchRecent(context.Context, *SearchRequest) (*SearchResponse, error)

func (UnimplementedQuerierServiceServer) SearchTagValues 

func (UnimplementedQuerierServiceServer) SearchTagValues(context.Context, *SearchTagValuesRequest) (*SearchTagValuesResponse, error)

func (UnimplementedQuerierServiceServer) SearchTagValuesV2 

func (UnimplementedQuerierServiceServer) SearchTagValuesV2(context.Context, *SearchTagValuesRequest) (*SearchTagValuesV2Response, error)

func (UnimplementedQuerierServiceServer) SearchTags 

func (UnimplementedQuerierServiceServer) SearchTags(context.Context, *SearchTagsRequest) (*SearchTagsResponse, error)

type UnimplementedTracepointConfigServiceServer 

type UnimplementedTracepointConfigServiceServer struct {
}

UnimplementedTracepointConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTracepointConfigServiceServer) CreateTracepoint 

func (UnimplementedTracepointConfigServiceServer) CreateTracepoint(context.Context, *CreateTracepointRequest) (*CreateTracepointResponse, error)

func (UnimplementedTracepointConfigServiceServer) DeleteTracepoint 

func (UnimplementedTracepointConfigServiceServer) DeleteTracepoint(context.Context, *DeleteTracepointRequest) (*DeleteTracepointResponse, error)

func (UnimplementedTracepointConfigServiceServer) ExecuteDeepQl 

func (UnimplementedTracepointConfigServiceServer) ExecuteDeepQl(context.Context, *DeepQlRequest) (*DeepQlResponse, error)

func (UnimplementedTracepointConfigServiceServer) LoadTracepoints 

func (UnimplementedTracepointConfigServiceServer) LoadTracepoints(context.Context, *LoadTracepointRequest) (*LoadTracepointResponse, error)

type UnsafeIngesterServiceServer 

type UnsafeIngesterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeIngesterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngesterServiceServer will result in compilation errors.

type UnsafeMetricsGeneratorServer 

type UnsafeMetricsGeneratorServer interface {
	// contains filtered or unexported methods
}

UnsafeMetricsGeneratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsGeneratorServer will result in compilation errors.

type UnsafeQuerierServiceServer 

type UnsafeQuerierServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeQuerierServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QuerierServiceServer will result in compilation errors.

type UnsafeTracepointConfigServiceServer 

type UnsafeTracepointConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTracepointConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TracepointConfigServiceServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis
common
v1
poll
v1
resource
v1
tracepoint
v1

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.