Documentation ¶
Index ¶
- Constants
- func AddApiSessionEventHandler(handler ApiSessionEventHandler)
- func AddSessionEventHandler(handler SessionEventHandler)
- func Init(dbProvider persistence.DbProvider, stores *persistence.Stores, ...)
- func RemoveApiSessionEventHandler(handler ApiSessionEventHandler)
- func RemoveSessionEventHandler(handler SessionEventHandler)
- type ApiSessionEvent
- type ApiSessionEventAdapter
- type ApiSessionEventHandler
- 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 ¶
func AddApiSessionEventHandler ¶ added in v0.20.122
func AddApiSessionEventHandler(handler ApiSessionEventHandler)
func AddSessionEventHandler ¶
func AddSessionEventHandler(handler SessionEventHandler)
func Init ¶
func Init(dbProvider persistence.DbProvider, stores *persistence.Stores, closeNotify <-chan struct{})
func RemoveApiSessionEventHandler ¶ added in v0.20.122
func RemoveApiSessionEventHandler(handler ApiSessionEventHandler)
func RemoveSessionEventHandler ¶
func RemoveSessionEventHandler(handler SessionEventHandler)
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 ApiSessionEventAdapter ¶ added in v0.20.122
type ApiSessionEventAdapter struct {
// contains filtered or unexported fields
}
func (*ApiSessionEventAdapter) AcceptApiSessionEvent ¶ added in v0.20.122
func (adapter *ApiSessionEventAdapter) AcceptApiSessionEvent(event *ApiSessionEvent)
type ApiSessionEventHandler ¶ added in v0.20.122
type ApiSessionEventHandler interface {
AcceptApiSessionEvent(event *ApiSessionEvent)
}
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
func (*JsonApiSessionEvent) WriteTo ¶ added in v0.20.122
func (event *JsonApiSessionEvent) WriteTo(output io.WriteCloser) error
type JsonEntityCountEvent ¶ added in v0.20.28
type JsonEntityCountEvent EntityCountEvent
func (*JsonEntityCountEvent) WriteTo ¶ added in v0.20.28
func (event *JsonEntityCountEvent) WriteTo(output io.WriteCloser) error
type JsonSessionEvent ¶ added in v0.20.28
type JsonSessionEvent SessionEvent
func (*JsonSessionEvent) WriteTo ¶ added in v0.20.28
func (event *JsonSessionEvent) WriteTo(output io.WriteCloser) error
type PlainTextApiSessionEvent ¶ added in v0.20.122
type PlainTextApiSessionEvent ApiSessionEvent
func (*PlainTextApiSessionEvent) WriteTo ¶ added in v0.20.122
func (event *PlainTextApiSessionEvent) WriteTo(output io.WriteCloser) error
type PlainTextEntityCountEvent ¶ added in v0.20.28
type PlainTextEntityCountEvent EntityCountEvent
func (*PlainTextEntityCountEvent) WriteTo ¶ added in v0.20.28
func (event *PlainTextEntityCountEvent) WriteTo(output io.WriteCloser) error
type PlainTextSessionEvent ¶ added in v0.20.28
type PlainTextSessionEvent SessionEvent
func (*PlainTextSessionEvent) WriteTo ¶ added in v0.20.28
func (event *PlainTextSessionEvent) WriteTo(output io.WriteCloser) error
type SessionEvent ¶ added in v0.20.28
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 ¶ 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.