events

Documentation

Index

• Constants
• func AddSessionEventHandler(handler SessionEventHandler)
• func Init(dbProvider persistence.DbProvider, stores *persistence.Stores, ...)
• func RemoveSessionEventHandler(handler SessionEventHandler)
• type EdgeJsonFormatter
  • func (formatter *EdgeJsonFormatter) AcceptEntityCountEvent(event *EntityCountEvent)
  • func (formatter *EdgeJsonFormatter) AcceptSessionEvent(event *SessionEvent)
• type EdgePlainTextFormatter
  • func (formatter *EdgePlainTextFormatter) AcceptEntityCountEvent(event *EntityCountEvent)
  • func (formatter *EdgePlainTextFormatter) AcceptSessionEvent(event *SessionEvent)
• type EntityCountEvent
  • func (event *EntityCountEvent) String() string
• type EntityCountEventHandler
• type JsonEntityCountEvent
  • func (event *JsonEntityCountEvent) WriteTo(output io.WriteCloser) error
• type JsonSessionEvent
  • func (event *JsonSessionEvent) WriteTo(output io.WriteCloser) error
• type PlainTextEntityCountEvent
  • func (event *PlainTextEntityCountEvent) WriteTo(output io.WriteCloser) error
• type PlainTextSessionEvent
  • func (event *PlainTextSessionEvent) WriteTo(output io.WriteCloser) error
• type SessionEvent
  • func (event *SessionEvent) String() string
• type SessionEventHandler

Constants

const EntityCountEventNS = "edge.entityCounts"

const SessionEventNS = "edge.sessions"

const SessionEventTypeCreated = "created"

const SessionEventTypeDeleted = "deleted"

Functions

func AddSessionEventHandler

func AddSessionEventHandler(handler SessionEventHandler)

func Init

func Init(dbProvider persistence.DbProvider, stores *persistence.Stores, closeNotify <-chan struct{})

func RemoveSessionEventHandler

func RemoveSessionEventHandler(handler SessionEventHandler)

Types

type EdgeJsonFormatter

type EdgeJsonFormatter struct {
	events.JsonFormatter
}

func (*EdgeJsonFormatter) AcceptEntityCountEvent

func (formatter *EdgeJsonFormatter) AcceptEntityCountEvent(event *EntityCountEvent)

func (*EdgeJsonFormatter) AcceptSessionEvent

func (formatter *EdgeJsonFormatter) AcceptSessionEvent(event *SessionEvent)

type EdgePlainTextFormatter

type EdgePlainTextFormatter struct {
	events.PlainTextFormatter
}

func (*EdgePlainTextFormatter) AcceptEntityCountEvent

func (formatter *EdgePlainTextFormatter) AcceptEntityCountEvent(event *EntityCountEvent)

func (*EdgePlainTextFormatter) AcceptSessionEvent

func (formatter *EdgePlainTextFormatter) AcceptSessionEvent(event *SessionEvent)

type EntityCountEvent

type EntityCountEvent struct {
	Namespace string           `json:"namespace"`
	Timestamp time.Time        `json:"timestamp"`
	Counts    map[string]int64 `json:"counts"`
	Error     string           `json:"error"`
}

func (*EntityCountEvent) String

func (event *EntityCountEvent) String() string

type EntityCountEventHandler

type EntityCountEventHandler interface {
	AcceptEntityCountEvent(event *EntityCountEvent)
}

type JsonEntityCountEvent

type JsonEntityCountEvent EntityCountEvent

func (*JsonEntityCountEvent) WriteTo

func (event *JsonEntityCountEvent) WriteTo(output io.WriteCloser) error

type JsonSessionEvent

type JsonSessionEvent SessionEvent

func (*JsonSessionEvent) WriteTo

func (event *JsonSessionEvent) WriteTo(output io.WriteCloser) error

type PlainTextEntityCountEvent

type PlainTextEntityCountEvent EntityCountEvent

func (*PlainTextEntityCountEvent) WriteTo

func (event *PlainTextEntityCountEvent) WriteTo(output io.WriteCloser) error

type PlainTextSessionEvent

type PlainTextSessionEvent SessionEvent

func (*PlainTextSessionEvent) WriteTo

func (event *PlainTextSessionEvent) WriteTo(output io.WriteCloser) error

type SessionEvent

type SessionEvent struct {
	Namespace    string    `json:"namespace"`
	EventType    string    `json:"event_type"`
	Id           string    `json:"id"`
	Timestamp    time.Time `json:"timestamp"`
	Token        string    `json:"token"`
	ApiSessionId string    `json:"api_session_id"`
	IdentityId   string    `json:"identity_id"`
}

func (*SessionEvent) String

func (event *SessionEvent) String() string

type SessionEventHandler

type SessionEventHandler interface {
	AcceptSessionEvent(event *SessionEvent)
}