api_v2

package
v1.9.0 Latest Latest
Warning

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

Go to latest
Published: Jan 21, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package api_v2 is a generated protocol buffer package.

It is generated from these files:
	api_v2.proto

It has these top-level messages:
	PostSpansRequest
	PostSpansResponse
	ProbabilisticSamplingStrategy
	RateLimitingSamplingStrategy
	OperationSamplingStrategy
	PerOperationSamplingStrategies
	SamplingStrategyResponse
	SamplingStrategyParameters

Package api_v2 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthApiV2 = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApiV2   = fmt.Errorf("proto: integer overflow")
)
View Source
var SamplingStrategyType_name = map[int32]string{
	0: "PROBABILISTIC",
	1: "RATE_LIMITING",
}
View Source
var SamplingStrategyType_value = map[string]int32{
	"PROBABILISTIC": 0,
	"RATE_LIMITING": 1,
}

Functions

func RegisterCollectorServiceHandler

func RegisterCollectorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCollectorServiceHandler registers the http handlers for service CollectorService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCollectorServiceHandlerClient

func RegisterCollectorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CollectorServiceClient) error

RegisterCollectorServiceHandler registers the http handlers for service CollectorService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CollectorServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CollectorServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CollectorServiceClient" to call the correct interceptors.

func RegisterCollectorServiceHandlerFromEndpoint

func RegisterCollectorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCollectorServiceHandlerFromEndpoint is same as RegisterCollectorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCollectorServiceServer

func RegisterCollectorServiceServer(s *grpc.Server, srv CollectorServiceServer)

func RegisterSamplingManagerHandler

func RegisterSamplingManagerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSamplingManagerHandler registers the http handlers for service SamplingManager to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSamplingManagerHandlerClient

func RegisterSamplingManagerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SamplingManagerClient) error

RegisterSamplingManagerHandler registers the http handlers for service SamplingManager to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SamplingManagerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SamplingManagerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SamplingManagerClient" to call the correct interceptors.

func RegisterSamplingManagerHandlerFromEndpoint

func RegisterSamplingManagerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSamplingManagerHandlerFromEndpoint is same as RegisterSamplingManagerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSamplingManagerServer

func RegisterSamplingManagerServer(s *grpc.Server, srv SamplingManagerServer)

Types

type CollectorServiceClient

type CollectorServiceClient interface {
	PostSpans(ctx context.Context, in *PostSpansRequest, opts ...grpc.CallOption) (*PostSpansResponse, error)
}

func NewCollectorServiceClient

func NewCollectorServiceClient(cc *grpc.ClientConn) CollectorServiceClient

type CollectorServiceServer

type CollectorServiceServer interface {
	PostSpans(context.Context, *PostSpansRequest) (*PostSpansResponse, error)
}

type OperationSamplingStrategy

