Documentation
¶
Index ¶
- Constants
- func MissingAttributeError(attribute string, metadata map[string]interface{}) error
- type Manager
- func (a *Manager) AddToEventQueue(event *models.EventInfo)
- func (a *Manager) Deregister() error
- func (a *Manager) ExecutePendingPlaybooks() error
- func (a *Manager) GetPlaybookCommand() playbook.AnsiblePlaybookCmd
- func (a *Manager) HandlePlaybook(messageId string, metadataMap map[string]interface{}, peName string, ...) error
- func (a *Manager) HasStarted() bool
- func (a *Manager) Init(config models.DeviceConfigurationMessage) error
- func (a *Manager) List() []api.PlaybookExecutionInfo
- func (a *Manager) PopEvents() []*models.EventInfo
- func (a *Manager) Start()
- func (a *Manager) String() string
- func (a *Manager) Update(config models.DeviceConfigurationMessage) error
- func (a *Manager) WaitPlaybookCompletion()
- type RequiredFields
- type YGGDResponse
Constants ¶
View Source
const ( // Failure types NotInstalled = "ANSIBLE_NOT_INSTALLED" UndefError = "UNDEFINED_ERROR" )
Variables ¶
This section is empty.
Functions ¶
func MissingAttributeError ¶
Types ¶
type Manager ¶
type Manager struct {
MappingRepository mapping.MappingRepository
// contains filtered or unexported fields
}
Manager handle ansible playbook execution
func NewAnsibleManager ¶
func NewAnsibleManager( configManager *cfg.Manager, dispatcherClient pb.DispatcherClient, configDir string, deviceId string, reg registration.RegistrationWrapper) (*Manager, error)
func (*Manager) AddToEventQueue ¶
func (*Manager) Deregister ¶
func (*Manager) ExecutePendingPlaybooks ¶
func (*Manager) GetPlaybookCommand ¶
func (a *Manager) GetPlaybookCommand() playbook.AnsiblePlaybookCmd
func (*Manager) HandlePlaybook ¶
func (*Manager) HasStarted ¶
func (*Manager) Init ¶
func (a *Manager) Init(config models.DeviceConfigurationMessage) error
Init no-op due to we need to an update from the source of truth in this case(API)
func (*Manager) List ¶
func (a *Manager) List() []api.PlaybookExecutionInfo
func (*Manager) WaitPlaybookCompletion ¶
func (a *Manager) WaitPlaybookCompletion()
type RequiredFields ¶
type RequiredFields struct {
// contains filtered or unexported fields
}
type YGGDResponse ¶
type YGGDResponse struct {
Metadata map[string]string
Body json.RawMessage
StatusCode int
}
func NewYGGDResponse ¶
func NewYGGDResponse(response []byte) (*YGGDResponse, error)
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package mapping is a generated GoMock package.
|
Package mapping is a generated GoMock package. |
|
model
|
|
Click to show internal directories.
Click to hide internal directories.