providers

package
v0.0.0-...-c77f481 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 9, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IProviderFactory

type IProviderFactory interface {
	GetProviders(config *Config) (*Providers, error)
}

Factory interface to init providers

type LocalProvider

type LocalProvider struct {
	BaseProvider
}

local provider runs on host pc

func (*LocalProvider) Data

func (l *LocalProvider) Data() *BaseProvider

a shortcut access to embedded struct in case of interface used as reference Value

func (*LocalProvider) DeleteFile

func (l *LocalProvider) DeleteFile()

remove file from local pc will be called if server mode or validation fails

func (*LocalProvider) Resume

func (l *LocalProvider) Resume()

if process suspended notifies pending routine to continue

func (*LocalProvider) Run

func (l *LocalProvider) Run()

starts calculating checksum according to user param related supplier (os,openssl or os apps) will be called

func (*LocalProvider) Status

func (l *LocalProvider) Status() *status.Status

collect status from running process and returns

func (*LocalProvider) Terminate

func (l *LocalProvider) Terminate() error

calls terminate on running calculation how terminate handled may vary according to lib parameter if its openssl or unix command it will call process kill but if go library it will just update status

func (*LocalProvider) Wait

func (l *LocalProvider) Wait()

This should be called before Run method marks provider as wait so runner will refer to WaitGroup first instead of running

type ProviderFactory

type ProviderFactory struct {
}

provider factory

func (*ProviderFactory) GetProviders

func (p *ProviderFactory) GetProviders(config *Config) (*Providers, error)

Reads configuration file according to params initializes list of providers if present remote ones are OnPremise,AWS,GCE,IBM,ORCL,Azure local provider is Local

type RemoteProvider

type RemoteProvider struct {
	BaseProvider
	// contains filtered or unexported fields
}

reaches given server using http client and collect status or run/terminates

func (*RemoteProvider) Data

func (l *RemoteProvider) Data() *BaseProvider

shorthand to embedded struct in case of interface used

func (*RemoteProvider) DeleteFile

func (l *RemoteProvider) DeleteFile()

no matter what remote server always deletes file this is interface impl

func (*RemoteProvider) Resume

func (l *RemoteProvider) Resume()

resume this provider

func (*RemoteProvider) Run

func (l *RemoteProvider) Run()

notifies server to run waits if process suspended

func (*RemoteProvider) Status

func (l *RemoteProvider) Status() *status.Status

collect status from remote server

func (*RemoteProvider) Terminate

func (l *RemoteProvider) Terminate() error

triggers terminate on remote server

func (*RemoteProvider) Wait

func (l *RemoteProvider) Wait()

suspend this runner SHOULD BE CALLED BEFORE Run method

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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