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) 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