events

Documentation

Index

• type ActionName
• type ActivityPublisher
  • func (p *ActivityPublisher) OnEvent(event *RuntimeEvent)
• type DeployErrorCollector
  • func (c *DeployErrorCollector) OnEvent(event *RuntimeEvent)
• type DeployPusher
  • func (p *DeployPusher) OnEvent(event *RuntimeEvent)
• type DeployTimeCollector
  • func (c *DeployTimeCollector) OnEvent(event *RuntimeEvent)
• type EventListener
  • func NewActivityPublisher(manager *EventManager) *EventListener
  • func NewDeployErrorCollector(manager *EventManager, db *dbclient.DBClient, bdl *bundle.Bundle) *EventListener
  • func NewDeployPusher(manager *EventManager, queue *queue.PusherQueue) *EventListener
  • func NewDeployTimeCollector(manager *EventManager, db *dbclient.DBClient) *EventListener
  • func NewEventboxPublisher(manager *EventManager) *EventListener
  • func NewWsPublisher(manager *EventManager) *EventListener
• type EventManager
  • func NewEventManager(cap int, queue *queue.PusherQueue, db *dbclient.DBClient, bdl *bundle.Bundle) *EventManager
  • func (m *EventManager) EmitEvent(e *RuntimeEvent)
  • func (m *EventManager) Start()
• type EventName
• type EventboxPublisher
  • func (p *EventboxPublisher) OnEvent(event *RuntimeEvent)
• type RuntimeEvent
• type WsPublisher
  • func (p *WsPublisher) OnEvent(event *RuntimeEvent)

Types

type ActionName

type ActionName string

const (
	R_ADD           ActionName = "R_ADD"
	R_DEL           ActionName = "R_DEL"
	R_DEPLOY_START  ActionName = "R_DEPLOY_START"
	R_DEPLOY_FAIL   ActionName = "R_DEPLOY_FAIL"
	R_DEPLOY_CANCEL ActionName = "R_DEPLOY_CANCEL"
	R_DEPLOY_OK     ActionName = "R_DEPLOY_OK"
)

type ActivityPublisher

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

func (*ActivityPublisher) OnEvent

func (p *ActivityPublisher) OnEvent(event *RuntimeEvent)

type DeployErrorCollector

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

func (*DeployErrorCollector) OnEvent

func (c *DeployErrorCollector) OnEvent(event *RuntimeEvent)

type DeployPusher

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

func (*DeployPusher) OnEvent

func (p *DeployPusher) OnEvent(event *RuntimeEvent)

type DeployTimeCollector

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

func (*DeployTimeCollector) OnEvent

func (c *DeployTimeCollector) OnEvent(event *RuntimeEvent)

type EventListener

type EventListener interface {
	OnEvent(e *RuntimeEvent)
}

func NewActivityPublisher

func NewActivityPublisher(manager *EventManager) *EventListener

func NewDeployErrorCollector

func NewDeployErrorCollector(manager *EventManager, db *dbclient.DBClient, bdl *bundle.Bundle) *EventListener

func NewDeployPusher

func NewDeployPusher(manager *EventManager, queue *queue.PusherQueue) *EventListener

func NewDeployTimeCollector

func NewDeployTimeCollector(manager *EventManager, db *dbclient.DBClient) *EventListener

func NewEventboxPublisher

func NewEventboxPublisher(manager *EventManager) *EventListener

func NewWsPublisher

func NewWsPublisher(manager *EventManager) *EventListener

type EventManager

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

func NewEventManager

func NewEventManager(cap int, queue *queue.PusherQueue, db *dbclient.DBClient, bdl *bundle.Bundle) *EventManager

func (*EventManager) EmitEvent

func (m *EventManager) EmitEvent(e *RuntimeEvent)

func (*EventManager) Start

func (m *EventManager) Start()

type EventName

type EventName string

const (
	// create
	RuntimeCreated EventName = "RuntimeCreated"
	// delete
	RuntimeDeleting     EventName = "RuntimeDeleting"
	RuntimeDeleted      EventName = "RuntimeDeleted"
	RuntimeDeleteFailed EventName = "RuntimeDeleteFailed"
	// runtime status
	RuntimeStatusChanged EventName = "RuntimeStatusChanged"
	// service
	RuntimeServiceStatusChanged    EventName = "RuntimeServiceStatusChanged"
	RuntimeServiceInstancesChanged EventName = "RuntimeServiceInstancesChanged"
	// deploy
	RuntimeDeployStart         EventName = "RuntimeDeployStart"
	RuntimeDeployStatusChanged EventName = "RuntimeDeployStatusChanged"
	RuntimeDeployFailed        EventName = "RuntimeDeployFailed"
	RuntimeDeployCanceling     EventName = "RuntimeDeployCanceling"
	RuntimeDeployCanceled      EventName = "RuntimeDeployCanceled"
	RuntimeDeployCancelFailed  EventName = "RuntimeDeployCancelFailed"
	RuntimeDeployOk            EventName = "RuntimeDeployOk"
)

type EventboxPublisher

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

func (*EventboxPublisher) OnEvent

func (p *EventboxPublisher) OnEvent(event *RuntimeEvent)

type RuntimeEvent

type RuntimeEvent struct {
	EventName EventName              `json:"eventName"`
	Operator  string                 `json:"operator"`
	Runtime   *apistructs.RuntimeDTO `json:"runtime,omitempty"`
	// only used for RuntimeService* events
	Service *apistructs.RuntimeServiceDTO `json:"service,omitempty"`
	// only used for RuntimeServiceInstancesChanged
	Instances []*apistructs.RuntimeInstanceDTO `json:"instance,omitempty"`
	// only used for RuntimeDeploy* events
	Deployment *apistructs.Deployment `json:"deployment,omitempty"`
}

type WsPublisher

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

func (*WsPublisher) OnEvent

func (p *WsPublisher) OnEvent(event *RuntimeEvent)