remotesource

Documentation

Index

• func NewRemoteSource(conn *grpc.ClientConn, grpcClientSettings *configgrpc.ClientConfig, ...) (source.Source, io.Closer)
• type ConfigManagerProxy
  • func NewConfigManager(conn *grpc.ClientConn) *ConfigManagerProxy
  • func (s *ConfigManagerProxy) GetSamplingStrategy(ctx context.Context, serviceName string) (*api_v2.SamplingStrategyResponse, error)

Functions

func NewRemoteSource

func NewRemoteSource(
	conn *grpc.ClientConn,
	grpcClientSettings *configgrpc.ClientConfig,
	reloadInterval time.Duration,
) (source.Source, io.Closer)

NewRemoteSource returns a StrategyStore that delegates to the configured Jaeger gRPC endpoint, making extension-configured enhancements (header additions only for now) to the gRPC context of every outbound gRPC call. Note: it would be nice to expand the configuration surface to include an optional TTL-based caching behavior for service-specific outbound GetSamplingStrategy calls.

Types

type ConfigManagerProxy

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

ConfigManagerProxy returns sampling decisions from collector over gRPC.

func NewConfigManager

func NewConfigManager(conn *grpc.ClientConn) *ConfigManagerProxy

NewConfigManager creates gRPC sampling manager.

func (*ConfigManagerProxy) GetSamplingStrategy

func (s *ConfigManagerProxy) GetSamplingStrategy(ctx context.Context, serviceName string) (*api_v2.SamplingStrategyResponse, error)

GetSamplingStrategy returns sampling strategies from collector.