Versions in this module Expand all Collapse all v0 v0.3.0 Feb 12, 2018 v0.2.0 Jan 30, 2018 Changes in this version + var GoUnusedProtection__ int + var PerOperationSamplingStrategies_DefaultUpperBoundTracesPerSecond_DEFAULT float64 + type OperationSamplingStrategy struct + Operation string + ProbabilisticSampling *ProbabilisticSamplingStrategy + func NewOperationSamplingStrategy() *OperationSamplingStrategy + func (p *OperationSamplingStrategy) GetOperation() string + func (p *OperationSamplingStrategy) GetProbabilisticSampling() *ProbabilisticSamplingStrategy + func (p *OperationSamplingStrategy) IsSetProbabilisticSampling() bool + func (p *OperationSamplingStrategy) Read(iprot thrift.TProtocol) error + func (p *OperationSamplingStrategy) ReadField1(iprot thrift.TProtocol) error + func (p *OperationSamplingStrategy) ReadField2(iprot thrift.TProtocol) error + func (p *OperationSamplingStrategy) String() string + func (p *OperationSamplingStrategy) Write(oprot thrift.TProtocol) error + type PerOperationSamplingStrategies struct + DefaultLowerBoundTracesPerSecond float64 + DefaultSamplingProbability float64 + DefaultUpperBoundTracesPerSecond *float64 + PerOperationStrategies []*OperationSamplingStrategy + var SamplingStrategyResponse_OperationSampling_DEFAULT *PerOperationSamplingStrategies + func NewPerOperationSamplingStrategies() *PerOperationSamplingStrategies + func (p *PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond() float64 + func (p *PerOperationSamplingStrategies) GetDefaultSamplingProbability() float64 + func (p *PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond() float64 + func (p *PerOperationSamplingStrategies) GetPerOperationStrategies() []*OperationSamplingStrategy + func (p *PerOperationSamplingStrategies) IsSetDefaultUpperBoundTracesPerSecond() bool + func (p *PerOperationSamplingStrategies) Read(iprot thrift.TProtocol) error + func (p *PerOperationSamplingStrategies) ReadField1(iprot thrift.TProtocol) error + func (p *PerOperationSamplingStrategies) ReadField2(iprot thrift.TProtocol) error + func (p *PerOperationSamplingStrategies) ReadField3(iprot thrift.TProtocol) error + func (p *PerOperationSamplingStrategies) ReadField4(iprot thrift.TProtocol) error + func (p *PerOperationSamplingStrategies) String() string + func (p *PerOperationSamplingStrategies) Write(oprot thrift.TProtocol) error + type ProbabilisticSamplingStrategy struct + SamplingRate float64 + var OperationSamplingStrategy_ProbabilisticSampling_DEFAULT *ProbabilisticSamplingStrategy + var SamplingStrategyResponse_ProbabilisticSampling_DEFAULT *ProbabilisticSamplingStrategy + func NewProbabilisticSamplingStrategy() *ProbabilisticSamplingStrategy + func (p *ProbabilisticSamplingStrategy) GetSamplingRate() float64 + func (p *ProbabilisticSamplingStrategy) Read(iprot thrift.TProtocol) error + func (p *ProbabilisticSamplingStrategy) ReadField1(iprot thrift.TProtocol) error + func (p *ProbabilisticSamplingStrategy) String() string + func (p *ProbabilisticSamplingStrategy) Write(oprot thrift.TProtocol) error + type RateLimitingSamplingStrategy struct + MaxTracesPerSecond int16 + var SamplingStrategyResponse_RateLimitingSampling_DEFAULT *RateLimitingSamplingStrategy + func NewRateLimitingSamplingStrategy() *RateLimitingSamplingStrategy + func (p *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int16 + func (p *RateLimitingSamplingStrategy) Read(iprot thrift.TProtocol) error + func (p *RateLimitingSamplingStrategy) ReadField1(iprot thrift.TProtocol) error + func (p *RateLimitingSamplingStrategy) String() string + func (p *RateLimitingSamplingStrategy) Write(oprot thrift.TProtocol) error + type SamplingManager interface + GetSamplingStrategy func(ctx context.Context, serviceName string) (r *SamplingStrategyResponse, err error) + type SamplingManagerClient struct + func NewSamplingManagerClient(c thrift.TClient) *SamplingManagerClient + func NewSamplingManagerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *SamplingManagerClient + func NewSamplingManagerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *SamplingManagerClient + func (p *SamplingManagerClient) GetSamplingStrategy(ctx context.Context, serviceName string) (r *SamplingStrategyResponse, err error) + type SamplingManagerGetSamplingStrategyArgs struct + ServiceName string + func NewSamplingManagerGetSamplingStrategyArgs() *SamplingManagerGetSamplingStrategyArgs + func (p *SamplingManagerGetSamplingStrategyArgs) GetServiceName() string + func (p *SamplingManagerGetSamplingStrategyArgs) Read(iprot thrift.TProtocol) error + func (p *SamplingManagerGetSamplingStrategyArgs) ReadField1(iprot thrift.TProtocol) error + func (p *SamplingManagerGetSamplingStrategyArgs) String() string + func (p *SamplingManagerGetSamplingStrategyArgs) Write(oprot thrift.TProtocol) error + type SamplingManagerGetSamplingStrategyResult struct + Success *SamplingStrategyResponse + func NewSamplingManagerGetSamplingStrategyResult() *SamplingManagerGetSamplingStrategyResult + func (p *SamplingManagerGetSamplingStrategyResult) GetSuccess() *SamplingStrategyResponse + func (p *SamplingManagerGetSamplingStrategyResult) IsSetSuccess() bool + func (p *SamplingManagerGetSamplingStrategyResult) Read(iprot thrift.TProtocol) error + func (p *SamplingManagerGetSamplingStrategyResult) ReadField0(iprot thrift.TProtocol) error + func (p *SamplingManagerGetSamplingStrategyResult) String() string + func (p *SamplingManagerGetSamplingStrategyResult) Write(oprot thrift.TProtocol) error + type SamplingManagerProcessor struct + func NewSamplingManagerProcessor(handler SamplingManager) *SamplingManagerProcessor + func (p *SamplingManagerProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *SamplingManagerProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *SamplingManagerProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *SamplingManagerProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type SamplingStrategyResponse struct + OperationSampling *PerOperationSamplingStrategies + ProbabilisticSampling *ProbabilisticSamplingStrategy + RateLimitingSampling *RateLimitingSamplingStrategy + StrategyType SamplingStrategyType + var SamplingManagerGetSamplingStrategyResult_Success_DEFAULT *SamplingStrategyResponse + func NewSamplingStrategyResponse() *SamplingStrategyResponse + func (p *SamplingStrategyResponse) GetOperationSampling() *PerOperationSamplingStrategies + func (p *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy + func (p *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy + func (p *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType + func (p *SamplingStrategyResponse) IsSetOperationSampling() bool + func (p *SamplingStrategyResponse) IsSetProbabilisticSampling() bool + func (p *SamplingStrategyResponse) IsSetRateLimitingSampling() bool + func (p *SamplingStrategyResponse) Read(iprot thrift.TProtocol) error + func (p *SamplingStrategyResponse) ReadField1(iprot thrift.TProtocol) error + func (p *SamplingStrategyResponse) ReadField2(iprot thrift.TProtocol) error + func (p *SamplingStrategyResponse) ReadField3(iprot thrift.TProtocol) error + func (p *SamplingStrategyResponse) ReadField4(iprot thrift.TProtocol) error + func (p *SamplingStrategyResponse) String() string + func (p *SamplingStrategyResponse) Write(oprot thrift.TProtocol) error + type SamplingStrategyType int64 + const SamplingStrategyType_PROBABILISTIC + const SamplingStrategyType_RATE_LIMITING + func SamplingStrategyTypeFromString(s string) (SamplingStrategyType, error) + func SamplingStrategyTypePtr(v SamplingStrategyType) *SamplingStrategyType + func (p *SamplingStrategyType) Scan(value interface{}) error + func (p *SamplingStrategyType) UnmarshalText(text []byte) error + func (p *SamplingStrategyType) Value() (driver.Value, error) + func (p SamplingStrategyType) MarshalText() ([]byte, error) + func (p SamplingStrategyType) String() string
Go to main page