integration

package

Go to main page

Versions in this module

v2

v2.1.0

Oct 2, 2024

Changes in this version

+ const LAST_UPDATE_COMPONENT_ID_ATTR_NAME

+ const LAST_UPDATE_EVENT_TYPE

+ const LAST_UPDATE_INTEGRATION_ID_ATTR_NAME

+ type Component interface

+ Execute func(ctx context.Context) error

+ ExecuteSync func(ctx context.Context) error

+ Shutdown func(ctx context.Context) error

+ Start func(ctx context.Context, wg *sync.WaitGroup) error

+ type ExecuteSyncFunc func(ctx context.Context, li *LabsIntegration) error

+ type Identifiable interface

+ GetId func() string

type LabsIntegration

+ func (i *LabsIntegration) AddComponent(c Component)

+ func (i *LabsIntegration) AddEventImmediate(ctx context.Context, eventType string, attributes map[string]interface{}) error

+ func (i *LabsIntegration) AddLastUpdateTimestamp(ctx context.Context, componentId string) error

+ func (i *LabsIntegration) AddSchedule(crontab string, components []Component)

+ func (i *LabsIntegration) GetAccountId() int

+ func (i *LabsIntegration) GetLastUpdateTimestamp(ctx context.Context, componentId string) (*time.Time, error)

+ func (i *LabsIntegration) UseLastUpdate(ctx context.Context, lastUpdateFunc LastUpdateFunc, componentId string) error

type LabsIntegrationOpt

+ func WithLastUpdate() LabsIntegrationOpt

+ type LastUpdateFunc func(lastUpdate time.Time) error

+ type SimpleComponent struct

+ func NewSimpleComponent(id string, i *LabsIntegration, executeFunc ExecuteSyncFunc) *SimpleComponent

+ func (s *SimpleComponent) Execute(ctx context.Context) error

+ func (s *SimpleComponent) ExecuteSync(ctx context.Context) error

+ func (s *SimpleComponent) GetId() string

+ func (s *SimpleComponent) Start(ctx context.Context, wg *sync.WaitGroup) error

+ func (t *SimpleComponent) Shutdown(ctx context.Context) error

v2.0.0

Aug 29, 2024

Changes in this version

+ const DEFAULT_INTERVAL

+ func NewConfigWithFile(configFile string) error

+ func NewConfigWithPaths() error

+ type InfraIntegrationArgs struct

+ ConfigPath string

+ EnvPrefix string

+ ShowVersion bool

+ type LabsIntegration struct

+ App *newrelic.Application

+ BuildInfo build.BuildInfo

+ DryRun bool

+ Id string

+ Integration *nriSdk.Integration

+ Interval time.Duration

+ Logger *logrus.Logger

+ Name string

+ NrClient *nrClient.NewRelic

+ RunAsService bool

+ func NewInfraIntegration(name, id string, labsIntegrationOpts ...LabsIntegrationOpt) (*LabsIntegration, error)

+ func NewLambdaIntegration(name, id, appName string, labsIntegrationOpts ...LabsIntegrationOpt) (*LabsIntegration, error)

+ func NewStandaloneIntegration(name, id, appName string, labsIntegrationOpts ...LabsIntegrationOpt) (*LabsIntegration, error)

+ func (i *LabsIntegration) AddEvent(ctx context.Context, eventType string, attributes map[string]string) error

+ func (i *LabsIntegration) AddPipeline(p pipeline.Pipeline)

+ func (i *LabsIntegration) GetApiKey() string

+ func (i *LabsIntegration) GetLicenseKey() string

+ func (i *LabsIntegration) GetRegion() region.Name

+ func (i *LabsIntegration) Run(ctx context.Context) error

+ func (i *LabsIntegration) Shutdown(ctx context.Context)

+ type LabsIntegrationOpt func(li *LabsIntegration) error

+ func WithAccountId() LabsIntegrationOpt

+ func WithApiKey() LabsIntegrationOpt

+ func WithClient() LabsIntegrationOpt

+ func WithEvents(ctx context.Context) LabsIntegrationOpt

+ func WithInterval(defaultInterval int) LabsIntegrationOpt

+ func WithLicenseKey() LabsIntegrationOpt

+ func WithLogs(ctx context.Context) LabsIntegrationOpt

Other modules containing this package

github.com/newrelic/newrelic-labs-sdk

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