type OperationSamplingStrategy struct {
	Operation             string                         `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	ProbabilisticSampling *ProbabilisticSamplingStrategy `protobuf:"bytes,2,opt,name=probabilisticSampling" json:"probabilisticSampling,omitempty"`
}

func (*OperationSamplingStrategy) Descriptor

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

func (*OperationSamplingStrategy) GetOperation

func (m *OperationSamplingStrategy) GetOperation() string

func (*OperationSamplingStrategy) GetProbabilisticSampling

func (m *OperationSamplingStrategy) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*OperationSamplingStrategy) Marshal

func (m *OperationSamplingStrategy) Marshal() (dAtA []byte, err error)

func (*OperationSamplingStrategy) MarshalTo

func (m *OperationSamplingStrategy) MarshalTo(dAtA []byte) (int, error)

func (*OperationSamplingStrategy) ProtoMessage

func (*OperationSamplingStrategy) ProtoMessage()

func (*OperationSamplingStrategy) Reset

func (m *OperationSamplingStrategy) Reset()

func (*OperationSamplingStrategy) Size

func (m *OperationSamplingStrategy) Size() (n int)

func (*OperationSamplingStrategy) String

func (m *OperationSamplingStrategy) String() string

func (*OperationSamplingStrategy) Unmarshal

func (m *OperationSamplingStrategy) Unmarshal(dAtA []byte) error

type PerOperationSamplingStrategies

type PerOperationSamplingStrategies struct {
	DefaultSamplingProbability       float64                      `protobuf:"fixed64,1,opt,name=defaultSamplingProbability,proto3" json:"defaultSamplingProbability,omitempty"`
	DefaultLowerBoundTracesPerSecond float64                      `protobuf:"fixed64,2,opt,name=defaultLowerBoundTracesPerSecond,proto3" json:"defaultLowerBoundTracesPerSecond,omitempty"`
	PerOperationStrategies           []*OperationSamplingStrategy `protobuf:"bytes,3,rep,name=perOperationStrategies" json:"perOperationStrategies,omitempty"`
	DefaultUpperBoundTracesPerSecond float64                      `protobuf:"fixed64,4,opt,name=defaultUpperBoundTracesPerSecond,proto3" json:"defaultUpperBoundTracesPerSecond,omitempty"`
}

func (*PerOperationSamplingStrategies) Descriptor

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

func (*PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond

func (m *PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetDefaultSamplingProbability

func (m *PerOperationSamplingStrategies) GetDefaultSamplingProbability() float64

func (*PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond

func (m *PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetPerOperationStrategies

func (m *PerOperationSamplingStrategies) GetPerOperationStrategies() []*OperationSamplingStrategy

func (*PerOperationSamplingStrategies) Marshal

func (m *PerOperationSamplingStrategies) Marshal() (dAtA []byte, err error)

func (*PerOperationSamplingStrategies) MarshalTo

func (m *PerOperationSamplingStrategies) MarshalTo(dAtA []byte) (int, error)

func (*PerOperationSamplingStrategies) ProtoMessage

func (*PerOperationSamplingStrategies) ProtoMessage()

func (*PerOperationSamplingStrategies) Reset

func (m *PerOperationSamplingStrategies) Reset()

func (*PerOperationSamplingStrategies) Size

func (m *PerOperationSamplingStrategies) Size() (n int)

func (*PerOperationSamplingStrategies) String

func (*PerOperationSamplingStrategies) Unmarshal

func (m *PerOperationSamplingStrategies) Unmarshal(dAtA []byte) error

type PostSpansRequest

type PostSpansRequest struct {
	Batch jaeger_api_v2.Batch `protobuf:"bytes,1,opt,name=batch" json:"batch"`
}

func (*PostSpansRequest) Descriptor

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

func (*PostSpansRequest) GetBatch

func (m *PostSpansRequest) GetBatch() jaeger_api_v2.Batch

func (*PostSpansRequest) Marshal

func (m *PostSpansRequest) Marshal() (dAtA []byte, err error)

func (*PostSpansRequest) MarshalTo

func (m *PostSpansRequest) MarshalTo(dAtA []byte) (int, error)

func (*PostSpansRequest) ProtoMessage

func (*PostSpansRequest) ProtoMessage()

func (*PostSpansRequest) Reset

func (m *PostSpansRequest) Reset()

func (*PostSpansRequest) Size

func (m *PostSpansRequest) Size() (n int)

func (*PostSpansRequest) String

func (m *PostSpansRequest) String() string

func (*PostSpansRequest) Unmarshal

func (m *PostSpansRequest) Unmarshal(dAtA []byte) error

type PostSpansResponse

type PostSpansResponse struct {
}

func (*PostSpansResponse) Descriptor

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

func (*PostSpansResponse) Marshal

func (m *PostSpansResponse) Marshal() (dAtA []byte, err error)

func (*PostSpansResponse) MarshalTo

func (m *PostSpansResponse) MarshalTo(dAtA []byte) (int, error)

func (*PostSpansResponse) ProtoMessage

func (*PostSpansResponse) ProtoMessage()

func (*PostSpansResponse) Reset

func (m *PostSpansResponse) Reset()

func (*PostSpansResponse) Size

func (m *PostSpansResponse) Size() (n int)

func (*PostSpansResponse) String

func (m *PostSpansResponse) String() string

func (*PostSpansResponse) Unmarshal

func (m *PostSpansResponse) Unmarshal(dAtA []byte) error

type ProbabilisticSamplingStrategy

type ProbabilisticSamplingStrategy struct {
	SamplingRate float64 `protobuf:"fixed64,1,opt,name=samplingRate,proto3" json:"samplingRate,omitempty"`
}

func (*ProbabilisticSamplingStrategy) Descriptor

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

func (*ProbabilisticSamplingStrategy) GetSamplingRate

func (m *ProbabilisticSamplingStrategy) GetSamplingRate() float64

func (*ProbabilisticSamplingStrategy) Marshal

func (m *ProbabilisticSamplingStrategy) Marshal() (dAtA []byte, err error)

func (*ProbabilisticSamplingStrategy) MarshalTo

func (m *ProbabilisticSamplingStrategy) MarshalTo(dAtA []byte) (int, error)

func (*ProbabilisticSamplingStrategy) ProtoMessage

func (*ProbabilisticSamplingStrategy) ProtoMessage()

func (*ProbabilisticSamplingStrategy) Reset

func (m *ProbabilisticSamplingStrategy) Reset()

func (*ProbabilisticSamplingStrategy) Size

func (m *ProbabilisticSamplingStrategy) Size() (n int)

func (*ProbabilisticSamplingStrategy) String

func (*ProbabilisticSamplingStrategy) Unmarshal

func (m *ProbabilisticSamplingStrategy) Unmarshal(dAtA []byte) error

type RateLimitingSamplingStrategy

type RateLimitingSamplingStrategy struct {
	MaxTracesPerSecond int32 `protobuf:"varint,1,opt,name=maxTracesPerSecond,proto3" json:"maxTracesPerSecond,omitempty"`
}

func (*RateLimitingSamplingStrategy) Descriptor

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

func (*RateLimitingSamplingStrategy) GetMaxTracesPerSecond

func (m *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int32

func (*RateLimitingSamplingStrategy) Marshal

func (m *RateLimitingSamplingStrategy) Marshal() (dAtA []byte, err error)

func (*RateLimitingSamplingStrategy) MarshalTo

func (m *RateLimitingSamplingStrategy) MarshalTo(dAtA []byte) (int, error)

func (*RateLimitingSamplingStrategy) ProtoMessage

func (*RateLimitingSamplingStrategy) ProtoMessage()

func (*RateLimitingSamplingStrategy) Reset

func (m *RateLimitingSamplingStrategy) Reset()

func (*RateLimitingSamplingStrategy) Size

func (m *RateLimitingSamplingStrategy) Size() (n int)

func (*RateLimitingSamplingStrategy) String

func (*RateLimitingSamplingStrategy) Unmarshal

func (m *RateLimitingSamplingStrategy) Unmarshal(dAtA []byte) error

type SamplingManagerClient

type SamplingManagerClient interface {
	GetSamplingStrategy(ctx context.Context, in *SamplingStrategyParameters, opts ...grpc.CallOption) (*SamplingStrategyResponse, error)
}

func NewSamplingManagerClient

func NewSamplingManagerClient(cc *grpc.ClientConn) SamplingManagerClient

type SamplingManagerServer

type SamplingManagerServer interface {
	GetSamplingStrategy(context.Context, *SamplingStrategyParameters) (*SamplingStrategyResponse, error)
}

type SamplingStrategyParameters

type SamplingStrategyParameters struct {
	ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
}

func (*SamplingStrategyParameters) Descriptor

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

func (*SamplingStrategyParameters) GetServiceName

func (m *SamplingStrategyParameters) GetServiceName() string

func (*SamplingStrategyParameters) Marshal

func (m *SamplingStrategyParameters) Marshal() (dAtA []byte, err error)

func (*SamplingStrategyParameters) MarshalTo

func (m *SamplingStrategyParameters) MarshalTo(dAtA []byte) (int, error)

func (*SamplingStrategyParameters) ProtoMessage

func (*SamplingStrategyParameters) ProtoMessage()

func (*SamplingStrategyParameters) Reset

func (m *SamplingStrategyParameters) Reset()

func (*SamplingStrategyParameters) Size

func (m *SamplingStrategyParameters) Size() (n int)

func (*SamplingStrategyParameters) String

func (m *SamplingStrategyParameters) String() string

func (*SamplingStrategyParameters) Unmarshal

func (m *SamplingStrategyParameters) Unmarshal(dAtA []byte) error

type SamplingStrategyResponse

type SamplingStrategyResponse struct {
	StrategyType          SamplingStrategyType            `protobuf:"varint,1,opt,name=strategyType,proto3,enum=jaeger.api_v2.SamplingStrategyType" json:"strategyType,omitempty"`
	ProbabilisticSampling *ProbabilisticSamplingStrategy  `protobuf:"bytes,2,opt,name=probabilisticSampling" json:"probabilisticSampling,omitempty"`
	RateLimitingSampling  *RateLimitingSamplingStrategy   `protobuf:"bytes,3,opt,name=rateLimitingSampling" json:"rateLimitingSampling,omitempty"`
	OperationSampling     *PerOperationSamplingStrategies `protobuf:"bytes,4,opt,name=operationSampling" json:"operationSampling,omitempty"`
}

func (*SamplingStrategyResponse) Descriptor

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

func (*SamplingStrategyResponse) GetOperationSampling

func (m *SamplingStrategyResponse) GetOperationSampling() *PerOperationSamplingStrategies

func (*SamplingStrategyResponse) GetProbabilisticSampling

func (m *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*SamplingStrategyResponse) GetRateLimitingSampling

func (m *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy

func (*SamplingStrategyResponse) GetStrategyType

func (m *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType

func (*SamplingStrategyResponse) Marshal

func (m *SamplingStrategyResponse) Marshal() (dAtA []byte, err error)

func (*SamplingStrategyResponse) MarshalTo

func (m *SamplingStrategyResponse) MarshalTo(dAtA []byte) (int, error)

func (*SamplingStrategyResponse) ProtoMessage

func (*SamplingStrategyResponse) ProtoMessage()

func (*SamplingStrategyResponse) Reset

func (m *SamplingStrategyResponse) Reset()

func (*SamplingStrategyResponse) Size

func (m *SamplingStrategyResponse) Size() (n int)

func (*SamplingStrategyResponse) String

func (m *SamplingStrategyResponse) String() string

func (*SamplingStrategyResponse) Unmarshal

func (m *SamplingStrategyResponse) Unmarshal(dAtA []byte) error

type SamplingStrategyType

type SamplingStrategyType int32
const (
	SamplingStrategyType_PROBABILISTIC SamplingStrategyType = 0
	SamplingStrategyType_RATE_LIMITING SamplingStrategyType = 1
)

func (SamplingStrategyType) EnumDescriptor

func (SamplingStrategyType) EnumDescriptor() ([]byte, []int)

func (SamplingStrategyType) String

func (x SamplingStrategyType) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL