Documentation ¶
Index ¶
- Constants
- func AddListener(listener EventListener)
- func BuildJanitorEvent(e *Event) (*janitor.TargetChangeEvent, error)
- func BuildResolverEvent(e *Event) (*nameserver.RecordGeneratorChangeEvent, error)
- func Init()
- func RemoveListener(listener EventListener)
- func SendEventByHttp(addr string, data interface{}) error
- func Start(ctx context.Context) error
- func Stop()
- func WriteEvent(e *Event)
- type DNSListener
- type Event
- type EventBus
- type EventListener
- type JanitorListener
- type SSEListener
Constants ¶
View Source
const ( //task_add and task_rm is used for dns/proxy service EventTypeTaskHealthy = "task_healthy" 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" )
Variables ¶
This section is empty.
Functions ¶
func AddListener ¶ added in v0.1.7
func AddListener(listener EventListener)
func BuildJanitorEvent ¶
func BuildResolverEvent ¶
func BuildResolverEvent(e *Event) (*nameserver.RecordGeneratorChangeEvent, error)
func RemoveListener ¶ added in v0.1.7
func RemoveListener(listener EventListener)
func SendEventByHttp ¶
func WriteEvent ¶ added in v0.1.7
func WriteEvent(e *Event)
Types ¶
type DNSListener ¶ added in v0.1.7
type DNSListener struct {
// contains filtered or unexported fields
}
func NewDNSListener ¶ added in v0.1.7
func NewDNSListener() *DNSListener
func (*DNSListener) AddAcceptor ¶ added in v0.1.7
func (listener *DNSListener) AddAcceptor(acceptor types.ResolverAcceptor)
func (*DNSListener) InterestIn ¶ added in v0.1.7
func (listener *DNSListener) InterestIn(e *Event) bool
func (*DNSListener) Key ¶ added in v0.1.7
func (listener *DNSListener) Key() string
func (*DNSListener) RemoveAcceptor ¶ added in v0.1.7
func (listener *DNSListener) RemoveAcceptor(ID string)
func (*DNSListener) Write ¶ added in v0.1.7
func (listener *DNSListener) Write(e *Event) error
type EventListener ¶ added in v0.1.7
type JanitorListener ¶ added in v0.1.7
type JanitorListener struct {
// contains filtered or unexported fields
}
func NewJanitorListener ¶ added in v0.1.7
func NewJanitorListener() *JanitorListener
func (*JanitorListener) AddAcceptor ¶ added in v0.1.7
func (jl *JanitorListener) AddAcceptor(acceptor types.JanitorAcceptor)
func (*JanitorListener) InterestIn ¶ added in v0.1.7
func (jl *JanitorListener) InterestIn(e *Event) bool
func (*JanitorListener) Key ¶ added in v0.1.7
func (jl *JanitorListener) Key() string
func (*JanitorListener) RemoveAcceptor ¶ added in v0.1.7
func (jl *JanitorListener) RemoveAcceptor(ID string)
func (*JanitorListener) Write ¶ added in v0.1.7
func (jl *JanitorListener) Write(e *Event) error
type SSEListener ¶ added in v0.1.7
type SSEListener struct {
// contains filtered or unexported fields
}
func NewSSEListener ¶ added in v0.1.7
func NewSSEListener(key string, appId string, rw http.ResponseWriter) (*SSEListener, chan struct{})
func (*SSEListener) InterestIn ¶ added in v0.1.7
func (sse *SSEListener) InterestIn(e *Event) bool
func (*SSEListener) Key ¶ added in v0.1.7
func (ssel *SSEListener) Key() string
func (*SSEListener) Write ¶ added in v0.1.7
func (ssel *SSEListener) Write(e *Event) error
Click to show internal directories.
Click to hide internal directories.