scope specification support, initial

Author: tonyredondo

agent/agent.go

@@ -45,6 +45,7 @@ type (
 		recorder         *SpanRecorder
 		recorderFilename string
 		flushFrequency   time.Duration
+		concurrencyLevel int
 
 		optionalRecorders []tracer.SpanRecorder
 
@@ -61,8 +62,8 @@ type (
 var (
 	version = "0.1.13-pre"
 
-	testingModeFrequency    = time.Second
-	nonTestingModeFrequency = time.Minute
+	testingModeFrequency    = time.Duration(env.ScopeTracerDispatcherHealthcheckFrequencyInTestMode.Value) * time.Millisecond
+	nonTestingModeFrequency = time.Duration(env.ScopeTracerDispatcherHealthcheckFrequency.Value) * time.Millisecond
 )
 
 func WithApiKey(apiKey string) Option {
@@ -184,6 +185,7 @@ func NewAgent(options ...Option) (*Agent, error) {
 	agent.userAgent = fmt.Sprintf("scope-agent-go/%s", agent.version)
 	agent.panicAsFail = false
 	agent.failRetriesCount = 0
+	agent.concurrencyLevel = env.ScopeTracerDispatcherConcurrencyLevel.Value
 
 	for _, opt := range options {
 		opt(agent)

agent/recorder.go

@@ -41,9 +41,10 @@ type (
 		payloadSpans  []PayloadSpan
 		payloadEvents []PayloadEvent
 
-		flushFrequency time.Duration
-		url            string
-		client         *http.Client
+		flushFrequency   time.Duration
+		concurrencyLevel int
+		url              string
+		client           *http.Client
 
 		logger    *log.Logger
 		stats     *RecorderStats
@@ -79,9 +80,13 @@ func NewSpanRecorder(agent *Agent) *SpanRecorder {
 	r.metadata = agent.metadata
 	r.logger = agent.logger
 	r.flushFrequency = agent.flushFrequency
+	r.concurrencyLevel = agent.concurrencyLevel
 	r.url = agent.getUrl("api/agent/ingest")
 	r.client = &http.Client{}
 	r.stats = &RecorderStats{}
+
+	r.logger.Printf("recorder frequency: %v", agent.flushFrequency)
+	r.logger.Printf("recorder concurrency level: %v", agent.concurrencyLevel)
 	r.t.Go(r.loop)
 	return r
 }

env/vars.go

@@ -3,22 +3,25 @@ package env
 import "go.undefinedlabs.com/scopeagent/tags"
 
 var (
-	ScopeDsn                              = newStringEnvVar("", "SCOPE_DSN")
-	ScopeApiKey                           = newStringEnvVar("", "SCOPE_APIKEY")
-	ScopeApiEndpoint                      = newStringEnvVar("https://app.scope.dev", "SCOPE_API_ENDPOINT")
-	ScopeService                          = newStringEnvVar("default", "SCOPE_SERVICE")
-	ScopeRepository                       = newStringEnvVar("", "SCOPE_REPOSITORY")
-	ScopeCommitSha                        = newStringEnvVar("", "SCOPE_COMMIT_SHA")
-	ScopeBranch                           = newStringEnvVar("", "SCOPE_BRANCH")
-	ScopeSourceRoot                       = newStringEnvVar("", "SCOPE_SOURCE_ROOT")
-	ScopeLoggerRoot                       = newStringEnvVar("", "SCOPE_LOGGER_ROOT", "SCOPE_LOG_ROOT_PATH")
-	ScopeDebug                            = newBooleanEnvVar(false, "SCOPE_DEBUG")
-	ScopeTracerGlobal                     = newBooleanEnvVar(false, "SCOPE_TRACER_GLOBAL", "SCOPE_SET_GLOBAL_TRACER")
-	ScopeTestingMode                      = newBooleanEnvVar(false, "SCOPE_TESTING_MODE")
-	ScopeTestingFailRetries               = newIntEnvVar(0, "SCOPE_TESTING_FAIL_RETRIES")
-	ScopeTestingPanicAsFail               = newBooleanEnvVar(false, "SCOPE_TESTING_PANIC_AS_FAIL")
-	ScopeConfiguration                    = newSliceEnvVar([]string{tags.PlatformName, tags.PlatformArchitecture, tags.GoVersion}, "SCOPE_CONFIGURATION")
-	ScopeMetadata                         = newMapEnvVar(nil, "SCOPE_METADATA")
-	ScopeInstrumentationHttpPayloads      = newBooleanEnvVar(false, "SCOPE_INSTRUMENTATION_HTTP_PAYLOADS")
-	ScopeInstrumentationDbStatementValues = newBooleanEnvVar(false, "SCOPE_INSTRUMENTATION_DB_STATEMENT_VALUES")
+	ScopeDsn                                            = newStringEnvVar("", "SCOPE_DSN")
+	ScopeApiKey                                         = newStringEnvVar("", "SCOPE_APIKEY")
+	ScopeApiEndpoint                                    = newStringEnvVar("https://app.scope.dev", "SCOPE_API_ENDPOINT")
+	ScopeService                                        = newStringEnvVar("default", "SCOPE_SERVICE")
+	ScopeRepository                                     = newStringEnvVar("", "SCOPE_REPOSITORY")
+	ScopeCommitSha                                      = newStringEnvVar("", "SCOPE_COMMIT_SHA")
+	ScopeBranch                                         = newStringEnvVar("", "SCOPE_BRANCH")
+	ScopeSourceRoot                                     = newStringEnvVar("", "SCOPE_SOURCE_ROOT")
+	ScopeLoggerRoot                                     = newStringEnvVar("", "SCOPE_LOGGER_ROOT", "SCOPE_LOG_ROOT_PATH")
+	ScopeDebug                                          = newBooleanEnvVar(false, "SCOPE_DEBUG")
+	ScopeTracerGlobal                                   = newBooleanEnvVar(false, "SCOPE_TRACER_GLOBAL", "SCOPE_SET_GLOBAL_TRACER")
+	ScopeTestingMode                                    = newBooleanEnvVar(false, "SCOPE_TESTING_MODE")
+	ScopeTestingFailRetries                             = newIntEnvVar(0, "SCOPE_INSTRUMENTATION_TESTS_FRAMEWORKS_FAIL_RETRIES", "SCOPE_TESTING_FAIL_RETRIES")
+	ScopeTestingPanicAsFail                             = newBooleanEnvVar(false, "SCOPE_INSTRUMENTATION_TESTS_FRAMEWORKS_PANIC_AS_FAIL", "SCOPE_TESTING_PANIC_AS_FAIL")
+	ScopeConfiguration                                  = newSliceEnvVar([]string{tags.PlatformName, tags.PlatformArchitecture, tags.GoVersion}, "SCOPE_CONFIGURATION")
+	ScopeMetadata                                       = newMapEnvVar(nil, "SCOPE_METADATA")
+	ScopeInstrumentationHttpPayloads                    = newBooleanEnvVar(false, "SCOPE_INSTRUMENTATION_HTTP_PAYLOADS")
+	ScopeInstrumentationDbStatementValues               = newBooleanEnvVar(false, "SCOPE_INSTRUMENTATION_DB_STATEMENT_VALUES")
+	ScopeTracerDispatcherHealthcheckFrequency           = newIntEnvVar(60000, "SCOPE_TRACER_DISPATCHER_HEALTHCHECK_FRECUENCY")
+	ScopeTracerDispatcherHealthcheckFrequencyInTestMode = newIntEnvVar(1000, "SCOPE_TRACER_DISPATCHER_HEALTHCHECK_FRECUENCY_IN_TESTMODE")
+	ScopeTracerDispatcherConcurrencyLevel               = newIntEnvVar(1, "SCOPE_TRACER_DISPATCHER_CONCURRENCY_LEVEL")
 )