Enum Topic

Source

pub enum Topic {
Show 74 variants    IdpIdentityUserCreated,
    IdpIdentityUserUpdated,
    IdpIdentityUserDeleted,
    IdpIdentityUserAuthenticated,
    IdpIdentityTenantCreated,
    IdpIdentityTenantUpdated,
    IdpIdentityTenantDeleted,
    DsPipelineJobRequested,
    DsPipelineJobStarted,
    DsPipelineJobCompleted,
    DsPipelineJobFailed,
    DsPipelineInjectionTaskRequested,
    DsPipelineInjectionTaskQueued,
    DsPipelineInjectionTaskStarted,
    DsPipelineInjectionTaskCompleted,
    DsPipelineInjectionTaskFailed,
    DsPipelineInjectionMetricCreated,
    DsPipelineTransformTaskRequested,
    DsPipelineTransformTaskQueued,
    DsPipelineTransformTaskStarted,
    DsPipelineTransformTaskCompleted,
    DsPipelineTransformTaskFailed,
    DsPipelineTransformMetricCreated,
    DsPipelineMigratorTaskRequested,
    DsPipelineMigratorTaskQueued,
    DsPipelineMigratorTaskStarted,
    DsPipelineMigratorTaskCompleted,
    DsPipelineMigratorTaskFailed,
    DsPipelineMigratorMetricCreated,
    DsPipelineSynchronizerJobRequested,
    DsPipelineSynchronizerJobQueued,
    DsPipelineSynchronizerJobStarted,
    DsPipelineSynchronizerJobCompleted,
    DsPipelineSynchronizerJobFailed,
    DsPipelineSynchronizerTaskRequested,
    DsPipelineSynchronizerTaskQueued,
    DsPipelineSynchronizerTaskStarted,
    DsPipelineSynchronizerTaskCompleted,
    DsPipelineSynchronizerTaskFailed,
    DsPipelineSynchronizerMetricCreated,
    DsPipelineCloneJobRequested,
    DsPipelineCloneJobQueued,
    DsPipelineCloneJobStarted,
    DsPipelineCloneJobCompleted,
    DsPipelineCloneJobFailed,
    DsPipelineCloneMetricCreated,
    DsPipelineCloneTaskRequested,
    DsPipelineCloneTaskQueued,
    DsPipelineCloneTaskStarted,
    DsPipelineCloneTaskCompleted,
    DsPipelineCloneTaskFailed,
    DsWorkflowPipelineJobRequested,
    DsWorkflowPipelineJobQueued,
    DsWorkflowPipelineJobStarted,
    DsWorkflowPipelineJobCompleted,
    DsWorkflowPipelineJobFailed,
    DsWorkflowPipelineTaskStarted,
    DsWorkflowPipelineTaskCompleted,
    DsWorkflowPipelineTaskFailed,
    DsWorkflowPipelineCreated,
    DsWorkflowPipelineUpdated,
    DsWorkflowPipelineDeleted,
    DsWorkflowDatasetCreated,
    DsWorkflowDatasetUpdated,
    DsWorkflowDatasetDeleted,
    DsWorkflowLinkedServiceCreated,
    DsWorkflowLinkedServiceUpdated,
    DsWorkflowLinkedServiceDeleted,
    DsCoreProvisionJobRequested,
    DsCoreProvisionJobCompleted,
    DsCoreProvisionJobFailed,
    DsCoreConfigInfoUpdated,
    DsCoreConfigStatusUpdated,
    DsCoreBillingUsageCreated,
}

Expand description

This enum contains all the topics for the DS Event Stream.

§Topics

