import "contrib.go.opencensus.io/exporter/ocagent"
Code:
exp, err := ocagent.NewExporter(ocagent.WithInsecure(), ocagent.WithServiceName("engine"))
if err != nil {
log.Fatalf("Failed to create the agent exporter: %v", err)
}
defer exp.Stop()
// Now register it as a trace exporter.
trace.RegisterExporter(exp)
// Then use the OpenCensus tracing library, like we normally would.
ctx, span := trace.StartSpan(context.Background(), "AgentExporter-Example")
defer span.End()
for i := 0; i < 10; i++ {
_, iSpan := trace.StartSpan(ctx, fmt.Sprintf("Sample-%d", i))
<-time.After(6 * time.Millisecond)
iSpan.End()
}
Code:
// Please take at look at https://godoc.org/google.golang.org/grpc/credentials#TransportCredentials // for ways on how to initialize gRPC TransportCredentials. creds, err := credentials.NewClientTLSFromFile("my-cert.pem", "") if err != nil { log.Fatalf("Failed to create gRPC client TLS credentials: %v", err) } exp, err := ocagent.NewExporter(ocagent.WithTLSCredentials(creds), ocagent.WithServiceName("engine")) if err != nil { log.Fatalf("Failed to create the agent exporter: %v", err) } defer exp.Stop() // Now register it as a trace exporter. trace.RegisterExporter(exp) // Then use the OpenCensus tracing library, like we normally would. ctx, span := trace.StartSpan(context.Background(), "Securely-Talking-To-Agent-Span") defer span.End() for i := 0; i < 10; i++ { _, iSpan := trace.StartSpan(ctx, fmt.Sprintf("Sample-%d", i)) <-time.After(6 * time.Millisecond) iSpan.End() }
common.go connection.go nodeinfo.go ocagent.go options.go span_config.go transform_spans.go transform_stats_to_metrics.go version.go
const Version = "0.0.1"NodeWithStartTime creates a node using nodeName and derives:
Hostname from the environment Pid from the current process StartTimestamp from the start time of this process Language and library information.
type Exporter struct {
// contains filtered or unexported fields
}func NewExporter(opts ...ExporterOption) (*Exporter, error)
func NewUnstartedExporter(opts ...ExporterOption) (*Exporter, error)
func (ae *Exporter) ExportMetricsServiceRequest(batch *agentmetricspb.ExportMetricsServiceRequest) error
ExportMetricsServiceRequest sends proto metrics with the metrics service client.
func (ae *Exporter) ExportTraceServiceRequest(batch *agenttracepb.ExportTraceServiceRequest) error
Start dials to the agent, establishing a connection to it. It also initiates the Config and Trace services by sending over the initial messages that consist of the node identifier. Start invokes a background connector that will reattempt connections to the agent periodically if the connection dies.
Stop shuts down all the connections and resources related to the exporter.
type ExporterOption interface {
// contains filtered or unexported methods
}func UseCompressor(compressorName string) ExporterOption
UseCompressor will set the compressor for the gRPC client to use when sending requests. It is the responsibility of the caller to ensure that the compressor set has been registered with google.golang.org/grpc/encoding. This can be done by encoding.RegisterCompressor. Some compressors auto-register on import, such as gzip, which can be registered by calling `import _ "google.golang.org/grpc/encoding/gzip"`
func WithAddress(addr string) ExporterOption
WithAddress allows one to set the address that the exporter will connect to the agent on. If unset, it will instead try to use connect to DefaultAgentHost:DefaultAgentPort
func WithDataBundlerOptions(delay time.Duration, count int) ExporterOption
WithDataBundlerOptions provides an option for the caller to configure the metrics data bundler.
func WithGRPCDialOption(opts ...grpc.DialOption) ExporterOption
WithGRPCDialOption opens support to any grpc.DialOption to be used. If it conflicts with some other configuration the GRPC specified via the agent the ones here will take preference since they are set last.
func WithHeaders(headers map[string]string) ExporterOption
WithHeaders will send the provided headers when the gRPC stream connection is instantiated
func WithInsecure() ExporterOption
WithInsecure disables client transport security for the exporter's gRPC connection just like grpc.WithInsecure() https://godoc.org/google.golang.org/grpc#WithInsecure does. Note, by default, client security is required unless WithInsecure is used.
func WithMetricNamePrefix(prefix string) ExporterOption
WithMetricNamePrefix provides an option for the caller to add a prefix to metric names.
func WithReconnectionPeriod(rp time.Duration) ExporterOption
func WithResourceDetector(rd resource.Detector) ExporterOption
WithResourceDetector allows one to register a resource detector. Resource Detector is used to detect resources associated with the application. Detected resource is exported along with the metrics. If the detector fails then it panics. If a resource detector is not provided then by default it detects from the environment.
func WithServiceName(serviceName string) ExporterOption
WithServiceName allows one to set/override the service name that the exporter will report to the agent.
func WithSpanConfig(spanConfig SpanConfig) ExporterOption
WithSpanConfig allows one to set the AnnotationEventsPerSpan and MessageEventsPerSpan
func WithTLSCredentials(creds credentials.TransportCredentials) ExporterOption
WithTLSCredentials allows the connection to use TLS credentials when talking to the server. It takes in grpc.TransportCredentials instead of say a Certificate file or a tls.Certificate, because the retrieving these credentials can be done in many ways e.g. plain file, in code tls.Config or by certificate rotation, so it is up to the caller to decide what to use.
func (spanConfig SpanConfig) GetAnnotationEventsPerSpan() int
func (spanConfig SpanConfig) GetMessageEventsPerSpan() int
| Path | Synopsis |
|---|---|
| example |
Package ocagent imports 30 packages (graph) and is imported by 42 packages. Updated 2020-09-08. Refresh now. Tools for package owners.