Documentation
¶
Index ¶
- Constants
- func CheckError(err error)
- func CheckRequiredFlags(c *cli.Context, flags []string)
- func CheckReturnCode(res int, mesg []byte)
- func CheckStandardStatus(status int, mesg []byte) error
- func Contains(s []string, x string) bool
- func ExecCode(code string, path string, filename string) (output string, exitCode int, startedAt time.Time, finishedAt time.Time)
- func FileExists(name string) bool
- func FlagConvertParams(c *cli.Context) *map[string]interface{}
- func FlagConvertParamsJSON(c *cli.Context, jsonFlags []string) (*map[string]interface{}, error)
- func FlagsRequired(c *cli.Context, flags []string)
- func GetDefaultCaCertFilePath() string
- func GetDefaultCertFilePath() string
- func GetDefaultKeyFilePath() string
- func GetDefaultLogFilePath() string
- func GetProcessIdFromFile(pidFileName string) (int, error)
- func ItemConvertParams(item interface{}) (*map[string]interface{}, error)
- func JSONParam(param string) (interface{}, error)
- func RandomString(strlen int) string
- func RemoveDuplicates(elements []string) []string
- func RemoveFileInfo(fileInfo os.FileInfo, fileInfoName string) error
- func Retry(attempts int, sleep time.Duration, fn func() error) error
- func RunCmd(command string) (output string, exitCode int, startedAt time.Time, finishedAt time.Time)
- func RunContinuousCmd(fn func(chunk string) error, command string, thresholdTime int, ...) (int, error)
- func RunFile(command string) (output string, exitCode int, startedAt time.Time, finishedAt time.Time)
- func RunTracedCmd(command string) (exitCode int, stdOut string, stdErr string, startedAt time.Time, ...)
- func ScrapeErrorMessage(message string, regExpression string) string
- func SetProcessIdToFile(pidFileName string) error
- func StopProcess(pidFileName string) error
- func StopProcessId(pid int) error
- func Subset(s1, s2 []string) bool
- func Untar(ctx context.Context, source, target string) error
- func Unzip(archive, target string) error
- type Cert
- type ConcertoService
- type Config
- type HTTPConcertoservice
- func (hcs *HTTPConcertoservice) Delete(path string) ([]byte, int, error)
- func (hcs *HTTPConcertoservice) Get(path string) ([]byte, int, error)
- func (hcs *HTTPConcertoservice) GetFile(path string, filePath string) (string, int, error)
- func (hcs *HTTPConcertoservice) Post(path string, payload *map[string]interface{}) ([]byte, int, error)
- func (hcs *HTTPConcertoservice) Put(path string, payload *map[string]interface{}) ([]byte, int, error)
- type MockConcertoService
- func (m *MockConcertoService) Delete(path string) ([]byte, int, error)
- func (m *MockConcertoService) Get(path string) ([]byte, int, error)
- func (m *MockConcertoService) GetFile(path string, filePath string) (string, int, error)
- func (m *MockConcertoService) Post(path string, payload *map[string]interface{}) ([]byte, int, error)
- func (m *MockConcertoService) Put(path string, payload *map[string]interface{}) ([]byte, int, error)
Constants ¶
const ( TimeStampLayout = "2006-01-02T15:04:05.000000-07:00" TimeLayoutYYYYMMDDHHMMSS = "20060102150405" RetriesFactor = 3 )
const VERSION = "0.8.0"
Variables ¶
This section is empty.
Functions ¶
func CheckRequiredFlags ¶
CheckRequiredFlags checks for required flags, and show usage if requirements not met
func CheckReturnCode ¶
func CheckStandardStatus ¶
CheckStandardStatus return error if status is not OK
func FlagConvertParams ¶
FlagConvertParams converts cli parameters in API callable params
func FlagConvertParamsJSON ¶
FlagConvertParamsJSON converts cli parameters in API callable params, and encodes JSON parameters
func GetDefaultCaCertFilePath ¶
func GetDefaultCaCertFilePath() string
GetDefaultCaCertFilePath returns default concerto configuration path file
func GetDefaultCertFilePath ¶
func GetDefaultCertFilePath() string
GetDefaultCertFilePath returns default concerto configuration path file
func GetDefaultKeyFilePath ¶
func GetDefaultKeyFilePath() string
GetDefaultKeyFilePath returns default concerto configuration path file
func GetDefaultLogFilePath ¶
func GetDefaultLogFilePath() string
GetDefaultLogFilePath returns default concerto configuration path file
func GetProcessIdFromFile ¶
GetProcessIdFromFile reads the process id previously stored in the file
func ItemConvertParams ¶
ItemConvertParams converts API items into map of interface
func RandomString ¶
RandomString generates a random string from lowercase letters and numbers
func RemoveDuplicates ¶ added in v0.8.0
RemoveDuplicates returns the slice removing duplicates if exist
func RemoveFileInfo ¶ added in v0.8.0
func RunContinuousCmd ¶
func RunContinuousCmd(fn func(chunk string) error, command string, thresholdTime int, thresholdLines int) (int, error)
thresholdTime > 0 continuous report thresholdLines > 0 bootstrapping
func RunTracedCmd ¶
func RunTracedCmd(command string) (exitCode int, stdOut string, stdErr string, startedAt time.Time, finishedAt time.Time)
RunTracedCmd executes the received command and manages two output pipes (output and error) It shouldn't throw any exception/error or stop the process.
func ScrapeErrorMessage ¶
func SetProcessIdToFile ¶
SetProcessIdToFile obtains the process id and save it inside a file
func StopProcess ¶
StopProcess reads the process id from given file and stops the process
func StopProcessId ¶
StopProcessId stops the process by the given id
Types ¶
type Cert ¶
type Cert struct {
Cert string `xml:"cert,attr"`
Key string `xml:"key,attr"`
Ca string `xml:"server_ca,attr"`
}
Cert stores cert files location
type ConcertoService ¶
type ConcertoService interface {
Post(path string, payload *map[string]interface{}) ([]byte, int, error)
Put(path string, payload *map[string]interface{}) ([]byte, int, error)
Delete(path string) ([]byte, int, error)
Get(path string) ([]byte, int, error)
GetFile(path string, filePath string) (string, int, error)
}
ConcertoService defines actions to be performed by web service manager
type Config ¶
type Config struct {
XMLName xml.Name `xml:"concerto"`
APIEndpoint string `xml:"server,attr"`
LogFile string `xml:"log_file,attr"`
LogLevel string `xml:"log_level,attr"`
Certificate Cert `xml:"ssl"`
ConfLocation string
ConfFile string
IsHost bool
ConcertoURL string
BrownfieldToken string
CommandPollingToken string
ServerID string
CurrentUserName string
CurrentUserIsAdmin bool
}
Config stores configuration file contents
func GetConcertoConfig ¶
GetConcertoConfig returns concerto configuration
func InitializeConcertoConfig ¶
InitializeConcertoConfig creates the concerto configuration structure
func (*Config) IsAgentMode ¶ added in v0.7.0
IsAgentMode returns whether CLI is acting as Server Or Client mode
func (*Config) IsConfigReady ¶
IsConfigReady returns whether configurations items are filled
func (*Config) IsConfigReadyBrownfield ¶
IsConfigReadyBrownfield returns whether config is ready for brownfield token authentication
func (*Config) IsConfigReadyCommandPolling ¶
IsConfigReadyCommandPolling returns whether config is ready for polling token authentication
func (*Config) IsConfigReadySetup ¶
IsConfigReadySetup returns whether we can use setup command
type HTTPConcertoservice ¶
type HTTPConcertoservice struct {
// contains filtered or unexported fields
}
HTTPConcertoservice web service manager.
func NewHTTPConcertoService ¶
func NewHTTPConcertoService(config *Config) (hcs *HTTPConcertoservice, err error)
NewHTTPConcertoService creates new http Concerto client based on config
func NewHTTPConcertoServiceWithBrownfieldToken ¶
func NewHTTPConcertoServiceWithBrownfieldToken(config *Config) (hcs *HTTPConcertoservice, err error)
NewHTTPConcertoService creates new http Concerto client based on config
func NewHTTPConcertoServiceWithCommandPolling ¶
func NewHTTPConcertoServiceWithCommandPolling(config *Config) (hcs *HTTPConcertoservice, err error)
func (*HTTPConcertoservice) Delete ¶
func (hcs *HTTPConcertoservice) Delete(path string) ([]byte, int, error)
Delete sends DELETE request to Concerto API
func (*HTTPConcertoservice) Get ¶
func (hcs *HTTPConcertoservice) Get(path string) ([]byte, int, error)
Get sends GET request to Concerto API
type MockConcertoService ¶
MockConcertoService service manager.
func (*MockConcertoService) Delete ¶
func (m *MockConcertoService) Delete(path string) ([]byte, int, error)
Delete mocks DELETE request to Concerto API
func (*MockConcertoService) Get ¶
func (m *MockConcertoService) Get(path string) ([]byte, int, error)
Get mocks GET request to Concerto API
Source Files
Directories