IdpIdentityUserCreated - The event when an identity user is created.
IdpIdentityUserUpdated - The event when an identity user is updated.
IdpIdentityUserDeleted - The event when an identity user is deleted.
IdpIdentityUserAuthenticated - The event when an identity user is authenticated.
IdpIdentityTenantCreated - The event when an identity tenant is created.
IdpIdentityTenantUpdated - The event when an identity tenant is updated.
IdpIdentityTenantDeleted - The event when an identity tenant is deleted.
DsPipelineJobRequested - The event when a pipeline job is requested.
DsPipelineJobStarted - The event when a pipeline job is started.
DsPipelineJobCompleted - The event when a pipeline job is completed.
DsPipelineJobFailed - The event when a pipeline job is failed.
DsPipelineInjectionTaskRequested - The event when a pipeline injection task is requested.
DsPipelineInjectionTaskQueued - The event when a pipeline injection task is queued.
DsPipelineInjectionTaskStarted - The event when a pipeline injection task is started.
DsPipelineInjectionTaskCompleted - The event when a pipeline injection task is completed.
DsPipelineInjectionTaskFailed - The event when a pipeline injection task is failed.
DsPipelineInjectionMetricCreated - The event when a pipeline injection metric is created.
DsPipelineTransformTaskRequested - The event when a pipeline transform task is requested.
DsPipelineTransformTaskQueued - The event when a pipeline transform task is queued.
DsPipelineTransformTaskStarted - The event when a pipeline transform task is started.
DsPipelineTransformTaskCompleted - The event when a pipeline transform task is completed.
DsPipelineTransformTaskFailed - The event when a pipeline transform task is failed.
DsPipelineTransformMetricCreated - The event when a pipeline transform metric is created.
DsPipelineMigratorTaskRequested - The event when a pipeline migrator task is requested.
DsPipelineMigratorTaskQueued - The event when a pipeline migrator task is queued.
DsPipelineMigratorTaskStarted - The event when a pipeline migrator task is started.
DsPipelineMigratorTaskCompleted - The event when a pipeline migrator task is completed.
DsPipelineMigratorTaskFailed - The event when a pipeline migrator task is failed.
DsPipelineMigratorMetricCreated - The event when a pipeline migrator metric is created.
DsPipelineSynchronizerJobRequested - The event when a pipeline synchronizer job is requested.
DsPipelineSynchronizerJobQueued - The event when a pipeline synchronizer job is queued.
DsPipelineSynchronizerJobStarted - The event when a pipeline synchronizer job is started.
DsPipelineSynchronizerJobCompleted - The event when a pipeline synchronizer job is completed.
DsPipelineSynchronizerJobFailed - The event when a pipeline synchronizer job is failed.
DsPipelineSynchronizerTaskRequested - The event when a pipeline synchronizer task is requested.
DsPipelineSynchronizerTaskQueued - The event when a pipeline synchronizer task is queued.
DsPipelineSynchronizerTaskStarted - The event when a pipeline synchronizer task is started.
DsPipelineSynchronizerTaskCompleted - The event when a pipeline synchronizer task is completed.
DsPipelineSynchronizerTaskFailed - The event when a pipeline synchronizer task is failed.
DsPipelineSynchronizerMetricCreated - The event when a pipeline synchronizer metric is created.
DsPipelineCloneJobRequested - The event when a pipeline clone job is requested.
DsPipelineCloneJobQueued - The event when a pipeline clone job is queued.
DsPipelineCloneJobStarted - The event when a pipeline clone job is started.
DsPipelineCloneJobCompleted - The event when a pipeline clone job is completed.
DsPipelineCloneJobFailed - The event when a pipeline clone job is failed.
DsPipelineCloneMetricCreated - The event when a pipeline clone metric is created.
DsPipelineCloneTaskRequested - The event when a pipeline clone task is requested.
DsPipelineCloneTaskQueued - The event when a pipeline clone task is queued.
DsPipelineCloneTaskStarted - The event when a pipeline clone task is started.
DsPipelineCloneTaskCompleted - The event when a pipeline clone task is completed.
DsPipelineCloneTaskFailed - The event when a pipeline clone task is failed.
DsWorkflowPipelineJobRequested - The event when a workflow pipeline job is requested.
DsWorkflowPipelineJobQueued - The event when a workflow pipeline job is queued.
DsWorkflowPipelineJobStarted - The event when a workflow pipeline job is started.
DsWorkflowPipelineJobCompleted - The event when a workflow pipeline job is completed.
DsWorkflowPipelineJobFailed - The event when a workflow pipeline job is failed.
DsWorkflowPipelineTaskStarted - The event when a workflow pipeline task is started.
DsWorkflowPipelineTaskCompleted - The event when a workflow pipeline task is completed.
DsWorkflowPipelineTaskFailed - The event when a workflow pipeline task is failed.
DsWorkflowPipelineCreated - The event when a workflow pipeline is created.
DsWorkflowPipelineUpdated - The event when a workflow pipeline is updated.
DsWorkflowPipelineDeleted - The event when a workflow pipeline is deleted.
DsWorkflowDatasetCreated - The event when a workflow dataset is created.
DsWorkflowDatasetUpdated - The event when a workflow dataset is updated.
DsWorkflowDatasetDeleted - The event when a workflow dataset is deleted.
DsWorkflowLinkedServiceCreated - The event when a workflow linked service is created.
DsWorkflowLinkedServiceUpdated - The event when a workflow linked service is updated.
DsWorkflowLinkedServiceDeleted - The event when a workflow linked service is deleted.
DsCoreProvisionJobRequested - The event when a core provision job is requested.
DsCoreProvisionJobCompleted - The event when a core provision job is completed.
DsCoreProvisionJobFailed - The event when a core provision job is failed.
DsCoreConfigInfoUpdated - The event when a core config info is updated.
DsCoreConfigStatusUpdated - The event when a core config status is updated.
DsCoreBillingUsageCreated - The event when a core billing usage is created.

Variants§

§

DsCoreBillingUsageCreated

Implementations§

Source §

impl Topic

Source

pub fn get_all_topics() -> Vec<Topic>

Get all the topics for the DS Event Stream.

§Returns

A vector of all topics for the DS Event Stream.

§Example

use ds_event_stream_rs_sdk::model::topics::Topic;
let topics = Topic::get_all_topics();
assert!(!topics.is_empty());

Source

pub fn filter_by_pattern(pattern: &str) -> Result<Vec<Topic>, UtilsError>

Filter topics by regex pattern.

§Arguments

pattern - A regex pattern to match against topic names

§Returns

A vector of topics that match the pattern

§Example

use ds_event_stream_rs_sdk::model::topics::Topic;
let pipeline_topics = Topic::filter_by_pattern(r"ds\.pipeline\.").unwrap();
assert!(!pipeline_topics.is_empty());