sampling

package
v1.35.1 Latest Latest
Warning

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

 Go to latest Published: May 31, 2022 License: Apache-2.0 Imports: 7 Imported by: 256

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var PerOperationSamplingStrategies_DefaultUpperBoundTracesPerSecond_DEFAULT float64

Functions

This section is empty.

Types

type OperationSamplingStrategy 

type OperationSamplingStrategy struct {
	Operation             string                         `thrift:"operation,1,required" db:"operation" json:"operation"`
	ProbabilisticSampling *ProbabilisticSamplingStrategy `thrift:"probabilisticSampling,2,required" db:"probabilisticSampling" json:"probabilisticSampling"`
}

Attributes:

  • Operation
  • ProbabilisticSampling

func NewOperationSamplingStrategy 

func NewOperationSamplingStrategy() *OperationSamplingStrategy

func (*OperationSamplingStrategy) Equals added in v1.23.0 

func (p *OperationSamplingStrategy) Equals(other *OperationSamplingStrategy) bool

func (*OperationSamplingStrategy) GetOperation 

func (p *OperationSamplingStrategy) GetOperation() string

func (*OperationSamplingStrategy) GetProbabilisticSampling 

func (p *OperationSamplingStrategy) GetProbabilisticSampling() *ProbabilisticSamplingStrategy

func (*OperationSamplingStrategy) IsSetProbabilisticSampling 

func (p *OperationSamplingStrategy) IsSetProbabilisticSampling() bool

func (*OperationSamplingStrategy) Read 

func (p *OperationSamplingStrategy) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*OperationSamplingStrategy) ReadField1 added in v1.19.0 

func (p *OperationSamplingStrategy) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*OperationSamplingStrategy) ReadField2 added in v1.19.0 

func (p *OperationSamplingStrategy) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*OperationSamplingStrategy) String 

func (p *OperationSamplingStrategy) String() string

func (*OperationSamplingStrategy) Write 

func (p *OperationSamplingStrategy) Write(ctx context.Context, oprot thrift.TProtocol) error

type PerOperationSamplingStrategies 

type PerOperationSamplingStrategies struct {
	DefaultSamplingProbability       float64                      `thrift:"defaultSamplingProbability,1,required" db:"defaultSamplingProbability" json:"defaultSamplingProbability"`
	DefaultLowerBoundTracesPerSecond float64                      `` /* 130-byte string literal not displayed */
	PerOperationStrategies           []*OperationSamplingStrategy `thrift:"perOperationStrategies,3,required" db:"perOperationStrategies" json:"perOperationStrategies"`
	DefaultUpperBoundTracesPerSecond *float64                     `` /* 131-byte string literal not displayed */
}

Attributes:

  • DefaultSamplingProbability
  • DefaultLowerBoundTracesPerSecond
  • PerOperationStrategies
  • DefaultUpperBoundTracesPerSecond
var SamplingStrategyResponse_OperationSampling_DEFAULT *PerOperationSamplingStrategies

func NewPerOperationSamplingStrategies 

func NewPerOperationSamplingStrategies() *PerOperationSamplingStrategies

func (*PerOperationSamplingStrategies) Equals added in v1.23.0 

func (p *PerOperationSamplingStrategies) Equals(other *PerOperationSamplingStrategies) bool

func (*PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond 

func (p *PerOperationSamplingStrategies) GetDefaultLowerBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetDefaultSamplingProbability 

func (p *PerOperationSamplingStrategies) GetDefaultSamplingProbability() float64

func (*PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond 

func (p *PerOperationSamplingStrategies) GetDefaultUpperBoundTracesPerSecond() float64

func (*PerOperationSamplingStrategies) GetPerOperationStrategies 

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

func (*PerOperationSamplingStrategies) IsSetDefaultUpperBoundTracesPerSecond 

func (p *PerOperationSamplingStrategies) IsSetDefaultUpperBoundTracesPerSecond() bool

func (*PerOperationSamplingStrategies) Read 

func (p *PerOperationSamplingStrategies) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*PerOperationSamplingStrategies) ReadField1 added in v1.19.0 

func (p *PerOperationSamplingStrategies) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*PerOperationSamplingStrategies) ReadField2 added in v1.19.0 

func (p *PerOperationSamplingStrategies) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*PerOperationSamplingStrategies) ReadField3 added in v1.19.0 

func (p *PerOperationSamplingStrategies) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*PerOperationSamplingStrategies) ReadField4 added in v1.19.0 

