sampling

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 2016 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoUnusedProtection__ int

Functions

This section is empty.

Types

type ProbabilisticSamplingStrategy

type ProbabilisticSamplingStrategy struct {
	SamplingRate float64 `thrift:"samplingRate,1,required" json:"samplingRate"`
}

Attributes:

  • SamplingRate
var SamplingStrategyResponse_ProbabilisticSampling_DEFAULT *ProbabilisticSamplingStrategy

func NewProbabilisticSamplingStrategy

func NewProbabilisticSamplingStrategy() *ProbabilisticSamplingStrategy

func (*ProbabilisticSamplingStrategy) GetSamplingRate

func (p *ProbabilisticSamplingStrategy) GetSamplingRate() float64

func (*ProbabilisticSamplingStrategy) Read

func (*ProbabilisticSamplingStrategy) String

func (*ProbabilisticSamplingStrategy) Write

type RateLimitingSamplingStrategy

type RateLimitingSamplingStrategy struct {
	MaxTracesPerSecond int16 `thrift:"maxTracesPerSecond,1,required" json:"maxTracesPerSecond"`
}

Attributes:

  • MaxTracesPerSecond
var SamplingStrategyResponse_RateLimitingSampling_DEFAULT *RateLimitingSamplingStrategy

func NewRateLimitingSamplingStrategy

func NewRateLimitingSamplingStrategy() *RateLimitingSamplingStrategy

func (*RateLimitingSamplingStrategy) GetMaxTracesPerSecond

func (p *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int16

func (*RateLimitingSamplingStrategy) Read

func (*RateLimitingSamplingStrategy) String

func (*RateLimitingSamplingStrategy) Write

type SamplingManager

type SamplingManager interface {
	// Parameters:
	//  - ServiceName
	GetSamplingStrategy(serviceName string) (r *SamplingStrategyResponse, err error)
}

type SamplingManagerClient

type SamplingManagerClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewSamplingManagerClientProtocol

func NewSamplingManagerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *SamplingManagerClient

func (*SamplingManagerClient) GetSamplingStrategy

func (p *SamplingManagerClient) GetSamplingStrategy(serviceName string) (r *SamplingStrategyResponse, err error)

Parameters:

  • ServiceName

type SamplingManagerGetSamplingStrategyArgs

type SamplingManagerGetSamplingStrategyArgs struct {
	ServiceName string `thrift:"serviceName,1" json:"serviceName"`
}

Attributes:

  • ServiceName

func NewSamplingManagerGetSamplingStrategyArgs

func NewSamplingManagerGetSamplingStrategyArgs() *SamplingManagerGetSamplingStrategyArgs

func (*SamplingManagerGetSamplingStrategyArgs) GetServiceName

func (p *SamplingManagerGetSamplingStrategyArgs) GetServiceName() string

func (*SamplingManagerGetSamplingStrategyArgs) Read

func (*SamplingManagerGetSamplingStrategyArgs) String

func (*SamplingManagerGetSamplingStrategyArgs) Write

type SamplingManagerGetSamplingStrategyResult

type SamplingManagerGetSamplingStrategyResult struct {
	Success *SamplingStrategyResponse `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewSamplingManagerGetSamplingStrategyResult

func NewSamplingManagerGetSamplingStrategyResult() *SamplingManagerGetSamplingStrategyResult

func (*SamplingManagerGetSamplingStrategyResult) GetSuccess

func (*SamplingManagerGetSamplingStrategyResult) IsSetSuccess

func (*SamplingManagerGetSamplingStrategyResult) Read

func (*SamplingManagerGetSamplingStrategyResult) String

func (*SamplingManagerGetSamplingStrategyResult) Write

type SamplingManagerProcessor

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

func NewSamplingManagerProcessor

func NewSamplingManagerProcessor(handler SamplingManager) *SamplingManagerProcessor

func (*SamplingManagerProcessor) AddToProcessorMap

func (p *SamplingManagerProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*SamplingManagerProcessor) GetProcessorFunction

func (p *SamplingManagerProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*SamplingManagerProcessor) Process

func (p *SamplingManagerProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*SamplingManagerProcessor) ProcessorMap

type SamplingStrategyResponse

type SamplingStrategyResponse struct {
	StrategyType          SamplingStrategyType           `thrift:"strategyType,1,required" json:"strategyType"`
	ProbabilisticSampling *ProbabilisticSamplingStrategy `thrift:"probabilisticSampling,2" json:"probabilisticSampling,omitempty"`
	RateLimitingSampling  *RateLimitingSamplingStrategy  `thrift:"rateLimitingSampling,3" json:"rateLimitingSampling,omitempty"`
}

Attributes:

  • StrategyType
  • ProbabilisticSampling
  • RateLimitingSampling
var SamplingManagerGetSamplingStrategyResult_Success_DEFAULT *SamplingStrategyResponse

func NewSamplingStrategyResponse

func NewSamplingStrategyResponse() *SamplingStrategyResponse

func (*SamplingStrategyResponse) GetProbabilisticSampling

func (p *SamplingStrategyResponse) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*SamplingStrategyResponse) GetRateLimitingSampling

func (p *SamplingStrategyResponse) GetRateLimitingSampling() *RateLimitingSamplingStrategy

func (*SamplingStrategyResponse) GetStrategyType

func (p *SamplingStrategyResponse) GetStrategyType() SamplingStrategyType

func (*SamplingStrategyResponse) IsSetProbabilisticSampling

func (p *SamplingStrategyResponse) IsSetProbabilisticSampling() bool

func (*SamplingStrategyResponse) IsSetRateLimitingSampling

func (p *SamplingStrategyResponse) IsSetRateLimitingSampling() bool

func (*SamplingStrategyResponse) Read

func (*SamplingStrategyResponse) String

func (p *SamplingStrategyResponse) String() string

func (*SamplingStrategyResponse) Write

type SamplingStrategyType

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

func SamplingStrategyTypeFromString

func SamplingStrategyTypeFromString(s string) (SamplingStrategyType, error)

func (SamplingStrategyType) MarshalText

func (p SamplingStrategyType) MarshalText() ([]byte, error)

func (SamplingStrategyType) String

func (p SamplingStrategyType) String() string

func (*SamplingStrategyType) UnmarshalText

func (p *SamplingStrategyType) UnmarshalText(text []byte) error

Jump to

Keyboard shortcuts

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