corrected constructor name

Author: pawels-optimizely

optimizely/client/factory.go

@@ -76,7 +76,7 @@ func (f OptimizelyFactory) StaticClient() (*OptimizelyClient, error) {
 // ClientWithOptions returns a client initialized with the given configuration options
 func (f OptimizelyFactory) ClientWithOptions(clientOptions Options) (*OptimizelyClient, error) {
 
-	executionCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	executionCtx := utils.NewCancelableExecutionCtx()
 	client := &OptimizelyClient{
 		isValid:      false,
 		executionCtx: executionCtx,

optimizely/config/polling_manager_test.go

@@ -48,7 +48,7 @@ func TestNewPollingProjectConfigManagerWithOptions(t *testing.T) {
 		Requester: mockRequester,
 	}
 
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	configManager := NewPollingProjectConfigManagerWithOptions(exeCtx, sdkKey, options)
 	mockRequester.AssertExpectations(t)
 
@@ -67,7 +67,7 @@ func TestNewPollingProjectConfigManagerWithNull(t *testing.T) {
 	options := PollingProjectConfigManagerOptions{
 		Requester: mockRequester,
 	}
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	configManager := NewPollingProjectConfigManagerWithOptions(exeCtx, sdkKey, options)
 	mockRequester.AssertExpectations(t)
 

optimizely/event/factory_test.go

@@ -91,7 +91,7 @@ func TestCreateAndSendImpressionEvent(t *testing.T) {
 
 	impressionUserEvent := BuildTestImpressionEvent()
 
-	processor := NewEventProcessor(utils.NewCancelableExecutionCtxExecutionCtx(), 10, 100, 100)
+	processor := NewEventProcessor(utils.NewCancelableExecutionCtx(), 10, 100, 100)
 
 	processor.ProcessEvent(impressionUserEvent)
 
@@ -106,7 +106,7 @@ func TestCreateAndSendConversionEvent(t *testing.T) {
 
 	conversionUserEvent := BuildTestConversionEvent()
 
-	processor := NewEventProcessor(utils.NewCancelableExecutionCtxExecutionCtx(), 10, 100, 100)
+	processor := NewEventProcessor(utils.NewCancelableExecutionCtx(), 10, 100, 100)
 
 	processor.ProcessEvent(conversionUserEvent)
 

optimizely/event/processor_test.go

@@ -15,7 +15,7 @@ func close(wg *sync.WaitGroup, cancelFn context.CancelFunc) {
 	wg.Wait()
 }
 func TestDefaultEventProcessor_ProcessImpression(t *testing.T) {
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	processor := NewEventProcessor(exeCtx, 10, 100, 100)
 
 	impression := BuildTestImpressionEvent()
@@ -41,7 +41,7 @@ func (f *MockDispatcher) DispatchEvent(event LogEvent) (bool, error) {
 }
 
 func TestDefaultEventProcessor_ProcessBatch(t *testing.T) {
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	processor := &QueueingEventProcessor{
 		MaxQueueSize:    100,
 		FlushInterval:   100,
@@ -78,7 +78,7 @@ func TestDefaultEventProcessor_ProcessBatch(t *testing.T) {
 }
 
 func TestBatchEventProcessor_FlushesOnClose(t *testing.T) {
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	processor := &QueueingEventProcessor{
 		MaxQueueSize:    100,
 		FlushInterval:   30 * time.Second,
@@ -106,7 +106,7 @@ func TestBatchEventProcessor_FlushesOnClose(t *testing.T) {
 }
 
 func TestDefaultEventProcessor_ProcessBatchRevisionMismatch(t *testing.T) {
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	processor := &QueueingEventProcessor{
 		MaxQueueSize:    100,
 		FlushInterval:   100,
@@ -144,7 +144,7 @@ func TestDefaultEventProcessor_ProcessBatchRevisionMismatch(t *testing.T) {
 }
 
 func TestDefaultEventProcessor_ProcessBatchProjectMismatch(t *testing.T) {
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	processor := &QueueingEventProcessor{
 		MaxQueueSize:    100,
 		FlushInterval:   100,
@@ -182,7 +182,7 @@ func TestDefaultEventProcessor_ProcessBatchProjectMismatch(t *testing.T) {
 }
 
 func TestChanQueueEventProcessor_ProcessImpression(t *testing.T) {
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	processor := &QueueingEventProcessor{
 		MaxQueueSize:    100,
 		FlushInterval:   100,
@@ -206,7 +206,7 @@ func TestChanQueueEventProcessor_ProcessImpression(t *testing.T) {
 }
 
 func TestChanQueueEventProcessor_ProcessBatch(t *testing.T) {
-	exeCtx := utils.NewCancelableExecutionCtxExecutionCtx()
+	exeCtx := utils.NewCancelableExecutionCtx()
 	processor := &QueueingEventProcessor{MaxQueueSize: 100, FlushInterval: 100, Q: NewChanQueue(100), EventDispatcher: &MockDispatcher{}, wg: exeCtx.GetWaitSync()}
 	processor.BatchSize = 10
 	processor.StartTicker(exeCtx.GetContext())

optimizely/utils/execution_context.go

@@ -40,8 +40,8 @@ type CancelableExecutionCtx struct {
 	CancelFunc context.CancelFunc
 }
 
-// NewCancelableExecutionCtxExecutionCtx returns constructed object
-func NewCancelableExecutionCtxExecutionCtx() *CancelableExecutionCtx {
+// NewCancelableExecutionCtx returns constructed object
+func NewCancelableExecutionCtx() *CancelableExecutionCtx {
 	ctx, cancelFn := context.WithCancel(context.Background())
 	var wg sync.WaitGroup