com.datasift.client.push

Class DataSiftPush

java.lang.Object

com.datasift.client.DataSiftApiClient

com.datasift.client.push.DataSiftPush

public class DataSiftPush
extends DataSiftApiClient

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	CREATE
java.lang.String	DELETE
java.lang.String	GET
java.lang.String	LOG
java.lang.String	PAUSE
java.lang.String	PULL
java.lang.String	RESUME
java.lang.String	STOP
java.lang.String	UPDATE
java.lang.String	VALIDATE

Fields inherited from class com.datasift.client.DataSiftApiClient

config

Constructor Summary

Constructors

Constructor and Description
DataSiftPush(DataSiftConfig config)

Method Summary

Modifier and Type	Method and Description
<T extends PushConnector> FutureData<PushSubscription>	create(T connector, FutureData<PreparedHistoricsQuery> historics, FutureData<Stream> stream, java.lang.String name)
<T extends PushConnector> FutureData<PushSubscription>	create(T connector, FutureData<PreparedHistoricsQuery> historics, FutureData<Stream> stream, java.lang.String name, Status initialStatus, long start, long end)
<T extends PushConnector> FutureData<PushSubscription>	create(T con, FutureData<PreparedHistoricsQuery> query, java.lang.String name)
<T extends PushConnector> FutureData<PushSubscription>	create(T connector, PreparedHistoricsQuery historics, java.lang.String name, Status initialStatus, long start, long end)
<T extends PushConnector> FutureData<PushSubscription>	create(T con, Stream stream, java.lang.String name)
<T extends PushConnector> FutureData<PushSubscription>	create(T connector, Stream stream, java.lang.String name, Status initialStatus, long start, long end)
FutureData<PushSubscription>	createPull(PullJsonType type, PreparedHistoricsQuery historics, Stream stream, java.lang.String name, Status initialStatus, long start, long end)
FutureData<PushSubscription>	createPull(PullJsonType jsonMeta, PreparedHistoricsQuery historics, java.lang.String name)
FutureData<PushSubscription>	createPull(PullJsonType jsonMeta, PreparedHistoricsQuery historics, java.lang.String name, Status initialStatus, long start, long end)
FutureData<PushSubscription>	createPull(PullJsonType jsonMeta, Stream stream, java.lang.String name)
FutureData<PushSubscription>	createPull(PullJsonType jsonMeta, Stream stream, java.lang.String name, Status initialStatus, long start, long end)
FutureData<DataSiftResult>	delete(java.lang.String id)
FutureData<PushCollection>	get(HistoricsQuery historics, int page, int perPage, java.lang.String orderBy, java.lang.String orderDirection, boolean includeFinished)
FutureData<PushCollection>	get(int page, int perPage, java.lang.String orderBy, java.lang.String orderDirection, boolean includeFinished)
FutureData<PushCollection>	get(Stream hash, int page, int perPage, java.lang.String orderBy, java.lang.String orderDirection, boolean includeFinished)
FutureData<PushSubscription>	get(java.lang.String id)
FutureData<PushLogMessages>	log(java.lang.String id, int page)
FutureData<PushLogMessages>	log(java.lang.String id, int page, int perPage, java.lang.String orderBy, java.lang.String orderDirection)
FutureData<PushSubscription>	pause(java.lang.String id)
FutureData<PulledInteractions>	pull(PushSubscription id)
FutureData<PulledInteractions>	pull(PushSubscription id, int size, java.lang.String cursor)
FutureData<PushSubscription>	resume(java.lang.String id)
protected void	sendPullRequest(FutureData<PulledInteractions> future, PushSubscription id, int size, java.lang.String cursor, java.net.URI uri, PullReader reader)
FutureData<PushSubscription>	stop(java.lang.String id)
FutureData<PushSubscription>	update(java.lang.String id, PushConnector connector)
FutureData<PushSubscription>	update(java.lang.String id, PushConnector connector, java.lang.String name)
<T extends PushConnector> FutureData<PushValidation>	validate(T connector)

Methods inherited from class com.datasift.client.DataSiftApiClient

failNotify, newParams, newRequestCallback, performRequest, unwrapFuture

Methods inherited from class java.lang.Object

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

Field Detail

VALIDATE

public final java.lang.String VALIDATE

See Also:

Constant Field Values

CREATE

public final java.lang.String CREATE

See Also:

Constant Field Values

PAUSE

public final java.lang.String PAUSE

See Also:

Constant Field Values

RESUME

public final java.lang.String RESUME

See Also:

Constant Field Values

UPDATE

public final java.lang.String UPDATE

See Also:

Constant Field Values

STOP

public final java.lang.String STOP

See Also:

Constant Field Values

