dispatcher

Documentation

Index

• func ComposeDispatcherMessage(events []message.AnsibleRunnerJobEventYaml, returnURL string, ...) (*pb.Data, error)
• func CreateMessage(events []message.AnsibleRunnerJobEventYaml) ([]byte, error)
• type AnsibleDispatcher
  • func NewAnsibleDispatcher(deviceIDParam string) *AnsibleDispatcher
  • func (d *AnsibleDispatcher) AddEvent(playbookFilname string, event *results.AnsiblePlaybookJSONResults) []message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) AddRunnerJobEvent(event message.AnsibleRunnerJobEventYaml) []message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) ExecutorOnFailed(correlationID string, stdout string, errorCode string, errorDetails string) message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) ExecutorOnStart(correlationID string, stdout string) message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) GetMsgList() []message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) PlaybookOnPlayStart(playbookFilename string, msgCounter int, ...) *message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) PlaybookOnStart(playbookFilename string, msgCounter int, ...) *message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) PlaybookOnTaskStart(runnerID string, playbookFilename string, playbookUUID string, msgCounter int, ...) *message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) RunnerOnFailed(runnerID string, playbookFilename string, playbookUUID string, msgCounter int, ...) *message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) RunnerOnOk(runnerID string, playbookFilename string, playbookUUID string, msgCounter int, ...) *message.AnsibleRunnerJobEventYaml
  • func (d *AnsibleDispatcher) RunnerOnSkipped(runnerID string, playbookFilename string, playbookUUID string, msgCounter int, ...) *message.AnsibleRunnerJobEventYaml

Functions

func ComposeDispatcherMessage

func ComposeDispatcherMessage(events []message.AnsibleRunnerJobEventYaml, returnURL string, responseTo string) (*pb.Data, error)

Create the message with event data to send back to Dispatcher

func CreateMessage

func CreateMessage(events []message.AnsibleRunnerJobEventYaml) ([]byte, error)

Types

type AnsibleDispatcher

type AnsibleDispatcher struct {
	// contains filtered or unexported fields
}

Event-generating functions for the Playbook Dispatcher

func NewAnsibleDispatcher

func NewAnsibleDispatcher(deviceIDParam string) *AnsibleDispatcher

func (*AnsibleDispatcher) AddEvent

func (d *AnsibleDispatcher) AddEvent(playbookFilname string, event *results.AnsiblePlaybookJSONResults) []message.AnsibleRunnerJobEventYaml

func (*AnsibleDispatcher) AddRunnerJobEvent

func (d *AnsibleDispatcher) AddRunnerJobEvent(event message.AnsibleRunnerJobEventYaml) []message.AnsibleRunnerJobEventYaml

TODO: Implement this function

func (*AnsibleDispatcher) ExecutorOnFailed

func (d *AnsibleDispatcher) ExecutorOnFailed(correlationID string, stdout string, errorCode string, errorDetails string) message.AnsibleRunnerJobEventYaml

required event for cloud connector

func (*AnsibleDispatcher) ExecutorOnStart

func (d *AnsibleDispatcher) ExecutorOnStart(correlationID string, stdout string) message.AnsibleRunnerJobEventYaml

required event for cloud connector

func (*AnsibleDispatcher) GetMsgList

func (d *AnsibleDispatcher) GetMsgList() []message.AnsibleRunnerJobEventYaml

func (*AnsibleDispatcher) PlaybookOnPlayStart

func (d *AnsibleDispatcher) PlaybookOnPlayStart(playbookFilename string, msgCounter int, play *results.AnsiblePlaybookJSONResultsPlay) *message.AnsibleRunnerJobEventYaml

https://github.com/ansible/ansible-runner/blob/7e60c1f61ee6118f0b943e7897dc3a58ecc043bd/ansible_runner/display_callback/callback/awx_display.py#L477

func (*AnsibleDispatcher) PlaybookOnStart

func (d *AnsibleDispatcher) PlaybookOnStart(playbookFilename string, msgCounter int, event *results.AnsiblePlaybookJSONResultsPlay) *message.AnsibleRunnerJobEventYaml

https://github.com/ansible/ansible-runner/blob/7e60c1f61ee6118f0b943e7897dc3a58ecc043bd/ansible_runner/display_callback/callback/awx_display.py#L442

func (*AnsibleDispatcher) PlaybookOnTaskStart

func (d *AnsibleDispatcher) PlaybookOnTaskStart(
	runnerID string,
	playbookFilename string,
	playbookUUID string,
	msgCounter int,
	host *string,
	tasks *results.AnsiblePlaybookJSONResultsPlayTaskItem,
	hosts *results.AnsiblePlaybookJSONResultsPlayTaskHostsItem,
	taskUUIDs map[string]int,
	duplicateTaskCount map[string]int) *message.AnsibleRunnerJobEventYaml

https://github.com/ansible/ansible-runner/blob/7e60c1f61ee6118f0b943e7897dc3a58ecc043bd/ansible_runner/display_callback/callback/awx_display.py#L530

func (*AnsibleDispatcher) RunnerOnFailed

func (d *AnsibleDispatcher) RunnerOnFailed(
	runnerID string,
	playbookFilename string,
	playbookUUID string,
	msgCounter int,
	host *string,
	tasks *results.AnsiblePlaybookJSONResultsPlayTaskItem,
	hosts *results.AnsiblePlaybookJSONResultsPlayTaskHostsItem) *message.AnsibleRunnerJobEventYaml

func (*AnsibleDispatcher) RunnerOnOk

func (d *AnsibleDispatcher) RunnerOnOk(
	runnerID string,
	playbookFilename string,
	playbookUUID string,
	msgCounter int,
	host *string,
	tasks *results.AnsiblePlaybookJSONResultsPlayTaskItem,
	hosts *results.AnsiblePlaybookJSONResultsPlayTaskHostsItem) *message.AnsibleRunnerJobEventYaml

func (*AnsibleDispatcher) RunnerOnSkipped

func (d *AnsibleDispatcher) RunnerOnSkipped(
	runnerID string,
	playbookFilename string,
	playbookUUID string,
	msgCounter int,
	host *string,
	tasks *results.AnsiblePlaybookJSONResultsPlayTaskItem,
	hosts *results.AnsiblePlaybookJSONResultsPlayTaskHostsItem) *message.AnsibleRunnerJobEventYaml