api_v2

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 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 (m *PerOperationSamplingStrategies) String() 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 (m *ProbabilisticSamplingStrategy) String() 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 (m *RateLimitingSamplingStrategy) String() 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

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.