DELETE

public final java.lang.String DELETE

See Also:

Constant Field Values

LOG

public final java.lang.String LOG

See Also:

Constant Field Values

GET

public final java.lang.String GET

See Also:

Constant Field Values

PULL

public final java.lang.String PULL

See Also:

Constant Field Values

Constructor Detail

DataSiftPush

public DataSiftPush(DataSiftConfig config)

Method Detail

pause

public FutureData<PushSubscription> pause(java.lang.String id)

resume

public FutureData<PushSubscription> resume(java.lang.String id)

stop

public FutureData<PushSubscription> stop(java.lang.String id)

delete

public FutureData<DataSiftResult> delete(java.lang.String id)

update

public FutureData<PushSubscription> update(java.lang.String id,
                                           PushConnector connector)

update

public FutureData<PushSubscription> update(java.lang.String id,
                                           PushConnector connector,
                                           java.lang.String name)

pull

public FutureData<PulledInteractions> pull(PushSubscription id)

pull

public FutureData<PulledInteractions> pull(PushSubscription id,
                                           int size,
                                           java.lang.String cursor)

sendPullRequest

protected void sendPullRequest(FutureData<PulledInteractions> future,
                               PushSubscription id,
                               int size,
                               java.lang.String cursor,
                               java.net.URI uri,
                               PullReader reader)

log

public FutureData<PushLogMessages> log(java.lang.String id,
                                       int page)

log

public FutureData<PushLogMessages> log(java.lang.String id,
                                       int page,
                                       int perPage,
                                       java.lang.String orderBy,
                                       java.lang.String orderDirection)

get

public FutureData<PushSubscription> get(java.lang.String id)

get

public FutureData<PushCollection> get(int page,
                                      int perPage,
                                      java.lang.String orderBy,
                                      java.lang.String orderDirection,
                                      boolean includeFinished)

get

public FutureData<PushCollection> get(Stream hash,
                                      int page,
                                      int perPage,
                                      java.lang.String orderBy,
                                      java.lang.String orderDirection,
                                      boolean includeFinished)

get

public FutureData<PushCollection> get(HistoricsQuery historics,
                                      int page,
                                      int perPage,
                                      java.lang.String orderBy,
                                      java.lang.String orderDirection,
                                      boolean includeFinished)

validate

public <T extends PushConnector> FutureData<PushValidation> validate(T connector)

create

public <T extends PushConnector> FutureData<PushSubscription> create(T connector,
                                                                     FutureData<PreparedHistoricsQuery> historics,
                                                                     FutureData<Stream> stream,
                                                                     java.lang.String name)

create

public <T extends PushConnector> FutureData<PushSubscription> create(T connector,
                                                                     PreparedHistoricsQuery historics,
                                                                     java.lang.String name,
                                                                     Status initialStatus,
                                                                     long start,
                                                                     long end)

create

public <T extends PushConnector> FutureData<PushSubscription> create(T con,
                                                                     FutureData<PreparedHistoricsQuery> query,
                                                                     java.lang.String name)

create

public <T extends PushConnector> FutureData<PushSubscription> create(T con,
                                                                     Stream stream,
                                                                     java.lang.String name)

create

public <T extends PushConnector> FutureData<PushSubscription> create(T connector,
                                                                     Stream stream,
                                                                     java.lang.String name,
                                                                     Status initialStatus,
                                                                     long start,
                                                                     long end)

createPull

public FutureData<PushSubscription> createPull(PullJsonType jsonMeta,
                                               PreparedHistoricsQuery historics,
                                               java.lang.String name,
                                               Status initialStatus,
                                               long start,
                                               long end)

createPull

public FutureData<PushSubscription> createPull(PullJsonType jsonMeta,
                                               PreparedHistoricsQuery historics,
                                               java.lang.String name)

createPull

public FutureData<PushSubscription> createPull(PullJsonType jsonMeta,
                                               Stream stream,
                                               java.lang.String name,
                                               Status initialStatus,
                                               long start,
                                               long end)

createPull

public FutureData<PushSubscription> createPull(PullJsonType jsonMeta,
                                               Stream stream,
                                               java.lang.String name)

createPull

public FutureData<PushSubscription> createPull(PullJsonType type,
                                               PreparedHistoricsQuery historics,
                                               Stream stream,
                                               java.lang.String name,
                                               Status initialStatus,
                                               long start,
                                               long end)

create

public <T extends PushConnector> FutureData<PushSubscription> create(T connector,
                                                                     FutureData<PreparedHistoricsQuery> historics,
                                                                     FutureData<Stream> stream,
                                                                     java.lang.String name,
                                                                     Status initialStatus,
                                                                     long start,
                                                                     long end)