Documentation
¶
Index ¶
- Constants
- type ApiSessionEvent
- type ApiSessionEventHandler
- type Dispatcher
- func (self *Dispatcher) AddApiSessionEventHandler(handler ApiSessionEventHandler)
- func (self *Dispatcher) AddSessionEventHandler(handler SessionEventHandler)
- func (self *Dispatcher) InitializeEvents()
- func (self *Dispatcher) RemoveApiSessionEventHandler(handler ApiSessionEventHandler)
- func (self *Dispatcher) RemoveSessionEventHandler(handler SessionEventHandler)
- type EdgeJsonFormatter
- type EdgePlainTextFormatter
- type EntityCountEvent
- type EntityCountEventHandler
- type JsonApiSessionEvent
- type JsonEntityCountEvent
- type JsonSessionEvent
- type PlainTextApiSessionEvent
- type PlainTextEntityCountEvent
- type PlainTextSessionEvent
- type SessionEvent
- type SessionEventHandler
Constants ¶
View Source
const ApiSessionEventNS = "edge.apiSessions"
View Source
const ApiSessionEventTypeCreated = "created"
View Source
const ApiSessionEventTypeDeleted = "deleted"
View Source
const EntityCountEventNS = "edge.entityCounts"
View Source
const SessionEventNS = "edge.sessions"
View Source
const SessionEventTypeCreated = "created"
View Source
const SessionEventTypeDeleted = "deleted"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApiSessionEvent ¶ added in v0.20.122
type ApiSessionEvent struct {
Namespace string `json:"namespace"`
EventType string `json:"event_type"`
Id string `json:"id"`
Timestamp time.Time `json:"timestamp"`
Token string `json:"token"`
IdentityId string `json:"identity_id"`
IpAddress string `json:"ip_address"`
}
func (*ApiSessionEvent) String ¶ added in v0.20.122
func (event *ApiSessionEvent) String() string
type ApiSessionEventHandler ¶ added in v0.20.122
type ApiSessionEventHandler interface {
AcceptApiSessionEvent(event *ApiSessionEvent)
}
type Dispatcher ¶ added in v0.23.0
type Dispatcher struct {
// contains filtered or unexported fields
}
func NewDispatcher ¶ added in v0.23.0
func NewDispatcher(n *network.Network, dbProvider persistence.DbProvider, stores *persistence.Stores, closeNotify <-chan struct{}) *Dispatcher
func (*Dispatcher) AddApiSessionEventHandler ¶ added in v0.23.0
func (self *Dispatcher) AddApiSessionEventHandler(handler ApiSessionEventHandler)
func (*Dispatcher) AddSessionEventHandler ¶ added in v0.23.0
func (self *Dispatcher) AddSessionEventHandler(handler SessionEventHandler)
func (*Dispatcher) InitializeEvents ¶ added in v0.23.0
func (self *Dispatcher) InitializeEvents()
func (*Dispatcher) RemoveApiSessionEventHandler ¶ added in v0.23.0
func (self *Dispatcher) RemoveApiSessionEventHandler(handler ApiSessionEventHandler)
func (*Dispatcher) RemoveSessionEventHandler ¶ added in v0.23.0
func (self *Dispatcher) RemoveSessionEventHandler(handler SessionEventHandler)
type EdgeJsonFormatter ¶ added in v0.16.43
type EdgeJsonFormatter struct {
events.JsonFormatter
}
func (*EdgeJsonFormatter) AcceptApiSessionEvent ¶ added in v0.20.122
func (formatter *EdgeJsonFormatter) AcceptApiSessionEvent(event *ApiSessionEvent)
func (*EdgeJsonFormatter) AcceptEntityCountEvent ¶ added in v0.20.28
func (formatter *EdgeJsonFormatter) AcceptEntityCountEvent(event *EntityCountEvent)
func (*EdgeJsonFormatter) AcceptSessionEvent ¶ added in v0.20.28
func (formatter *EdgeJsonFormatter) AcceptSessionEvent(event *SessionEvent)
type EdgePlainTextFormatter ¶ added in v0.16.43
type EdgePlainTextFormatter struct {
events.PlainTextFormatter
}
func (*EdgePlainTextFormatter) AcceptApiSessionEvent ¶ added in v0.20.122
func (formatter *EdgePlainTextFormatter) AcceptApiSessionEvent(event *ApiSessionEvent)
func (*EdgePlainTextFormatter) AcceptEntityCountEvent ¶ added in v0.20.28
func (formatter *EdgePlainTextFormatter) AcceptEntityCountEvent(event *EntityCountEvent)
func (*EdgePlainTextFormatter) AcceptSessionEvent ¶ added in v0.20.28
func (formatter *EdgePlainTextFormatter) AcceptSessionEvent(event *SessionEvent)
type EntityCountEvent ¶ added in v0.20.28
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 ¶ added in v0.20.28
func (event *EntityCountEvent) String() string
type EntityCountEventHandler ¶ added in v0.20.28
type EntityCountEventHandler interface {
AcceptEntityCountEvent(event *EntityCountEvent)
}
type JsonApiSessionEvent ¶ added in v0.20.122
type JsonApiSessionEvent ApiSessionEvent
type JsonEntityCountEvent ¶ added in v0.20.28
type JsonEntityCountEvent EntityCountEvent
type JsonSessionEvent ¶ added in v0.20.28
type JsonSessionEvent SessionEvent
type PlainTextApiSessionEvent ¶ added in v0.20.122
type PlainTextApiSessionEvent ApiSessionEvent
type PlainTextEntityCountEvent ¶ added in v0.20.28
type PlainTextEntityCountEvent EntityCountEvent
type PlainTextSessionEvent ¶ added in v0.20.28
type PlainTextSessionEvent SessionEvent
type SessionEvent ¶ added in v0.20.28
type SessionEvent struct {
Namespace string `json:"namespace"`
EventType string `json:"event_type"`
SessionType string `json:"session_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"`
ServiceId string `json:"service_id"`
}
func (*SessionEvent) String ¶ added in v0.20.28
func (event *SessionEvent) String() string
type SessionEventHandler ¶
type SessionEventHandler interface {
AcceptSessionEvent(event *SessionEvent)
}
Click to show internal directories.
Click to hide internal directories.