backup

package module

v0.0.0-...-b8b1ebd Latest Latest Go to latest Published: Feb 17, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ktenzer/temporal-demo-apps

Links

Open Source Insights

README ¶

Overview

Documentation ¶

Index ¶

func DrainManualSignals(ctx workflow.Context, signal BackupSignal, signalChan workflow.ReceiveChannel) error
func DrainScheduledSignals(ctx workflow.Context, signal BackupSignal, signalChan workflow.ReceiveChannel) error
func GetBackupState(hostname, port, backupId string) (string, error)
func SetCustomRetryPolicy(retryIntervalSeconds, maxIntervalSeconds, maxAttempts int) workflow.ActivityOptions
func SignalWorkflow(ctx workflow.Context) (string, error)
func SpawnManualChildWorkflow(ctx workflow.Context, signal BackupSignal) error
func SpawnScheduleChildWorkflow(ctx workflow.Context, signal BackupSignal) error
func UpdateBackupStatusSearchAttribute(ctx workflow.Context, queryResult string) error
type BackupSignal
type Result
type Status
type WorkflowResult

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DrainManualSignals ¶

func DrainManualSignals(ctx workflow.Context, signal BackupSignal, signalChan workflow.ReceiveChannel) error

func DrainScheduledSignals ¶

func DrainScheduledSignals(ctx workflow.Context, signal BackupSignal, signalChan workflow.ReceiveChannel) error

func GetBackupState ¶

func GetBackupState(hostname, port, backupId string) (string, error)

func SetCustomRetryPolicy ¶

func SetCustomRetryPolicy(retryIntervalSeconds, maxIntervalSeconds, maxAttempts int) workflow.ActivityOptions

func SignalWorkflow ¶

func SignalWorkflow(ctx workflow.Context) (string, error)

func SpawnManualChildWorkflow ¶

func SpawnManualChildWorkflow(ctx workflow.Context, signal BackupSignal) error

func SpawnScheduleChildWorkflow ¶

func SpawnScheduleChildWorkflow(ctx workflow.Context, signal BackupSignal) error

func UpdateBackupStatusSearchAttribute ¶

func UpdateBackupStatusSearchAttribute(ctx workflow.Context, queryResult string) error

Types ¶

type BackupSignal ¶

type BackupSignal struct {
	Action       string `json:"action"`
	AppName      string `json:"appName"`
	BackupId     string `json:"backupId"`
	CronSchedule string `json:"cronSchedule"`
}

type Result ¶

type Result struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

func Backup ¶

func Backup(hostname, port, backupId string) (Result, error)

func BackupActivity ¶

func BackupActivity(ctx context.Context, backupId string) (Result, error)

func Quiesce ¶

func Quiesce(hostname, port, backupId string) (Result, error)

func QuiesceActivity ¶

func QuiesceActivity(ctx context.Context, backupId string) (Result, error)

func UnQuiesce ¶

func UnQuiesce(hostname, port, backupId string) (Result, error)

func UnQuiesceActivity ¶

func UnQuiesceActivity(ctx context.Context, backupId string) (Result, error)

type Status ¶

type Status struct {
	Msg     string `json:"msg"`
	Version string `json:"version"`
}

type WorkflowResult ¶

type WorkflowResult struct {
	Id       string   `json:"id"`
	AppName  string   `json:"appName"`
	Code     int      `json:"code"`
	Messages []string `json:"message"`
	State    string   `json:"state"`
}

func ChildWorkflow ¶

func ChildWorkflow(ctx workflow.Context, signal BackupSignal) (WorkflowResult, error)

func RunBackup ¶

func RunBackup(ctx workflow.Context, workflowResult WorkflowResult) (WorkflowResult, string, error)

func RunQuiesce ¶

func RunQuiesce(ctx workflow.Context, workflowResult WorkflowResult) (WorkflowResult, string, error)

func RunUnQuiesce ¶

func RunUnQuiesce(ctx workflow.Context, workflowResult WorkflowResult) (WorkflowResult, string, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cron
schedule
service
signaler
starter
worker

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL