executor

Documentation

Index

• type Executor
  • func CreateExecutor(opts ...ExecutorOption) (*Executor, error)
  • func (e *Executor) ServeForEver() error
  • func (e *Executor) Shutdown() error
• type ExecutorOption
  • func WithAWSS3AccessKey(accessKey string) ExecutorOption
  • func WithAWSS3BucketName(bucketName string) ExecutorOption
  • func WithAWSS3Endpoint(endpoint string) ExecutorOption
  • func WithAWSS3InsecureSkipVerify(skipVerify bool) ExecutorOption
  • func WithAWSS3Region(region string) ExecutorOption
  • func WithAWSS3SecretAccessKey(secretAccessKey string) ExecutorOption
  • func WithAWSS3Secure(secure bool) ExecutorOption
  • func WithBackupPath(path string) ExecutorOption
  • func WithColoniesInsecure(insecure bool) ExecutorOption
  • func WithColoniesServerHost(host string) ExecutorOption
  • func WithColoniesServerPort(port int) ExecutorOption
  • func WithColonyID(id string) ExecutorOption
  • func WithColonyPrvKey(prvkey string) ExecutorOption
  • func WithDBDatabase(name string) ExecutorOption
  • func WithDBHost(host string) ExecutorOption
  • func WithDBPassword(password string) ExecutorOption
  • func WithDBPort(port int) ExecutorOption
  • func WithDBUser(user string) ExecutorOption
  • func WithExecutorID(id string) ExecutorOption
  • func WithExecutorPrvKey(key string) ExecutorOption
  • func WithFullbackups(count int) ExecutorOption
• type Result
  • func (r *Result) ToJSON() (string, error)

Types

type Executor

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

func CreateExecutor

func CreateExecutor(opts ...ExecutorOption) (*Executor, error)

func (*Executor) ServeForEver

func (e *Executor) ServeForEver() error

func (*Executor) Shutdown

func (e *Executor) Shutdown() error

type ExecutorOption

type ExecutorOption func(*Executor)

func WithAWSS3AccessKey

func WithAWSS3AccessKey(accessKey string) ExecutorOption

func WithAWSS3BucketName

func WithAWSS3BucketName(bucketName string) ExecutorOption

func WithAWSS3Endpoint

func WithAWSS3Endpoint(endpoint string) ExecutorOption

func WithAWSS3InsecureSkipVerify

func WithAWSS3InsecureSkipVerify(skipVerify bool) ExecutorOption

func WithAWSS3Region

func WithAWSS3Region(region string) ExecutorOption

func WithAWSS3SecretAccessKey

func WithAWSS3SecretAccessKey(secretAccessKey string) ExecutorOption

func WithAWSS3Secure

func WithAWSS3Secure(secure bool) ExecutorOption

func WithBackupPath

func WithBackupPath(path string) ExecutorOption

func WithColoniesInsecure

func WithColoniesInsecure(insecure bool) ExecutorOption

func WithColoniesServerHost

func WithColoniesServerHost(host string) ExecutorOption

func WithColoniesServerPort

func WithColoniesServerPort(port int) ExecutorOption

func WithColonyID

func WithColonyID(id string) ExecutorOption

func WithColonyPrvKey

func WithColonyPrvKey(prvkey string) ExecutorOption

func WithDBDatabase

func WithDBDatabase(name string) ExecutorOption

func WithDBHost

func WithDBHost(host string) ExecutorOption

func WithDBPassword

func WithDBPassword(password string) ExecutorOption

func WithDBPort

func WithDBPort(port int) ExecutorOption

func WithDBUser

func WithDBUser(user string) ExecutorOption

func WithExecutorID

func WithExecutorID(id string) ExecutorOption

func WithExecutorPrvKey

func WithExecutorPrvKey(key string) ExecutorOption

func WithFullbackups

func WithFullbackups(count int) ExecutorOption

type Result

type Result struct {
	Filename         string `json:"filename"`
	Bucket           string `json:"bucket"`
	FilePathS3       string `json:"filepath_s3"`
	ExecTimeBackup   int64  `json:"exectime_backup"`
	Size             int64  `json:"size"`
	SizeS3           int64  `json:"size_s3"`
	ExecTimeUploadS3 int64  `json:"exectime_upload_s3"`
}

func (*Result) ToJSON

func (r *Result) ToJSON() (string, error)