Package com.snowflake.connectors.application.lifecycle

Class DefaultLifecycleService

java.lang.Object

com.snowflake.connectors.application.lifecycle.DefaultLifecycleService

All Implemented Interfaces:

LifecycleService

public class DefaultLifecycleService
extends Object
implements LifecycleService

Default implementation of LifecycleService.

Field Summary

Fields inherited from interface com.snowflake.connectors.application.lifecycle.LifecycleService

ROLLBACK_CODE, UNKNOWN_ERROR_CODE

Constructor Summary

Constructors

Constructor	Description
DefaultLifecycleService(PrivilegeTools privilegeTools, ConnectorStatusService statusService, ConnectorStatus statusAfterRollback)	Creates a new DefaultLifecycleService.

Method Summary

Modifier and Type	Method	Description
void	updateStatus(ConnectorStatus status)	Updates the connector status to a provided one.
void	validateRequiredPrivileges()	Validates whether the application instance has been granted all privileges necessary to run the lifecycle processes.
void	validateStatus(ConnectorStatus... statuses)	Validates if the current connector status contains provided ones.
ConnectorResponse	withRollbackHandling(Supplier<ConnectorResponse> action)	Executes the specified action with handling of rollback and unexpected errors.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultLifecycleService

public DefaultLifecycleService(PrivilegeTools privilegeTools,
                               ConnectorStatusService statusService,
                               ConnectorStatus statusAfterRollback)

Creates a new DefaultLifecycleService.

Parameters:

privilegeTools - privilege tools instance

statusService - connector status service instance

statusAfterRollback - connector status set after connector rollback

Method Detail

validateStatus

public void validateStatus(ConnectorStatus... statuses)

Description copied from interface: LifecycleService

Validates if the current connector status contains provided ones.

Specified by:

validateStatus in interface LifecycleService

Parameters:

statuses - expected connector statuses

updateStatus

public void updateStatus(ConnectorStatus status)

Description copied from interface: LifecycleService

Updates the connector status to a provided one.

Specified by:

updateStatus in interface LifecycleService

Parameters:

status - new connector status

validateRequiredPrivileges

public void validateRequiredPrivileges()

Description copied from interface: LifecycleService

Validates whether the application instance has been granted all privileges necessary to run the lifecycle processes.

Specified by:

validateRequiredPrivileges in interface LifecycleService

withRollbackHandling

public ConnectorResponse withRollbackHandling(Supplier<ConnectorResponse> action)

Description copied from interface: LifecycleService

Executes the specified action with handling of rollback and unexpected errors.

If a ROLLBACK code was returned by the action - the connector status is updated accordingly and the action response is returned by this method.

If an unexpected exception has been thrown during the action execution - a response with an UNKNOWN_ERROR code is returned by this method.

Specified by:

withRollbackHandling in interface LifecycleService

Parameters:

action - an action to execute

Returns:

a response with the code OK if the execution was successful, a response with the code ROLLBACK if the action performed a rollback operation, or a response with an UNKNOWN_ERROR code and an error message