org.nuxeo.segment.io

Class SegmentIOComponent

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.segment.io.SegmentIOComponent

All Implemented Interfaces:

Adaptable, Component, Extensible, TimestampedService, SegmentIO

public class SegmentIOComponent
extends DefaultComponent
implements SegmentIO

Author:

Tiry

Field Summary

Fields

Modifier and Type	Field and Description
protected org.osgi.framework.Bundle	bundle
protected SegmentIOConfig	config
static String	CONFIG_EP
protected boolean	debugMode
protected static String	DEFAULT_DEBUG_KEY
protected Map<String,List<SegmentIOMapper>>	event2Mappers
static String	FILTERS_EP
protected com.github.segmentio.flush.Flusher	flusher
protected static org.apache.commons.logging.Log	log
static String	MAPPER_EP
protected Map<String,SegmentIOMapper>	mappers
static String	PROVIDER_EP
protected com.github.segmentio.models.Providers	providers
protected SegmentIOProviders	providersConfig
protected List<Map<String,Object>>	testData
protected SegmentIOUserFilter	userFilters
static String	WRITE_KEY

Fields inherited from class org.nuxeo.runtime.model.DefaultComponent

lastModified

Constructor Summary

Constructors

Constructor and Description
SegmentIOComponent()

Method Summary

Modifier and Type	Method and Description
void	activate(ComponentContext context) Activates the component.
void	applicationStarted(ComponentContext context) Notify the component that Nuxeo Framework finished starting all Nuxeo bundles.
protected void	computeEvent2Mappers()
void	deactivate(ComponentContext context) Deactivates the component.
void	flush()
Map<String,List<SegmentIOMapper>>	getAllMappers()
org.osgi.framework.Bundle	getBundle()
protected com.github.segmentio.flush.Flusher	getFlusher()
Map<String,String>	getGlobalParameters()
Set<String>	getMappedEvents()
Map<String,List<SegmentIOMapper>>	getMappers(List<String> events)
com.github.segmentio.models.Providers	getProviders()
List<Map<String,Object>>	getTestData()
SegmentIOUserFilter	getUserFilters()
String	getWriteKey()
protected void	group(String groupId, String userId, com.github.segmentio.models.Traits traits, com.github.segmentio.models.Context ctx)
void	identify(NuxeoPrincipal principal)
void	identify(NuxeoPrincipal principal, Map<String,Serializable> metadata)
protected boolean	mustTrackprincipal(String principalName)
protected void	pushForTest(String action, String principalName, String eventName, Map<String,Serializable> metadata)
void	registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor)
void	track(NuxeoPrincipal principal, String eventName)
void	track(NuxeoPrincipal principal, String eventName, Map<String,Serializable> metadata)

Methods inherited from class org.nuxeo.runtime.model.DefaultComponent

getAdapter, getApplicationStartedOrder, getLastModified, registerExtension, setLastModified, setModifiedNow, unregisterContribution, unregisterExtension

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static org.apache.commons.logging.Log log

DEFAULT_DEBUG_KEY

protected static final String DEFAULT_DEBUG_KEY

See Also:

Constant Field Values

WRITE_KEY

public static final String WRITE_KEY

See Also:

Constant Field Values

CONFIG_EP

public static final String CONFIG_EP

See Also:

Constant Field Values

MAPPER_EP

public static final String MAPPER_EP

See Also:

Constant Field Values

PROVIDER_EP

public static final String PROVIDER_EP

See Also:

Constant Field Values

FILTERS_EP

public static final String FILTERS_EP

See Also:

Constant Field Values

debugMode

protected boolean debugMode

mappers

protected Map<String,SegmentIOMapper> mappers

event2Mappers

protected Map<String,List<SegmentIOMapper>> event2Mappers

testData

protected List<Map<String,Object>> testData

config

protected SegmentIOConfig config

providersConfig

protected SegmentIOProviders providersConfig

userFilters

protected SegmentIOUserFilter userFilters

providers

protected com.github.segmentio.models.Providers providers

bundle

protected org.osgi.framework.Bundle bundle

flusher

protected com.github.segmentio.flush.Flusher flusher

Constructor Detail

SegmentIOComponent

public SegmentIOComponent()

Method Detail

getBundle

public org.osgi.framework.Bundle getBundle()

activate

public void activate(ComponentContext context)

Description copied from interface: Component

Activates the component.

This method is called by the runtime when a component is activated.

Specified by:

activate in interface Component

Overrides:

activate in class DefaultComponent

Parameters:

context - the runtime context

deactivate

public void deactivate(ComponentContext context)

Description copied from interface: Component

Deactivates the component.

This method is called by the runtime when a component is deactivated.

Specified by:

deactivate in interface Component

Overrides:

deactivate in class DefaultComponent

Parameters:

context - the runtime context

registerContribution

public void registerContribution(Object contribution,
                                 String extensionPoint,
                                 ComponentInstance contributor)

Overrides:

registerContribution in class DefaultComponent

applicationStarted

public void applicationStarted(ComponentContext context)

Description copied from interface: Component

Notify the component that Nuxeo Framework finished starting all Nuxeo bundles.

Specified by:

applicationStarted in interface Component

Overrides:

applicationStarted in class DefaultComponent

computeEvent2Mappers

protected void computeEvent2Mappers()

getWriteKey

public String getWriteKey()

Specified by:

getWriteKey in interface SegmentIO

getGlobalParameters

public Map<String,String> getGlobalParameters()

Specified by:

getGlobalParameters in interface SegmentIO

getFlusher

protected com.github.segmentio.flush.Flusher getFlusher()

identify

public void identify(NuxeoPrincipal principal)

Specified by:

identify in interface SegmentIO

getProviders

public com.github.segmentio.models.Providers getProviders()

Specified by:

getProviders in interface SegmentIO

identify

public void identify(NuxeoPrincipal principal,
                     Map<String,Serializable> metadata)

Specified by:

identify in interface SegmentIO

group

protected void group(String groupId,
                     String userId,
                     com.github.segmentio.models.Traits traits,
                     com.github.segmentio.models.Context ctx)

pushForTest

protected void pushForTest(String action,
                           String principalName,
                           String eventName,
                           Map<String,Serializable> metadata)

getTestData

public List<Map<String,Object>> getTestData()

mustTrackprincipal

protected boolean mustTrackprincipal(String principalName)

track

public void track(NuxeoPrincipal principal,
                  String eventName)

Specified by:

track in interface SegmentIO

track

public void track(NuxeoPrincipal principal,
                  String eventName,
                  Map<String,Serializable> metadata)

Specified by:

track in interface SegmentIO

flush

public void flush()

Specified by:

flush in interface SegmentIO

getMappers

public Map<String,List<SegmentIOMapper>> getMappers(List<String> events)

getMappedEvents

public Set<String> getMappedEvents()

getAllMappers

public Map<String,List<SegmentIOMapper>> getAllMappers()

getUserFilters

public SegmentIOUserFilter getUserFilters()

Specified by:

getUserFilters in interface SegmentIO