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.