event

type APIManager interface {
	// not passing ODPConfig here to avoid multiple mutex lock calls inside the batch events loop
	SendOdpEvents(apiKey, apiHost string, events []Event) (canRetry bool, err error)
}

type BatchEventManager struct {
	// contains filtered or unexported fields
}

type DefaultEventAPIManager struct {
	// contains filtered or unexported fields
}

type EMOptionFunc func(em *BatchEventManager)

type Event struct {
	Type        string                 `json:"type"`
	Action      string                 `json:"action"`
	Identifiers map[string]string      `json:"identifiers"`
	Data        map[string]interface{} `json:"data"`
}

type Manager interface {
	// odpConfig is required here since it can be updated anytime and ticker needs to be aware of latest changes
	Start(ctx context.Context, odpConfig config.Config)
	IdentifyUser(apiKey, apiHost, userID string)
	ProcessEvent(apiKey, apiHost string, odpEvent Event) error
	FlushEvents(apiKey, apiHost string)
}