events

type Bus ¶

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

Bus, abonelere dağıtan veriyolu.

func New(maxSubs, buffer int) *Bus

func (b *Bus) Publish(e Event)

func (b *Bus) Stats() Stats

func (b *Bus) Subscribe() (ch <-chan Event, cancel func(), ok bool)

type Event ¶

type Event struct {
	At     time.Time `json:"at"`
	Kind   Kind      `json:"kind"`
	User   string    `json:"user,omitempty"`
	Target string    `json:"target,omitempty"`
	Source string    `json:"source,omitempty"` // istemcinin adresi
	Detail string    `json:"detail,omitempty"`
}

Event, tek bir olay.

⚠️ İÇİNDE SIR YOK ve olmamalı: bu yapı doğrudan tarayıcıya JSON olarak akıyor. Sertifika, token, parola ya da doğrulama kodu buraya konursa panelde oturum açmış her yöneticinin ekranına düşer.

type Kind ¶

type Kind string

Kind, olay türü. Panelde süzme ve simge seçimi buna bakıyor.

const (
	SessionStarted Kind = "session.started"
	SessionEnded   Kind = "session.ended"
	AuthDenied     Kind = "auth.denied"
	AuthOK         Kind = "auth.ok"
)

type Nop ¶

type Nop struct{}

Nop, olay yayını kapalıyken kullanılan Publisher.

func (Nop) Publish(Event)

type Publisher ¶

type Publisher interface {
	Publish(Event)
}

Publisher, üretici tarafın gördüğü yüz.

proxy ve sshd bu arayüzü alıyor, *Bus'ı değil: nil bir Publisher yerine no-op geçebilmek ve testte yayınları toplayabilmek için.

type Stats ¶

type Stats struct {
	Subscribers int    `json:"subscribers"`
	Dropped     uint64 `json:"dropped"`
}

Stats, panelde gösterilen sayaçlar.