Omni-NewRelic

New Relic integrations for PlexusOne abstraction layers.

Overview

omni-newrelic wraps the official newrelic-client-go SDK and provides implementations for multiple PlexusOne packages:

Package	Status	Description
omnisignal	✅ Implemented	Alert and incident ingestion
omniobserve	✅ Implemented	Telemetry export and data querying

Installation

go get github.com/plexusone/omni-newrelic

Usage

Signal Ingestion (omnisignal)

import (
    "github.com/plexusone/omnisignal"
    _ "github.com/plexusone/omni-newrelic/omnisignal" // Register New Relic provider
)

func main() {
    provider, err := omnisignal.New("newrelic", omnisignal.Config{
        APIKey: os.Getenv("NEW_RELIC_API_KEY"),
        Options: map[string]any{
            "account_id": 12345,
            "region":     "US", // or "EU"
        },
    })
    if err != nil {
        log.Fatal(err)
    }
    defer provider.Close()

    // Fetch incidents from the last 24 hours
    signals, err := provider.Fetch(ctx, omnisignal.FetchOptions{
        Since: time.Now().Add(-24 * time.Hour),
    })
    if err != nil {
        log.Fatal(err)
    }

    for _, sig := range signals {
        fmt.Printf("Signal: %s - %s\n", sig.ID, sig.Summary)
    }
}

Telemetry Export (omniobserve)

Import the package to register the New Relic telemetry provider:

import (
    "github.com/plexusone/omniobserve/observops"
    _ "github.com/plexusone/omni-newrelic/omniobserve" // Register New Relic provider
)

func main() {
    provider, err := observops.Open("newrelic",
        observops.WithAPIKey(os.Getenv("NEW_RELIC_LICENSE_KEY")),
        observops.WithServiceName("my-service"),
    )
    if err != nil {
        log.Fatal(err)
    }
    defer provider.Shutdown(context.Background())

    // Create metrics
    counter, _ := provider.Meter().Counter("requests_total")
    counter.Add(ctx, 1)

    // Create traces
    ctx, span := provider.Tracer().Start(ctx, "ProcessRequest")
    defer span.End()
}

Data Querying (omniobserve)

Query observability data from New Relic using NRQL, APM APIs, and entity search:

import "github.com/plexusone/omni-newrelic/omniobserve"

func main() {
    qp, err := omniobserve.NewQueryProvider(omniobserve.QueryConfig{
        APIKey:    os.Getenv("NEW_RELIC_API_KEY"),
        AccountID: 12345,
        Region:    "US",
    })
    if err != nil {
        log.Fatal(err)
    }
    defer qp.Close()

    // Execute NRQL queries
    result, err := qp.QueryNRQL(ctx, "SELECT count(*) FROM Transaction SINCE 1 hour ago")

    // List APM applications
    apps, err := qp.ListAPMApplications(ctx)

    // Search entities
    entities, err := qp.SearchEntities(ctx, omniobserve.EntitySearchOptions{
        Domain: "APM",
        Type:   "APPLICATION",
    })

    // Query logs
    logs, err := qp.QueryLogs(ctx, "level='ERROR'", 100, time.Hour)

    // Query distributed traces
    traces, err := qp.QueryTraces(ctx, "name='WebTransaction'", 50, time.Hour)
}

Configuration

omnisignal

Option	Type	Required	Description
APIKey	string	Yes	New Relic Personal API Key
account_id	int	Yes	New Relic Account ID
region	string	No	"US" (default) or "EU"

omniobserve (Telemetry Export)

Option	Type	Required	Description
WithAPIKey	string	Yes	New Relic License Key (Ingest)
WithServiceName	string	Yes	Service name for telemetry
WithNewRelicRegion	string	No	"us" (default) or "eu"

omniobserve (Data Query)

Option	Type	Required	Description
APIKey	string	Yes	New Relic Personal API Key (User key)
AccountID	int	Yes	New Relic Account ID
Region	string	No	"US" (default) or "EU"

Capabilities

omnisignal Provider

• Fetch: List incidents with filtering by time and status
• Acknowledge: Acknowledge open incidents
• Close: Close open incidents
• Streaming: Not supported (requires webhook configuration)

omniobserve Provider

Telemetry Export:

• Metrics (counters, gauges, histograms)
• Distributed tracing
• Structured logging with trace correlation

Data Query:

• NRQL query execution
• APM application listing and metrics
• Entity search across all domains
• Log querying via NRQL
• Distributed trace querying via NRQL

Related Packages

• omnisignal - Signal ingestion abstraction
• omniobserve - Observability abstraction
• signal-spec - Canonical signal data model
• newrelic-client-go - Official New Relic Go SDK

Changelog

See CHANGELOG.md for release history and RELEASE_NOTES_v0.1.0.md for detailed release notes.

License

MIT