Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

instrumentation

package

Go to main page

Versions in this module

v0

v0.1.15

Jun 19, 2019

v0.1.14

Jun 19, 2019

v0.1.13

Jun 17, 2019

v0.1.12

Jun 14, 2019

Changes in this version

+ const APPD_ATTACH_FAILED

v0.1.11

Jun 12, 2019

Changes in this version

+ const ANNOTATION_UPDATE_ERROR

+ const APPD_AGENT_ID

+ const APPD_APPID

+ const APPD_ASSOCIATE_ERROR

+ const APPD_ATTACH_DEPLOYMENT

+ const APPD_ATTACH_PENDING

+ const APPD_NODEID

+ const APPD_NODENAME

+ const APPD_SECRET_KEY_NAME

+ const APPD_SECRET_NAME

+ const APPD_TIERID

+ const ATTACHED_ANNOTATION

+ const DEFAULT_EXEC_CMD

+ const DEPLOY_ANNOTATION

+ const DEPLOY_BIQ_ANNOTATION

+ const ERROR_CODE

+ const GET_JAVA_PID_CMD

+ const MAX_INSTRUMENTATION_ATTEMPTS

+ func AgentInitExists(podSpec *v1.PodSpec, bag *m.AppDBag) bool

+ func AnalyticsAgentExists(podSpec *v1.PodSpec, bag *m.AppDBag) bool

+ func GetAgentRequestsForDeployment(deploy *appsv1.Deployment, bag *m.AppDBag, l *log.Logger) *m.AgentRequestList

+ func GetAttachMetadata(appTag string, tierTag string, deploy *appsv1.Deployment, bag *m.AppDBag) (string, string, string)

+ func GetVolumePath(bag *m.AppDBag, r *m.AgentRequest) string

+ func IsPodInstrumented(podObj *v1.Pod, l *log.Logger) bool

+ func ShouldInstrumentDeployment(deployObj *appsv1.Deployment, bag *m.AppDBag, pendingCache *[]string, ...) (bool, bool, *m.AgentRequestList)

+ type AgentInjector struct

+ AppdController *app.ControllerClient

+ Bag *m.AppDBag

+ ClientSet *kubernetes.Clientset

+ K8sConfig *rest.Config

+ Logger *log.Logger

+ func NewAgentInjector(client *kubernetes.Clientset, config *rest.Config, bag *m.AppDBag, ...) AgentInjector

+ func (ai AgentInjector) Associate(podObj *v1.Pod, exec *Executor, agentRequest *m.AgentRequest) error

+ func (ai AgentInjector) EnsureInstrumentation(statusChanel chan m.AttachStatus, podObj *v1.Pod, podSchema *m.PodSchema) error

+ func (ai AgentInjector) RetryAssociate(podObj *v1.Pod, agentRequest *m.AgentRequest) error

+ type DotNetInjector struct

+ AppdController *app.ControllerClient

+ Bag *m.AppDBag

+ func NewDotNetInjector(bag *m.AppDBag, appdController *app.ControllerClient) DotNetInjector

+ func (dni *DotNetInjector) AddEnvVars(container *v1.Container, agentRequest *m.AgentRequest)

+ type Executor struct

+ ClientSet *kubernetes.Clientset

+ K8sConfig *rest.Config

+ Logger *log.Logger

+ func NewExecutor(clientSet *kubernetes.Clientset, config *rest.Config, l *log.Logger) Executor

+ func (exec *Executor) CopyFilesToPod(podObject *v1.Pod, containerName string, src string, dest string) (int, string, error)

+ func (exec *Executor) RunCommand(podObject *v1.Pod, cmd string, args string) (int, string, error)

+ func (exec *Executor) RunCommandInPod(podName string, namespace string, containerName string, cmd string, ...) (int, string, error)

+ type Writer struct

+ Str []string

+ func (w *Writer) GetOutput() string

+ func (w *Writer) Write(p []byte) (n int, err error)