runintegration

Documentation

Overview

Copyright 2020 New Relic Corporation. All rights reserved. SPDX-License-Identifier: Apache-2.0

Index

• Variables
• func LogDecorated(logger log.Entry, cmd commandapi.Command, args RunIntArgs) log.Entry
• func NewConfigFromCmdChannelRunInt(args RunIntArgs) config.ConfigEntry
• func NewHandler(definitionQ chan<- integration.Definition, il integration.InstancesLookup, ...) *cmdchannel.CmdHandler
• func NotifyPlatform(dmEmitter dm.Emitter, def integration.Definition, ev protocol.EventData)
• type RunIntArgs
  • func (a *RunIntArgs) Hash() string

Variables

var (
	ErrNoIntName     = errors.New("missing required \"integration_name\"")
	ErrIntNotAllowed = errors.New("integration not allowed to run/stop from command channel")
)

Errors

Functions

func LogDecorated

func LogDecorated(logger log.Entry, cmd commandapi.Command, args RunIntArgs) log.Entry

func NewConfigFromCmdChannelRunInt

func NewConfigFromCmdChannelRunInt(args RunIntArgs) config.ConfigEntry

newConfigFromCmdReq creates an integration config from a command request.

func NewHandler

func NewHandler(definitionQ chan<- integration.Definition, il integration.InstancesLookup, dmEmitter dm.Emitter, logger log.Entry) *cmdchannel.CmdHandler

NewHandler creates a cmd-channel handler for run-integration requests.

func NotifyPlatform

func NotifyPlatform(dmEmitter dm.Emitter, def integration.Definition, ev protocol.EventData)

Types

type RunIntArgs

type RunIntArgs struct {
	IntegrationName string   `json:"integration_name"`
	IntegrationArgs []string `json:"integration_args"`
}

func (*RunIntArgs) Hash

func (a *RunIntArgs) Hash() string

Hash hashes the run-integration request, so intergation can be required to stop using same arguments.