Skip to content

Commit 74f14fd

Browse files
[FSSDK-11915] Fix Go Region EU problem (#421)
* [FSSDK-11915] Fix Go Region EU problem * Implement suggested change request * Fix test case and correct the default endpoint assertion
1 parent fb5930d commit 74f14fd

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

pkg/event/processor.go

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -161,10 +161,6 @@ func NewBatchEventProcessor(options ...BPOptionConfig) *BatchEventProcessor {
161161
p.BatchSize = DefaultBatchSize
162162
}
163163

164-
if p.EventEndPoint == "" {
165-
p.EventEndPoint = EventEndPoints["US"]
166-
}
167-
168164
if p.BatchSize > p.MaxQueueSize {
169165
p.logger.Warning(
170166
fmt.Sprintf("Batch size %d is larger than queue size %d. Setting to defaults",

pkg/event/processor_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ func TestCustomEventProcessor_Create(t *testing.T) {
122122
func TestEndPointOptionEventProcessor(t *testing.T) {
123123
// Default end point
124124
processor := NewBatchEventProcessor()
125-
assert.Equal(t, EventEndPoints["US"], processor.EventEndPoint)
125+
assert.Equal(t, "", processor.EventEndPoint)
126126

127127
customEndPoint := "https://logx.optimizely.com"
128128
processor = NewBatchEventProcessor(
@@ -133,7 +133,7 @@ func TestEndPointOptionEventProcessor(t *testing.T) {
133133
func TestEndPointOptionEU(t *testing.T) {
134134
// Default end point
135135
processor := NewBatchEventProcessor()
136-
assert.Equal(t, EventEndPoints["US"], processor.EventEndPoint)
136+
assert.Equal(t, "", processor.EventEndPoint)
137137

138138
euEndpoint := EventEndPoints["EU"]
139139
processor = NewBatchEventProcessor(

0 commit comments

Comments
 (0)