export field to add events

runtime/client_http_request.go

@@ -29,7 +29,6 @@ import (
 	"strings"
 	"time"
 
-	"github.com/opentracing/opentracing-go"
 	"github.com/pkg/errors"
 	"github.com/uber/zanzibar/v2/runtime/jsonwrapper"
 
@@ -219,7 +218,7 @@ func (req *ClientHTTPRequest) Do() (*ClientHTTPResponse, error) {
 
 	req.res.setRawHTTPResponse(res)
 
-	// generate events
+	// generate Events
 	if GetToCapture(ctx) {
 		// ReadAll, caches bytes internally so multiple calls will return the same data
 		rspBytes, err := req.res.ReadAll()
@@ -239,7 +238,7 @@ func (req *ClientHTTPRequest) Do() (*ClientHTTPResponse, error) {
 			}
 
 			if ec := GetEventContainer(ctx); ec != nil {
-				ec.events = append(ec.events, event)
+				ec.Events = append(ec.Events, event)
 			}
 		}
 	}

runtime/context_test.go

@@ -656,5 +656,5 @@ func TestEventContainer(t *testing.T) {
 	ctx = WithEventContainer(ctx, &EventContainer{})
 	ec := GetEventContainer(ctx)
 
-	assert.Equal(t, len(ec.events), 0)
+	assert.Equal(t, len(ec.Events), 0)
 }

runtime/events.go

@@ -22,7 +22,7 @@ package zanzibar
 
 // Context Variables
 const (
-	// ToCapture set to true if events have to be captured
+	// ToCapture set to true if Events have to be captured
 	ToCapture = "to_capture"
 )
 
@@ -40,9 +40,9 @@ type Event interface {
 	Name() string
 }
 
-// EventContainer holds generated events.
+// EventContainer holds generated Events.
 type EventContainer struct {
-	events []Event
+	Events []Event
 }
 
 // ThriftOutgoingEvent captures request and response data
@@ -118,7 +118,7 @@ type HTTPCapture struct {
 	RspBody       []byte
 }
 
-// NoOpEventHandler ignored events
+// NoOpEventHandler ignored Events
 func NoOpEventHandler(events []Event) error {
 	return nil
 }

runtime/router.go

@@ -26,7 +26,6 @@ import (
 	"net/http"
 	"net/url"
 
-	"github.com/opentracing/opentracing-go"
 	"github.com/pborman/uuid"
 	"github.com/pkg/errors"
 	"github.com/uber-go/tally"
@@ -177,12 +176,12 @@ func (endpoint *RouterEndpoint) HandleRequest(
 	endpoint.HandlerFn(ctx, req, req.res)
 	req.res.flush(ctx)
 
-	// retrieve the container to see if any events are generated?
+	// retrieve the container to see if any Events are generated?
 	if GetToCapture(ctx) {
 		ec := GetEventContainer(ctx)
 		var events []Event
 		if ec != nil {
-			events = append(events, ec.events...)
+			events = append(events, ec.Events...)
 		}
 
 		event := &HTTPIncomingEvent{

runtime/tchannel_client.go

@@ -27,7 +27,6 @@ import (
 
 	"github.com/pkg/errors"
 	"github.com/uber-go/tally"
-	"github.com/uber/tchannel-go"
 	"github.com/uber/zanzibar/v2/runtime/ruleengine"
 	netContext "golang.org/x/net/context"
 )
@@ -303,7 +302,7 @@ func (c *TChannelClient) call(
 		}
 
 		if ec := GetEventContainer(ctx); ec != nil {
-			ec.events = append(ec.events, event)
+			ec.Events = append(ec.Events, event)
 		}
 	}