Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

event

package

Go to main page

Versions in this module

v2

v2.3.1

Jan 22, 2026

v2.3.0

Dec 12, 2025

v2.2.1

Oct 24, 2025

v2.2.0

Sep 30, 2025

Changes in this version

+ var EventEndPoints = map[string]string

+ var SupportedRegions = map[string]bool

type Batch

+ Region string

type Context

+ Region string

type DecisionMetadata

+ CmabUUID *string

v2.1.0

Nov 8, 2024

v2.0.0

Jan 22, 2024

Changes in this version

+ const CloseEventDispatchTimeout

+ const CloseEventDispatchWaitTime

+ const DefaultBatchSize

+ const DefaultEventEndPoint

+ const DefaultEventFlushInterval

+ const DefaultEventQueueSize

+ var ClientName = "go-sdk"

+ var Version = "2.0.0"

+ type BPOptionConfig func(qp *BatchEventProcessor)

+ func WithBatchSize(bsize int) BPOptionConfig

+ func WithEventDispatcher(d Dispatcher) BPOptionConfig

+ func WithEventDispatcherMetrics(metricsRegistry metrics.Registry) BPOptionConfig

+ func WithEventEndPoint(endPoint string) BPOptionConfig

+ func WithFlushInterval(flushInterval time.Duration) BPOptionConfig

+ func WithQueue(q Queue) BPOptionConfig

+ func WithQueueSize(qsize int) BPOptionConfig

+ func WithSDKKey(sdkKey string) BPOptionConfig

+ type Batch struct

+ AccountID string

+ AnonymizeIP bool

+ ClientName string

+ ClientVersion string

+ EnrichDecisions bool

+ ProjectID string

+ Revision string

+ Visitors []Visitor

+ type BatchEventProcessor struct

+ BatchSize int

+ EventDispatcher Dispatcher

+ EventEndPoint string

+ FlushInterval time.Duration

+ MaxQueueSize int

+ Q Queue

+ Ticker *time.Ticker

+ func NewBatchEventProcessor(options ...BPOptionConfig) *BatchEventProcessor

+ func (p *BatchEventProcessor) OnEventDispatch(callback func(logEvent LogEvent)) (int, error)

+ func (p *BatchEventProcessor) ProcessEvent(event UserEvent) bool

+ func (p *BatchEventProcessor) RemoveOnEventDispatch(id int) error

+ func (p *BatchEventProcessor) Start(ctx context.Context)

+ type Context struct

+ AccountID string

+ AnonymizeIP bool

+ BotFiltering bool

+ ClientName string

+ ClientVersion string

+ ProjectID string

+ Revision string

+ func CreateEventContext(projectConfig config.ProjectConfig) Context

+ type ConversionEvent struct

+ Attributes []VisitorAttribute

+ EntityID string

+ Key string

+ Revenue *int64

+ Tags map[string]interface{}

+ Value *float64

+ type Decision struct

+ CampaignID string

+ ExperimentID string

+ Metadata DecisionMetadata

+ VariationID string

+ type DecisionMetadata struct

+ Enabled bool

+ FlagKey string

+ RuleKey string

+ RuleType string

+ VariationKey string

+ type Dispatcher interface

+ DispatchEvent func(event LogEvent) (bool, error)

+ func NewHTTPEventDispatcher(sdkKey string, requester *utils.HTTPRequester, ...) Dispatcher

+ type ImpressionEvent struct

+ Attributes []VisitorAttribute

+ CampaignID string

+ EntityID string

+ ExperimentID string

+ Key string

+ Metadata DecisionMetadata

+ VariationID string

+ type InMemoryQueue struct

+ MaxSize int

+ Mux sync.Mutex

+ Queue []interface{}

+ func (q *InMemoryQueue) Add(item interface{})

+ func (q *InMemoryQueue) Get(count int) []interface{}

+ func (q *InMemoryQueue) Remove(count int) []interface{}

+ func (q *InMemoryQueue) Size() int

+ type LogEvent struct

+ EndPoint string

+ Event Batch

+ type Processor interface

+ OnEventDispatch func(callback func(logEvent LogEvent)) (int, error)

+ ProcessEvent func(event UserEvent) bool

+ RemoveOnEventDispatch func(id int) error

+ type Queue interface

+ Add func(item interface{})

+ Get func(count int) []interface{}

+ Remove func(count int) []interface{}

+ Size func() int

+ func NewInMemoryQueue(queueSize int) Queue

+ func NewInMemoryQueueWithLogger(queueSize int, logger logging.OptimizelyLogProducer) Queue

+ type QueueEventDispatcher struct

+ Dispatcher Dispatcher

+ func NewQueueEventDispatcher(sdkKey string, metricsRegistry metrics.Registry) *QueueEventDispatcher

+ func (ed *QueueEventDispatcher) DispatchEvent(event LogEvent) (bool, error)

+ type Snapshot struct

+ Decisions []Decision

+ Events []SnapshotEvent

+ type SnapshotEvent struct

+ EntityID string

+ Key string

+ Revenue *int64

+ Tags map[string]interface{}

+ Timestamp int64

+ UUID string

+ Value *float64

+ type UserEvent struct

+ Conversion *ConversionEvent

+ EventContext Context

+ Impression *ImpressionEvent

+ Timestamp int64

+ UUID string

+ VisitorID string

+ func CreateConversionUserEvent(projectConfig config.ProjectConfig, event entities.Event, ...) UserEvent

+ func CreateImpressionUserEvent(projectConfig config.ProjectConfig, experiment entities.Experiment, ...) (UserEvent, bool)

+ type Visitor struct

+ Attributes []VisitorAttribute

+ Snapshots []Snapshot

+ VisitorID string

+ type VisitorAttribute struct

+ AttributeType string

+ EntityID string

+ Key string

+ Value interface{}

Other modules containing this package

github.com/optimizely/go-sdk