Documentation
¶
Overview ¶
Package runcommand implements runcommand core processing module
Package runcommand implements runcommand core processing module ¶
Package runcommand implements runcommand core processing module ¶
Package runcommand implements runcommand core processing module ¶
Package runcommand implements runcommand core processing module
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FormatPayload ¶
func FormatPayload(log log.T, pluginID string, agentInfo contracts.AgentInfo, outputs map[string]*contracts.PluginResult) messageContracts.SendReplyPayload
FormatPayload builds SendReply Payload from the internal plugins map
Types ¶
type RunCommandService ¶
type RunCommandService struct {
// contains filtered or unexported fields
}
RunCommandService is an object that can process MDS messages.
func NewOfflineService ¶
func NewOfflineService(context context.T) (*RunCommandService, error)
NewOfflineService initialize a new offline command document processor
func NewService ¶
func NewService(ctx context.T, serviceName string, service mdsService.Service, processor *processor.EngineProcessor) *RunCommandService
NewService performs common initialization for Mds and Offline processors
func (*RunCommandService) ModuleExecute ¶
func (s *RunCommandService) ModuleExecute() (err error)
ModuleExecute starts the scheduling of the message processor plugin
func (*RunCommandService) ModuleName ¶
func (s *RunCommandService) ModuleName() string
ModuleName returns the module name
func (*RunCommandService) ModuleStop ¶
func (s *RunCommandService) ModuleStop() (err error)
type SendDocumentLevelResponse ¶
type SendDocumentLevelResponse func(messageID string, resultStatus contracts.ResultStatus, documentTraceOutput string)
SendDocumentLevelResponse is used to send status response before plugin begins
type SendResponse ¶
type SendResponse func(messageID string, res contracts.DocumentResult)
type TopicPrefix ¶
type TopicPrefix string
TopicPrefix is the prefix of the Topic field in an MDS message.
const ( // SendCommandTopicPrefix is the topic prefix for a send command MDS message. SendCommandTopicPrefix TopicPrefix = "aws.ssm.sendCommand." // CancelCommandTopicPrefix is the topic prefix for a cancel command MDS message. CancelCommandTopicPrefix TopicPrefix = "aws.ssm.cancelCommand." // SendCommandTopicPrefixOffline is the topic prefix for a send command MDS message received from the offline service. SendCommandTopicPrefixOffline TopicPrefix = "aws.ssm.sendCommand.offline." // CancelCommandTopicPrefixOffline is the topic prefix for a cancel command MDS message received from the offline service. CancelCommandTopicPrefixOffline TopicPrefix = "aws.ssm.cancelCommand.offline." // CloudWatchLogGroupNamePrefix CloudWatch output's log group name prefix CloudWatchLogGroupNamePrefix = "/aws/ssm/" )
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package model contains message struct for MDS/SSM messages.
|
Package model contains message struct for MDS/SSM messages. |
|
Package service is a wrapper for the SSM Message Delivery Service and Offline Command Service
|
Package service is a wrapper for the SSM Message Delivery Service and Offline Command Service |
Click to show internal directories.
Click to hide internal directories.