eventingstructs

Documentation

Index

• Constants
• Variables
• type ConditionalCheckDefinition
• type ConditionalCheckEventingMessage
• type ConditionalCheckEventingMessageResponse
• type CustomFunctionDefinition
• type EventingDefinition
• type NewCustomEventingMessage
• type NewCustomEventingMessageResponse
• type OPSEC_ROLE
• type ResponseInterceptMessage
• type ResponseInterceptMessageResponse
• type TaskInterceptMessage
• type TaskInterceptMessageResponse

Constants

const (
	OPSEC_ROLE_LEAD           OPSEC_ROLE = "lead"
	OPSEC_ROLE_OPERATOR                  = "operator"
	OPSEC_ROLE_OTHER_OPERATOR            = "other_operator"
)

Variables

var (
	AllEventingData containerEventingData
)

Types

type ConditionalCheckDefinition

type ConditionalCheckDefinition struct {
	Name        string                                                                              `json:"name"`
	Description string                                                                              `json:"description"`
	Function    func(input ConditionalCheckEventingMessage) ConditionalCheckEventingMessageResponse `json:"-"`
}

type ConditionalCheckEventingMessage

type ConditionalCheckEventingMessage struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id"`
	FunctionName        string                 `json:"function_name"`
	ContainerName       string                 `json:"container_name"`
	Environment         map[string]interface{} `json:"environment"`
	Inputs              map[string]interface{} `json:"inputs"`
	ActionData          map[string]interface{} `json:"action_data"`
}

type ConditionalCheckEventingMessageResponse

type ConditionalCheckEventingMessageResponse struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id" mapstructure:"eventstepinstance_id"`
	Success             bool                   `json:"action_success" mapstructure:"action_success"`
	StdOut              string                 `json:"stdout" mapstructure:"stdout"`
	StdErr              string                 `json:"stderr" mapstructure:"stderr"`
	Outputs             map[string]interface{} `json:"outputs" mapstructure:"outputs"`
	SkipStep            bool                   `json:"skip_step" mapstructure:"skip_step"`
}

type CustomFunctionDefinition

type CustomFunctionDefinition struct {
	Name        string                                                                `json:"name"`
	Description string                                                                `json:"description"`
	Function    func(input NewCustomEventingMessage) NewCustomEventingMessageResponse `json:"-"`
}

type EventingDefinition

type EventingDefinition struct {
	Name                      string `json:"name"`
	Description               string `json:"description"`
	CustomFunctions           []CustomFunctionDefinition
	ConditionalChecks         []ConditionalCheckDefinition
	TaskInterceptFunction     func(input TaskInterceptMessage) TaskInterceptMessageResponse                             `json:"-"`
	ResponseInterceptFunction func(input ResponseInterceptMessage) ResponseInterceptMessageResponse                     `json:"-"`
	Subscriptions             []string                                                                                  `json:"subscriptions"`
	OnContainerStartFunction  func(sharedStructs.ContainerOnStartMessage) sharedStructs.ContainerOnStartMessageResponse `json:"-"`
}

type NewCustomEventingMessage

type NewCustomEventingMessage struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id"`
	FunctionName        string                 `json:"function_name"`
	ContainerName       string                 `json:"container_name"`
	Environment         map[string]interface{} `json:"environment"`
	Inputs              map[string]interface{} `json:"inputs"`
	ActionData          map[string]interface{} `json:"action_data"`
}

type NewCustomEventingMessageResponse

type NewCustomEventingMessageResponse struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id"`
	Success             bool                   `json:"success"`
	StdOut              string                 `json:"stdout"`
	StdErr              string                 `json:"stderr"`
	Outputs             map[string]interface{} `json:"outputs"`
}

type OPSEC_ROLE

type OPSEC_ROLE string

type ResponseInterceptMessage

type ResponseInterceptMessage struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id"`
	ResponseID          int                    `json:"response_id"`
	CallbackID          int                    `json:"callback_id"`
	CallbackDisplayID   int                    `json:"callback_display_id"`
	AgentCallbackID     string                 `json:"agent_callback_id"`
	ContainerName       string                 `json:"container_name"`
	Environment         map[string]interface{} `json:"environment"`
	Inputs              map[string]interface{} `json:"inputs"`
	ActionData          map[string]interface{} `json:"action_data"`
}

type ResponseInterceptMessageResponse

type ResponseInterceptMessageResponse struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id" mapstructure:"eventstepinstance_id"`
	ResponseID          int                    `json:"response_id" mapstructure:"response_id"`
	Success             bool                   `json:"success" mapstructure:"success"`
	StdOut              string                 `json:"stdout" mapstructure:"stdout"`
	StdErr              string                 `json:"stderr" mapstructure:"stderr"`
	Outputs             map[string]interface{} `json:"outputs" mapstructure:"outputs"`
	Response            string                 `json:"response" mapstructure:"response"`
}

type TaskInterceptMessage

type TaskInterceptMessage struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id"`
	TaskID              int                    `json:"task_id"`
	CallbackID          int                    `json:"callback_id"`
	ContainerName       string                 `json:"container_name"`
	Environment         map[string]interface{} `json:"environment"`
	Inputs              map[string]interface{} `json:"inputs"`
	ActionData          map[string]interface{} `json:"action_data"`
}

type TaskInterceptMessageResponse

type TaskInterceptMessageResponse struct {
	EventStepInstanceID int                    `json:"eventstepinstance_id" mapstructure:"eventstepinstance_id"`
	TaskID              int                    `json:"task_id" mapstructure:"task_id"`
	Success             bool                   `json:"success" mapstructure:"success"`
	StdOut              string                 `json:"stdout" mapstructure:"stdout"`
	StdErr              string                 `json:"stderr" mapstructure:"stderr"`
	BlockTask           bool                   `json:"block_task" mapstructure:"block_task"`
	BypassRole          OPSEC_ROLE             `json:"bypass_role" mapstructure:"bypass_role"`
	BypassMessage       string                 `json:"bypass_message" mapstructure:"bypass_message"`
	Outputs             map[string]interface{} `json:"outputs" mapstructure:"outputs"`
}