func (p *PerOperationSamplingStrategies) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*PerOperationSamplingStrategies) String 

func (p *PerOperationSamplingStrategies) String() string

func (*PerOperationSamplingStrategies) Write 

func (p *PerOperationSamplingStrategies) Write(ctx context.Context, oprot thrift.TProtocol) error

type ProbabilisticSamplingStrategy 

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

Attributes:

  • SamplingRate
var OperationSamplingStrategy_ProbabilisticSampling_DEFAULT *ProbabilisticSamplingStrategy
var SamplingStrategyResponse_ProbabilisticSampling_DEFAULT *ProbabilisticSamplingStrategy

func NewProbabilisticSamplingStrategy 

func NewProbabilisticSamplingStrategy() *ProbabilisticSamplingStrategy

func (*ProbabilisticSamplingStrategy) Equals added in v1.23.0 

func (p *ProbabilisticSamplingStrategy) Equals(other *ProbabilisticSamplingStrategy) bool

func (*ProbabilisticSamplingStrategy) GetSamplingRate 

func (p *ProbabilisticSamplingStrategy) GetSamplingRate() float64

func (*ProbabilisticSamplingStrategy) Read 

func (p *ProbabilisticSamplingStrategy) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ProbabilisticSamplingStrategy) ReadField1 added in v1.19.0 

func (p *ProbabilisticSamplingStrategy) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ProbabilisticSamplingStrategy) String 

func (p *ProbabilisticSamplingStrategy) String() string

func (*ProbabilisticSamplingStrategy) Write 

func (p *ProbabilisticSamplingStrategy) Write(ctx context.Context, oprot thrift.TProtocol) error

type RateLimitingSamplingStrategy 

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

Attributes:

  • MaxTracesPerSecond
var SamplingStrategyResponse_RateLimitingSampling_DEFAULT *RateLimitingSamplingStrategy

func NewRateLimitingSamplingStrategy 

func NewRateLimitingSamplingStrategy() *RateLimitingSamplingStrategy

func (*RateLimitingSamplingStrategy) Equals added in v1.23.0 

func (p *RateLimitingSamplingStrategy) Equals(other *RateLimitingSamplingStrategy) bool

func (*RateLimitingSamplingStrategy) GetMaxTracesPerSecond 

func (p *RateLimitingSamplingStrategy) GetMaxTracesPerSecond() int16

func (*RateLimitingSamplingStrategy) Read 

func (p *RateLimitingSamplingStrategy) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*RateLimitingSamplingStrategy) ReadField1 added in v1.19.0 

func (p *RateLimitingSamplingStrategy) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*RateLimitingSamplingStrategy) String 

func (p *RateLimitingSamplingStrategy) String() string

func (*RateLimitingSamplingStrategy) Write 

func (p *RateLimitingSamplingStrategy) Write(ctx context.Context, oprot thrift.TProtocol) error

type SamplingManager 

type SamplingManager interface {
	// Parameters:
	//  - ServiceName
	GetSamplingStrategy(ctx context.Context, serviceName string) (_r *SamplingStrategyResponse, _err error)
}

type SamplingManagerClient 

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

func NewSamplingManagerClient added in v1.19.0 

func NewSamplingManagerClient(c thrift.TClient) *SamplingManagerClient

func NewSamplingManagerClientFactory 

func NewSamplingManagerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *SamplingManagerClient

func NewSamplingManagerClientProtocol 

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

func (*SamplingManagerClient) Client_ added in v1.19.0 

func (p *SamplingManagerClient) Client_() thrift.TClient

func (*SamplingManagerClient) GetSamplingStrategy 

func (p *SamplingManagerClient) GetSamplingStrategy(ctx context.Context, serviceName string) (_r *SamplingStrategyResponse, _err error)

Parameters:

  • ServiceName

func (*SamplingManagerClient) LastResponseMeta_ added in v1.23.0 

func (p *SamplingManagerClient) LastResponseMeta_() thrift.ResponseMeta

func (*SamplingManagerClient) SetLastResponseMeta_ added in v1.23.0 

