Documentation
¶
Index ¶
- func GetNextCommandFailErrMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- func GetNextCommandFailJSONMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- func GetNextCommandFailStatusMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- func GetNextCommandMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- func PingFailErrMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
- func PingFailJSONMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
- func PingFailStatusMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
- func PingMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
- func ReportBootstrapLogFailErrMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
- func ReportBootstrapLogFailJSONMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
- func ReportBootstrapLogFailStatusMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
- func ReportBootstrapLogMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
- func UpdateCommandFailErrMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- func UpdateCommandFailJSONMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- func UpdateCommandFailStatusMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- func UpdateCommandMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
- type PollingService
- func (p *PollingService) GetNextCommand() (command *types.PollingCommand, status int, err error)
- func (p *PollingService) Ping() (ping *types.PollingPing, status int, err error)
- func (p *PollingService) ReportBootstrapLog(PollingContinuousReportVector *map[string]interface{}) (command *types.PollingContinuousReport, status int, err error)
- func (p *PollingService) UpdateCommand(pollingCommandVector *map[string]interface{}, ID string) (command *types.PollingCommand, status int, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetNextCommandFailErrMocked ¶
func GetNextCommandFailErrMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
GetNextCommandFailErrMocked test mocked function
func GetNextCommandFailJSONMocked ¶
func GetNextCommandFailJSONMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
GetNextCommandFailJSONMocked test mocked function
func GetNextCommandFailStatusMocked ¶
func GetNextCommandFailStatusMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
GetNextCommandFailStatusMocked test mocked function
func GetNextCommandMocked ¶
func GetNextCommandMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
GetNextCommandMocked test mocked function
func PingFailErrMocked ¶
func PingFailErrMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
PingFailErrMocked test mocked function
func PingFailJSONMocked ¶
func PingFailJSONMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
PingFailJSONMocked test mocked function
func PingFailStatusMocked ¶
func PingFailStatusMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
PingFailStatusMocked test mocked function
func PingMocked ¶
func PingMocked(t *testing.T, pingIn *types.PollingPing) *types.PollingPing
PingMocked test mocked function
func ReportBootstrapLogFailErrMocked ¶
func ReportBootstrapLogFailErrMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
ReportBootstrapLogFailErrMocked test mocked function
func ReportBootstrapLogFailJSONMocked ¶
func ReportBootstrapLogFailJSONMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
ReportBootstrapLogFailJSONMocked test mocked function
func ReportBootstrapLogFailStatusMocked ¶
func ReportBootstrapLogFailStatusMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
ReportBootstrapLogFailStatusMocked test mocked function
func ReportBootstrapLogMocked ¶
func ReportBootstrapLogMocked(t *testing.T, commandIn *types.PollingContinuousReport) *types.PollingContinuousReport
ReportBootstrapLogMocked test mocked function
func UpdateCommandFailErrMocked ¶
func UpdateCommandFailErrMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
UpdateCommandFailErrMocked test mocked function
func UpdateCommandFailJSONMocked ¶
func UpdateCommandFailJSONMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
UpdateCommandFailJSONMocked test mocked function
func UpdateCommandFailStatusMocked ¶
func UpdateCommandFailStatusMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
UpdateCommandFailStatusMocked test mocked function
func UpdateCommandMocked ¶
func UpdateCommandMocked(t *testing.T, commandIn *types.PollingCommand) *types.PollingCommand
UpdateCommandMocked test mocked function
Types ¶
type PollingService ¶
type PollingService struct {
// contains filtered or unexported fields
}
PollingService manages polling operations
func NewPollingService ¶
func NewPollingService(concertoService utils.ConcertoService) (*PollingService, error)
NewPollingService returns a Concerto polling service
func (*PollingService) GetNextCommand ¶
func (p *PollingService) GetNextCommand() (command *types.PollingCommand, status int, err error)
GetNextCommand returns the command to be executed
func (*PollingService) Ping ¶
func (p *PollingService) Ping() (ping *types.PollingPing, status int, err error)
Ping resolves if new command is waiting for execution
func (*PollingService) ReportBootstrapLog ¶
func (p *PollingService) ReportBootstrapLog(PollingContinuousReportVector *map[string]interface{}) (command *types.PollingContinuousReport, status int, err error)
ReportBootstrapLog reports a command result
func (*PollingService) UpdateCommand ¶
func (p *PollingService) UpdateCommand(pollingCommandVector *map[string]interface{}, ID string) (command *types.PollingCommand, status int, err error)
UpdateCommand updates a command by its ID
Source Files
Click to show internal directories.
Click to hide internal directories.