events

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
  • func (event *ApiSessionEvent) String() string
• type ApiSessionEventAdapter
  • func (adapter *ApiSessionEventAdapter) AcceptApiSessionEvent(event *ApiSessionEvent)
• type ApiSessionEventHandler
• type EdgeJsonFormatter
  • func (formatter *EdgeJsonFormatter) AcceptApiSessionEvent(event *ApiSessionEvent)
  • func (formatter *EdgeJsonFormatter) AcceptEntityCountEvent(event *EntityCountEvent)
  • func (formatter *EdgeJsonFormatter) AcceptSessionEvent(event *SessionEvent)
• type EdgePlainTextFormatter
  • func (formatter *EdgePlainTextFormatter) AcceptApiSessionEvent(event *ApiSessionEvent)
  • func (formatter *EdgePlainTextFormatter) AcceptEntityCountEvent(event *EntityCountEvent)
  • func (formatter *EdgePlainTextFormatter) AcceptSessionEvent(event *SessionEvent)
• type EntityCountEvent
  • func (event *EntityCountEvent) String() string
• type EntityCountEventHandler
• type JsonApiSessionEvent
  • func (event *JsonApiSessionEvent) WriteTo(output io.WriteCloser) error
• type JsonEntityCountEvent
  • func (event *JsonEntityCountEvent) WriteTo(output io.WriteCloser) error
• type JsonSessionEvent
  • func (event *JsonSessionEvent) WriteTo(output io.WriteCloser) error
• type PlainTextApiSessionEvent
  • func (event *PlainTextApiSessionEvent) 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 ApiSessionEventNS = "edge.apiSessions"

const ApiSessionEventTypeCreated = "created"

const ApiSessionEventTypeDeleted = "deleted"

const EntityCountEventNS = "edge.entityCounts"

const SessionEventNS = "edge.sessions"

const SessionEventTypeCreated = "created"

const SessionEventTypeDeleted = "deleted"

Functions

func AddApiSessionEventHandler

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

func RemoveApiSessionEventHandler(handler ApiSessionEventHandler)

func RemoveSessionEventHandler

func RemoveSessionEventHandler(handler SessionEventHandler)

Types

type ApiSessionEvent

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

func (event *ApiSessionEvent) String() string

type ApiSessionEventAdapter

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

func (*ApiSessionEventAdapter) AcceptApiSessionEvent

func (adapter *ApiSessionEventAdapter) AcceptApiSessionEvent(event *ApiSessionEvent)

type ApiSessionEventHandler

type ApiSessionEventHandler interface {
	AcceptApiSessionEvent(event *ApiSessionEvent)
}

type EdgeJsonFormatter

type EdgeJsonFormatter struct {
	events.JsonFormatter
}

func (*EdgeJsonFormatter) AcceptApiSessionEvent

func (formatter *EdgeJsonFormatter) AcceptApiSessionEvent(event *ApiSessionEvent)

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) AcceptApiSessionEvent

func (formatter *EdgePlainTextFormatter) AcceptApiSessionEvent(event *ApiSessionEvent)

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 JsonApiSessionEvent

type JsonApiSessionEvent ApiSessionEvent

func (*JsonApiSessionEvent) WriteTo

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

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 PlainTextApiSessionEvent

type PlainTextApiSessionEvent ApiSessionEvent

func (*PlainTextApiSessionEvent) WriteTo

func (event *PlainTextApiSessionEvent) 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)
}