handlers

Documentation

Index

• func BackupScheduleHandler(ctx context.Context, driver db.DBConnector, schedule types.BackupSchedule, ...) error
• func CancelYdbOperation(ctx context.Context, client client.ClientConnector, conn *ydb.Driver, ...) error
• func DBOperationHandler(ctx context.Context, operation types.Operation, db db.DBConnector, ...) error
• func DeleteBackupData(s3 s3.S3Connector, s3PathPrefix string, s3Bucket string) error
• func NewDBOperationHandler(db db.DBConnector, s3 s3.S3Connector, config config.Config, ...) types.OperationHandler
• func NewRBOperationHandler(db db.DBConnector, client client.ClientConnector, config config.Config) types.OperationHandler
• func NewTBOperationHandler(db db.DBConnector, client client.ClientConnector, s3 s3.S3Connector, ...) types.OperationHandler
• func RBOperationHandler(ctx context.Context, operation types.Operation, db db.DBConnector, ...) error
• func TBOperationHandler(ctx context.Context, operation types.Operation, db db.DBConnector, ...) error
• type BackupScheduleHandlerType
  • func NewBackupScheduleHandler(clientConn client.ClientConnector, s3 config.S3Config, ...) BackupScheduleHandlerType
• type LookupYdbOperationResponse
  • func (r *LookupYdbOperationResponse) IssueString() string

Functions

func BackupScheduleHandler

func BackupScheduleHandler(
	ctx context.Context,
	driver db.DBConnector,
	schedule types.BackupSchedule,
	now time.Time,
	clientConn client.ClientConnector,
	s3 config.S3Config,
	clientConfig config.ClientConnectionConfig,
	queryBuilderFactory queries.WriteQueryBulderFactory,
) error

func CancelYdbOperation

func CancelYdbOperation(
	ctx context.Context, client client.ClientConnector, conn *ydb.Driver,
	operation types.Operation, ydbOperationId string, reason string,
) error

func DBOperationHandler

func DBOperationHandler(
	ctx context.Context,
	operation types.Operation,
	db db.DBConnector,
	s3 s3.S3Connector,
	config config.Config,
	queryBuilderFactory queries.WriteQueryBulderFactory,
) error

func DeleteBackupData

func DeleteBackupData(s3 s3.S3Connector, s3PathPrefix string, s3Bucket string) error

func NewDBOperationHandler

func NewDBOperationHandler(
	db db.DBConnector,
	s3 s3.S3Connector,
	config config.Config,
	queryBulderFactory queries.WriteQueryBulderFactory,
) types.OperationHandler

func NewRBOperationHandler

func NewRBOperationHandler(
	db db.DBConnector, client client.ClientConnector, config config.Config,
) types.OperationHandler

func NewTBOperationHandler

func NewTBOperationHandler(
	db db.DBConnector, client client.ClientConnector, s3 s3.S3Connector, config config.Config,
	queryBulderFactory queries.WriteQueryBulderFactory,
) types.OperationHandler

func RBOperationHandler

func RBOperationHandler(
	ctx context.Context,
	operation types.Operation,
	db db.DBConnector,
	client client.ClientConnector,
	config config.Config,
) error

func TBOperationHandler

func TBOperationHandler(
	ctx context.Context,
	operation types.Operation,
	db db.DBConnector,
	client client.ClientConnector,
	s3 s3.S3Connector,
	config config.Config,
	queryBuilderFactory queries.WriteQueryBulderFactory,
) error

Types

type BackupScheduleHandlerType

type BackupScheduleHandlerType func(context.Context, db.DBConnector, types.BackupSchedule, time.Time) error

func NewBackupScheduleHandler

func NewBackupScheduleHandler(
	clientConn client.ClientConnector,
	s3 config.S3Config,
	clientConfig config.ClientConnectionConfig,
	queryBuilderFactory queries.WriteQueryBulderFactory,
) BackupScheduleHandlerType

type LookupYdbOperationResponse

type LookupYdbOperationResponse struct {
	// contains filtered or unexported fields
}

func (*LookupYdbOperationResponse) IssueString

func (r *LookupYdbOperationResponse) IssueString() string