Interface IKNetSourceConnector

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

Helper interface for KNetSourceConnector<TSourceConnector, TTask>

public interface IKNetSourceConnector : IKNetConnector, IKNetCommon, IKNetConnectLogging, IConnector, IVersion

Inherited Members

IKNetConnector.Properties

IKNetConnector.AllocateTask(long)

IKNetConnector.ConnectorName

IKNetConnector.TaskClassType

IKNetConnector.Start(IReadOnlyDictionary<string, string>)

IKNetConnector.TaskConfigs(int, int, IDictionary<string, string>)

IKNetCommon.ExecuteOnRemote(string, params object[])

IKNetCommon.ExecuteOnRemote<T>(string, params object[])

IKNetConnectLogging.Name

IKNetConnectLogging.IsTraceEnabled

IKNetConnectLogging.LogTrace(string)

IKNetConnectLogging.LogTrace(string, JVMBridgeException)

IKNetConnectLogging.LogTrace(string, params object[])

IKNetConnectLogging.IsDebugEnabled

IKNetConnectLogging.LogDebug(string)

IKNetConnectLogging.LogDebug(string, JVMBridgeException)

IKNetConnectLogging.LogDebug(string, params object[])

IKNetConnectLogging.IsInfoEnabled

IKNetConnectLogging.LogInfo(string)

IKNetConnectLogging.LogInfo(string, JVMBridgeException)

IKNetConnectLogging.LogInfo(string, params object[])

IKNetConnectLogging.IsWarnEnabled

IKNetConnectLogging.LogWarn(string)

IKNetConnectLogging.LogWarn(string, JVMBridgeException)

IKNetConnectLogging.LogWarn(string, params object[])

IKNetConnectLogging.IsErrorEnabled

IKNetConnectLogging.LogError(string)

IKNetConnectLogging.LogError(string, JVMBridgeException)

IKNetConnectLogging.LogError(string, params object[])

IConnector.Initialize(ConnectorContext)

IConnector.Initialize(ConnectorContext, List<Map<String, String>>)

IConnector.Start(Map<String, String>)

IConnector.Reconfigure(Map<String, String>)

IConnector.TaskClass()

IConnector.TaskConfigs(int)

IConnector.Stop()

IConnector.Validate(Map<String, String>)

IConnector.Config()

IVersion.Version()

Properties

CanDefineTransactionBoundaries

Implement the method to return the ConnectorTransactionBoundaries value

ConnectorTransactionBoundaries CanDefineTransactionBoundaries { get; }

Property Value

ConnectorTransactionBoundaries

Context

The SourceConnectorContext

SourceConnectorContext Context { get; }

Property Value

SourceConnectorContext

ExactlyOnceSupport

Implement the method to return the ExactlyOnceSupport value

ExactlyOnceSupport ExactlyOnceSupport { get; }

Property Value

ExactlyOnceSupport