ingester

package
v0.0.0-...-deba56b Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2023 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IngesterService_BatchCreateRequestMetadatas_FullMethodName = "/k6.cloud.insights.proto.v1.ingester.IngesterService/BatchCreateRequestMetadatas"
	IngesterService_BatchCreateSpans_FullMethodName            = "/k6.cloud.insights.proto.v1.ingester.IngesterService/BatchCreateSpans"
)

Variables

View Source 
var File_v1_ingester_ingester_proto protoreflect.FileDescriptor
View Source 
var IngesterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "k6.cloud.insights.proto.v1.ingester.IngesterService",
	HandlerType: (*IngesterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BatchCreateRequestMetadatas",
			Handler:    _IngesterService_BatchCreateRequestMetadatas_Handler,
		},
		{
			MethodName: "BatchCreateSpans",
			Handler:    _IngesterService_BatchCreateSpans_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/ingester/ingester.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)

Functions

func RegisterIngesterServiceServer 

func RegisterIngesterServiceServer(s grpc.ServiceRegistrar, srv IngesterServiceServer)

Types

type BatchCreateRequestMetadatasRequest 

type BatchCreateRequestMetadatasRequest struct {
	Requests []*CreateRequestMetadataRequest `protobuf:"bytes,1,rep,name=Requests,proto3" json:"Requests,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchCreateRequestMetadatasRequest) Descriptor deprecated 

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

Deprecated: Use BatchCreateRequestMetadatasRequest.ProtoReflect.Descriptor instead.

func (*BatchCreateRequestMetadatasRequest) GetRequests 

func (x *BatchCreateRequestMetadatasRequest) GetRequests() []*CreateRequestMetadataRequest

func (*BatchCreateRequestMetadatasRequest) ProtoMessage 

func (*BatchCreateRequestMetadatasRequest) ProtoMessage()

func (*BatchCreateRequestMetadatasRequest) ProtoReflect 

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

func (*BatchCreateRequestMetadatasRequest) Reset 

func (x *BatchCreateRequestMetadatasRequest) Reset()

func (*BatchCreateRequestMetadatasRequest) String 

func (x *BatchCreateRequestMetadatasRequest) String() string

type BatchCreateRequestMetadatasResponse 

type BatchCreateRequestMetadatasResponse struct {
	RequestMetadatas []*k6.RequestMetadata `protobuf:"bytes,1,rep,name=RequestMetadatas,proto3" json:"RequestMetadatas,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchCreateRequestMetadatasResponse) Descriptor deprecated 

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

Deprecated: Use BatchCreateRequestMetadatasResponse.ProtoReflect.Descriptor instead.

func (*BatchCreateRequestMetadatasResponse) GetRequestMetadatas 

func (x *BatchCreateRequestMetadatasResponse) GetRequestMetadatas() []*k6.RequestMetadata

func (*BatchCreateRequestMetadatasResponse) ProtoMessage 

func (*BatchCreateRequestMetadatasResponse) ProtoMessage()

func (*BatchCreateRequestMetadatasResponse) ProtoReflect 

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

func (*BatchCreateRequestMetadatasResponse) Reset 

func (x *BatchCreateRequestMetadatasResponse) Reset()

func (*BatchCreateRequestMetadatasResponse) String 

func (x *BatchCreateRequestMetadatasResponse) String() string

type BatchCreateSpansRequest 

type BatchCreateSpansRequest struct {
	Requests []*CreateSpanRequest `protobuf:"bytes,1,rep,name=Requests,proto3" json:"Requests,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchCreateSpansRequest) Descriptor deprecated 

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

Deprecated: Use BatchCreateSpansRequest.ProtoReflect.Descriptor instead.

func (*BatchCreateSpansRequest) GetRequests 

func (x *BatchCreateSpansRequest) GetRequests() []*CreateSpanRequest

func (*BatchCreateSpansRequest) ProtoMessage 

func (*BatchCreateSpansRequest) ProtoMessage()

func (*BatchCreateSpansRequest) ProtoReflect 

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

func (*BatchCreateSpansRequest) Reset 

func (x *BatchCreateSpansRequest) Reset()

func (*BatchCreateSpansRequest) String 

func (x *BatchCreateSpansRequest) String() string

type BatchCreateSpansResponse 

type BatchCreateSpansResponse struct {
	Spans []*trace.Span `protobuf:"bytes,1,rep,name=Spans,proto3" json:"Spans,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchCreateSpansResponse) Descriptor deprecated 

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

Deprecated: Use BatchCreateSpansResponse.ProtoReflect.Descriptor instead.

func (*BatchCreateSpansResponse) GetSpans 

func (x *BatchCreateSpansResponse) GetSpans() []*trace.Span

func (*BatchCreateSpansResponse) ProtoMessage 

func (*BatchCreateSpansResponse) ProtoMessage()

func (*BatchCreateSpansResponse) ProtoReflect 

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

func (*BatchCreateSpansResponse) Reset 

func (x *BatchCreateSpansResponse) Reset()

func (*BatchCreateSpansResponse) String 

func (x *BatchCreateSpansResponse) String() string

type CreateRequestMetadataRequest 

type CreateRequestMetadataRequest struct {
	RequestMetadata *k6.RequestMetadata `protobuf:"bytes,1,opt,name=RequestMetadata,proto3" json:"RequestMetadata,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequestMetadataRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequestMetadataRequest.ProtoReflect.Descriptor instead.

func (*CreateRequestMetadataRequest) GetRequestMetadata 

func (x *CreateRequestMetadataRequest) GetRequestMetadata() *k6.RequestMetadata

func (*CreateRequestMetadataRequest) ProtoMessage 

func (*CreateRequestMetadataRequest) ProtoMessage()

func (*CreateRequestMetadataRequest) ProtoReflect 

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

func (*CreateRequestMetadataRequest) Reset 

func (x *CreateRequestMetadataRequest) Reset()

func (*CreateRequestMetadataRequest) String 

func (x *CreateRequestMetadataRequest) String() string

type CreateSpanRequest 

type CreateSpanRequest struct {
	Span *trace.Span `protobuf:"bytes,1,opt,name=Span,proto3" json:"Span,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSpanRequest) Descriptor deprecated 

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

Deprecated: Use CreateSpanRequest.ProtoReflect.Descriptor instead.

func (*CreateSpanRequest) GetSpan 

func (x *CreateSpanRequest) GetSpan() *trace.Span

func (*CreateSpanRequest) ProtoMessage 

func (*CreateSpanRequest) ProtoMessage()

func (*CreateSpanRequest) ProtoReflect 

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

func (*CreateSpanRequest) Reset 

func (x *CreateSpanRequest) Reset()

func (*CreateSpanRequest) String 

func (x *CreateSpanRequest) String() string

type IngesterServiceClient 

type IngesterServiceClient interface {
	BatchCreateRequestMetadatas(ctx context.Context, in *BatchCreateRequestMetadatasRequest, opts ...grpc.CallOption) (*BatchCreateRequestMetadatasResponse, error)
	BatchCreateSpans(ctx context.Context, in *BatchCreateSpansRequest, opts ...grpc.CallOption) (*BatchCreateSpansResponse, 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 {
	BatchCreateRequestMetadatas(context.Context, *BatchCreateRequestMetadatasRequest) (*BatchCreateRequestMetadatasResponse, error)
	BatchCreateSpans(context.Context, *BatchCreateSpansRequest) (*BatchCreateSpansResponse, error)
	// contains filtered or unexported methods
}

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

type UnimplementedIngesterServiceServer 

type UnimplementedIngesterServiceServer struct {
}

UnimplementedIngesterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedIngesterServiceServer) BatchCreateRequestMetadatas 

func (UnimplementedIngesterServiceServer) BatchCreateRequestMetadatas(context.Context, *BatchCreateRequestMetadatasRequest) (*BatchCreateRequestMetadatasResponse, error)

func (UnimplementedIngesterServiceServer) BatchCreateSpans 

func (UnimplementedIngesterServiceServer) BatchCreateSpans(context.Context, *BatchCreateSpansRequest) (*BatchCreateSpansResponse, 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.

Source Files

View all Source files

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.