Interface ManualActivityCompletionClientFactory

public interface ManualActivityCompletionClientFactory

Method Summary

Modifier and Type	Method	Description
ManualActivityCompletionClient	getClient(byte[] taskToken, com.uber.m3.tally.Scope metricsScope)
ManualActivityCompletionClient	getClient(byte[] taskToken, com.uber.m3.tally.Scope metricsScope, ActivitySerializationContext activitySerializationContext)
ManualActivityCompletionClient	getClient(byte[] taskToken, com.uber.m3.tally.Scope metricsScope, ActivitySerializationContext activitySerializationContext, StorageDriverTargetInfo storageTarget)
ManualActivityCompletionClient	getClient(io.temporal.api.common.v1.WorkflowExecution execution, String activityId, com.uber.m3.tally.Scope metricsScope)
ManualActivityCompletionClient	getClient(io.temporal.api.common.v1.WorkflowExecution execution, String activityId, com.uber.m3.tally.Scope metricsScope, ActivitySerializationContext activitySerializationContext)
static ManualActivityCompletionClientFactory	newFactory(io.temporal.serviceclient.WorkflowServiceStubs service, String namespace, String identity, DataConverter dataConverter)
static ManualActivityCompletionClientFactory	newFactory(io.temporal.serviceclient.WorkflowServiceStubs service, String namespace, String identity, DataConverter dataConverter, ExternalStorageRunner externalStorage)

Method Details

newFactory

static ManualActivityCompletionClientFactory newFactory(@Nonnull
 io.temporal.serviceclient.WorkflowServiceStubs service,
 @Nonnull
 String namespace,
 @Nonnull
 String identity,
 @Nonnull
 DataConverter dataConverter)

newFactory

static ManualActivityCompletionClientFactory newFactory(@Nonnull
 io.temporal.serviceclient.WorkflowServiceStubs service,
 @Nonnull
 String namespace,
 @Nonnull
 String identity,
 @Nonnull
 DataConverter dataConverter,
 @Nullable
 ExternalStorageRunner externalStorage)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 byte[] taskToken,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 byte[] taskToken,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope,
 @Nullable
 ActivitySerializationContext activitySerializationContext)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 byte[] taskToken,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope,
 @Nullable
 ActivitySerializationContext activitySerializationContext,
 @Nullable
 StorageDriverTargetInfo storageTarget)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 io.temporal.api.common.v1.WorkflowExecution execution,
 @Nonnull
 String activityId,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 io.temporal.api.common.v1.WorkflowExecution execution,
 @Nonnull
 String activityId,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope,
 @Nullable
 ActivitySerializationContext activitySerializationContext)