func (p *SamplingManagerClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type SamplingManagerGetSamplingStrategyArgs 

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

Attributes:

  • ServiceName

func NewSamplingManagerGetSamplingStrategyArgs 

func NewSamplingManagerGetSamplingStrategyArgs() *SamplingManagerGetSamplingStrategyArgs

func (*SamplingManagerGetSamplingStrategyArgs) GetServiceName 

func (p *SamplingManagerGetSamplingStrategyArgs) GetServiceName() string

func (*SamplingManagerGetSamplingStrategyArgs) Read 

func (p *SamplingManagerGetSamplingStrategyArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingManagerGetSamplingStrategyArgs) ReadField1 added in v1.19.0 

func (p *SamplingManagerGetSamplingStrategyArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingManagerGetSamplingStrategyArgs) String 

func (p *SamplingManagerGetSamplingStrategyArgs) String() string

func (*SamplingManagerGetSamplingStrategyArgs) Write 

func (p *SamplingManagerGetSamplingStrategyArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type SamplingManagerGetSamplingStrategyResult 

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

Attributes:

  • Success

func NewSamplingManagerGetSamplingStrategyResult 

func NewSamplingManagerGetSamplingStrategyResult() *SamplingManagerGetSamplingStrategyResult

func (*SamplingManagerGetSamplingStrategyResult) GetSuccess 

func (p *SamplingManagerGetSamplingStrategyResult) GetSuccess() *SamplingStrategyResponse

func (*SamplingManagerGetSamplingStrategyResult) IsSetSuccess 

func (p *SamplingManagerGetSamplingStrategyResult) IsSetSuccess() bool

func (*SamplingManagerGetSamplingStrategyResult) Read 

func (p *SamplingManagerGetSamplingStrategyResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingManagerGetSamplingStrategyResult) ReadField0 added in v1.19.0 

func (p *SamplingManagerGetSamplingStrategyResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingManagerGetSamplingStrategyResult) String 

func (p *SamplingManagerGetSamplingStrategyResult) String() string

func (*SamplingManagerGetSamplingStrategyResult) Write 

func (p *SamplingManagerGetSamplingStrategyResult) Write(ctx context.Context, oprot thrift.TProtocol) error

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(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*SamplingManagerProcessor) ProcessorMap 

func (p *SamplingManagerProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type SamplingStrategyResponse 

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

Attributes:

  • StrategyType
  • ProbabilisticSampling
  • RateLimitingSampling
  • OperationSampling
var SamplingManagerGetSamplingStrategyResult_Success_DEFAULT *SamplingStrategyResponse

func NewSamplingStrategyResponse 

func NewSamplingStrategyResponse() *SamplingStrategyResponse

func (*SamplingStrategyResponse) Equals added in v1.23.0 

func (p *SamplingStrategyResponse) Equals(other *SamplingStrategyResponse) bool

func (*SamplingStrategyResponse) GetOperationSampling 

func (p *SamplingStrategyResponse) GetOperationSampling() *PerOperationSamplingStrategies

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) IsSetOperationSampling 

func (p *SamplingStrategyResponse) IsSetOperationSampling() bool

func (*SamplingStrategyResponse) IsSetProbabilisticSampling 

func (p *SamplingStrategyResponse) IsSetProbabilisticSampling() bool

func (*SamplingStrategyResponse) IsSetRateLimitingSampling 

func (p *SamplingStrategyResponse) IsSetRateLimitingSampling() bool

func (*SamplingStrategyResponse) Read 

func (p *SamplingStrategyResponse) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingStrategyResponse) ReadField1 added in v1.19.0 

func (p *SamplingStrategyResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingStrategyResponse) ReadField2 added in v1.19.0 

func (p *SamplingStrategyResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingStrategyResponse) ReadField3 added in v1.19.0 

func (p *SamplingStrategyResponse) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingStrategyResponse) ReadField4 added in v1.19.0 

func (p *SamplingStrategyResponse) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*SamplingStrategyResponse) String 

func (p *SamplingStrategyResponse) String() string

func (*SamplingStrategyResponse) Write 

func (p *SamplingStrategyResponse) Write(ctx context.Context, oprot thrift.TProtocol) error

type SamplingStrategyType 

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

func SamplingStrategyTypeFromString 

func SamplingStrategyTypeFromString(s string) (SamplingStrategyType, error)

func SamplingStrategyTypePtr 

func SamplingStrategyTypePtr(v SamplingStrategyType) *SamplingStrategyType

func (SamplingStrategyType) MarshalText 

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

func (*SamplingStrategyType) Scan added in v1.19.0 

func (p *SamplingStrategyType) Scan(value interface{}) error

func (SamplingStrategyType) String 

func (p SamplingStrategyType) String() string

func (*SamplingStrategyType) UnmarshalText 

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

func (*SamplingStrategyType) Value added in v1.19.0 

func (p *SamplingStrategyType) Value() (driver.Value, error)

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.