event

package

Go to main page

Versions in this module

v0

v0.1.11

May 3, 2017

Changes in this version

+ const EventTypeTaskWeightChange

+ func Full() bool

+ func Listeners() map[string]EventListener

type Event

+ func (e *Event) String() string

type EventBus

+ func Instance() *EventBus

type EventListener

+ Wait func()

type SSEListener

+ func (ssel *SSEListener) Wait()

v0.1.9

Mar 20, 2017

v0.1.7

Mar 6, 2017

Changes in this version

+ func AddListener(listener EventListener)

+ func Init()

+ func RemoveListener(listener EventListener)

+ func Start(ctx context.Context) error

+ func Stop()

+ func WriteEvent(e *Event)

+ type DNSListener struct

+ func NewDNSListener() *DNSListener

+ func (listener *DNSListener) AddAcceptor(acceptor types.ResolverAcceptor)

+ func (listener *DNSListener) InterestIn(e *Event) bool

+ func (listener *DNSListener) Key() string

+ func (listener *DNSListener) RemoveAcceptor(ID string)

+ func (listener *DNSListener) Write(e *Event) error

+ type EventListener interface

+ InterestIn func(e *Event) bool

+ Key func() string

+ Write func(e *Event) error

+ type JanitorListener struct

+ func NewJanitorListener() *JanitorListener

+ func (jl *JanitorListener) AddAcceptor(acceptor types.JanitorAcceptor)

+ func (jl *JanitorListener) InterestIn(e *Event) bool

+ func (jl *JanitorListener) Key() string

+ func (jl *JanitorListener) RemoveAcceptor(ID string)

+ func (jl *JanitorListener) Write(e *Event) error

+ type SSEListener struct

+ func NewSSEListener(key string, appId string, rw http.ResponseWriter) (*SSEListener, chan struct{})

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

+ func (ssel *SSEListener) Key() string

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

v0.1.5

Feb 27, 2017

v0.1.3

Feb 17, 2017

Changes in this version

type DNSSubscriber

+ func (subscriber *DNSSubscriber) RemoveAcceptor(ID string)

type Event

+ AppID string

+ ID string

type JanitorSubscriber

+ func (js *JanitorSubscriber) RemoveAcceptor(ID string)

v0.1.1

Jan 17, 2017

Changes in this version

+ const EventTypeAppStateCancelUpdate

+ const EventTypeAppStateCreating

+ const EventTypeAppStateDeletion

+ const EventTypeAppStateNormal

+ const EventTypeAppStateScaleDown

+ const EventTypeAppStateScaleUp

+ const EventTypeAppStateUpdating

+ const EventTypeTaskHealthy

+ const EventTypeTaskStateDropped

+ const EventTypeTaskStateError

+ const EventTypeTaskStateFailed

+ const EventTypeTaskStateFinished

+ const EventTypeTaskStateGone

+ const EventTypeTaskStateGoneByOperator

+ const EventTypeTaskStateKilled

+ const EventTypeTaskStateKilling

+ const EventTypeTaskStateLost

+ const EventTypeTaskStatePendingKill

+ const EventTypeTaskStatePendingOffer

+ const EventTypeTaskStateReap

+ const EventTypeTaskStateRunning

+ const EventTypeTaskStateStaging

+ const EventTypeTaskStateStarting

+ const EventTypeTaskStateUnknown

+ const EventTypeTaskStateUnreachable

+ const EventTypeTaskUnhealthy

+ func BuildJanitorEvent(e *Event) (*upstream.TargetChangeEvent, error)

+ func BuildResolverEvent(e *Event) (*nameserver.RecordGeneratorChangeEvent, error)

+ func SendEventByHttp(addr, method string, data []byte) error

+ type AppInfoEvent struct

+ AppId string

+ ClusterId string

+ Name string

+ RunAs string

+ State string

+ type DNSSubscriber struct

+ Key string

+ func NewDNSSubscriber() *DNSSubscriber

+ func (subscriber *DNSSubscriber) AddAcceptor(acceptor types.ResolverAcceptor)

+ func (subscriber *DNSSubscriber) InterestIn(e *Event) bool

+ func (subscriber *DNSSubscriber) Subscribe(bus *EventBus) error

+ func (subscriber *DNSSubscriber) Unsubscribe(bus *EventBus) error

+ func (subscriber *DNSSubscriber) Write(e *Event) error

+ type Event struct

+ AppId string

+ AppMode string

+ Id string

+ Payload interface{}

+ Type string

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

+ type EventBus struct

+ EventChan chan *Event

+ Lock sync.Mutex

+ Subscribers map[string]EventSubscriber

+ func New() *EventBus

+ func (bus *EventBus) Start(ctx context.Context) error

+ func (bus *EventBus) Stop()

+ type EventSubscriber interface

+ InterestIn func(e *Event) bool

+ Subscribe func(bus *EventBus) error

+ Unsubscribe func(bus *EventBus) error

+ Write func(e *Event) error

+ type JanitorSubscriber struct

+ Key string

+ func NewJanitorSubscriber() *JanitorSubscriber

+ func (js *JanitorSubscriber) AddAcceptor(acceptor types.JanitorAcceptor)

+ func (js *JanitorSubscriber) InterestIn(e *Event) bool

+ func (js *JanitorSubscriber) Subscribe(bus *EventBus) error

+ func (js *JanitorSubscriber) Unsubscribe(bus *EventBus) error

+ func (js *JanitorSubscriber) Write(e *Event) error

+ type SSESubscriber struct

+ Key string

+ func NewSSESubscriber(key string, appId string, rw http.ResponseWriter) (*SSESubscriber, chan struct{})

+ func (sse *SSESubscriber) InterestIn(e *Event) bool

+ func (sse *SSESubscriber) Subscribe(bus *EventBus) error

+ func (sse *SSESubscriber) Unsubscribe(bus *EventBus) error

+ func (sses *SSESubscriber) Write(e *Event) error

+ type TaskInfoEvent struct

+ AppId string

+ ClusterId string

+ Healthy bool

+ Ip string

+ Port string

+ RunAs string

+ State string

+ TaskId string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL