event

Documentation

Index

• Constants
• func AddListener(listener EventListener)
• func Full() bool
• func Listeners() map[string]EventListener
• func RemoveListener(listener EventListener)
• func SendEventByHttp(addr string, data interface{}) error
• func Start(ctx context.Context) error
• func WriteEvent(e *Event)
• type Event
  • func NewEvent(t string, payload interface{}) *Event
  • func (e *Event) String() string
• type EventBus
  • func Init() *EventBus
  • func Instance() *EventBus
• type EventListener
• type SSEListener
  • func NewSSEListener(key, appId string, rw http.ResponseWriter) (*SSEListener, error)
  • func (sse *SSEListener) InterestIn(e *Event) bool
  • func (ssel *SSEListener) Key() string
  • func (ssel *SSEListener) Wait()
  • func (ssel *SSEListener) Write(e *Event) error

Constants

const (
	//task_add and task_rm is used for dns/proxy service
	EventTypeTaskHealthy      = "task_healthy"
	EventTypeTaskWeightChange = "task_weight_change"
	EventTypeTaskUnhealthy    = "task_unhealthy"

	EventTypeTaskStatePendingOffer   = "task_state_pending_offer"
	EventTypeTaskStatePendingKill    = "task_state_pending_killed"
	EventTypeTaskStateReap           = "task_state_pending_reap"
	EventTypeTaskStateStaging        = "task_state_staging"
	EventTypeTaskStateStarting       = "task_state_starting"
	EventTypeTaskStateRunning        = "task_state_running"
	EventTypeTaskStateKilling        = "task_state_killing"
	EventTypeTaskStateFinished       = "task_state_finished"
	EventTypeTaskStateFailed         = "task_state_failed"
	EventTypeTaskStateKilled         = "task_state_killed"
	EventTypeTaskStateError          = "task_state_error"
	EventTypeTaskStateLost           = "task_state_lost"
	EventTypeTaskStateDropped        = "task_state_dropped"
	EventTypeTaskStateUnreachable    = "task_state_unreachable"
	EventTypeTaskStateGone           = "task_state_gone"
	EventTypeTaskStateGoneByOperator = "task_state_gone_by_operator"
	EventTypeTaskStateUnknown        = "task_state_unknown"

	EventTypeAppStateCreating     = "app_state_creating"
	EventTypeAppStateDeletion     = "app_state_deletion"
	EventTypeAppStateNormal       = "app_state_normal"
	EventTypeAppStateUpdating     = "app_state_updating"
	EventTypeAppStateCancelUpdate = "app_state_cancel_update"
	EventTypeAppStateScaleUp      = "app_state_scale_up"
	EventTypeAppStateScaleDown    = "app_state_scale_down"
)

Functions

func AddListener

func AddListener(listener EventListener)

func Full

func Full() bool

func Listeners

func Listeners() map[string]EventListener

func RemoveListener

func RemoveListener(listener EventListener)

func SendEventByHttp

func SendEventByHttp(addr string, data interface{}) error

func Start

func Start(ctx context.Context) error

func WriteEvent

func WriteEvent(e *Event)

Types

type Event

type Event struct {
	ID      string
	Type    string
	AppID   string
	AppMode string
	Payload interface{}
}

func NewEvent

func NewEvent(t string, payload interface{}) *Event

func (*Event) String

func (e *Event) String() string

type EventBus

type EventBus struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func Init

func Init() *EventBus

func Instance

func Instance() *EventBus

type EventListener

type EventListener interface {
	Write(e *Event) error
	InterestIn(e *Event) bool
	Key() string
	Wait()
}

type SSEListener

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

func NewSSEListener

func NewSSEListener(key, appId string, rw http.ResponseWriter) (*SSEListener, error)

func (*SSEListener) InterestIn

func (sse *SSEListener) InterestIn(e *Event) bool

func (*SSEListener) Key

func (ssel *SSEListener) Key() string

func (*SSEListener) Wait

func (ssel *SSEListener) Wait()

func (*SSEListener) Write

func (ssel *SSEListener) Write(e *Event) error