queue

Documentation

Index

• type DefaultPluginWorker
  • func (w *DefaultPluginWorker) PublishMessage(cloud string, payload PluginPayload) error
• type PluginAction
• type PluginPayload
• type PluginWorker
  • func NewPluginWorker(app *application.App) PluginWorker

Types

type DefaultPluginWorker

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

func (*DefaultPluginWorker) PublishMessage

func (w *DefaultPluginWorker) PublishMessage(cloud string, payload PluginPayload) error

type PluginAction

type PluginAction string

const (
	PluginActionTagUpdate PluginAction = "TAG_UPDATE"
)

type PluginPayload

type PluginPayload struct {
	Cloud      string       `json:"cloud"`
	TenantID   string       `json:"tenant_id"`
	ResourceID string       `json:"resource_id"`
	Action     PluginAction `json:"action"`
	Payload    interface{}  `json:"payload"`
}

type PluginWorker

type PluginWorker interface {
	PublishMessage(cloud string, payload PluginPayload) error
}

func NewPluginWorker

func NewPluginWorker(app *application.App) PluginWorker