events

Documentation

Index

• Constants
• type ApiSessionEvent
  • func (event *ApiSessionEvent) String() string
• type ApiSessionEventHandler
• type ApiSessionEventHandlerWrapper
• type EdgeEventDispatcher
  • func NewEdgeEventDispatcher(n *network.Network, dbProvider persistence.DbProvider, ...) *EdgeEventDispatcher
  • func (self *EdgeEventDispatcher) AddApiSessionEventHandler(handler ApiSessionEventHandler)
  • func (self *EdgeEventDispatcher) AddEntityCountEventHandler(handler EntityCountEventHandler, interval time.Duration, onlyLeaderEvents bool)
  • func (self *EdgeEventDispatcher) AddSessionEventHandler(handler SessionEventHandler)
  • func (self *EdgeEventDispatcher) InitializeEvents()
  • func (self *EdgeEventDispatcher) RemoveApiSessionEventHandler(handler ApiSessionEventHandler)
  • func (self *EdgeEventDispatcher) RemoveEntityCountEventHandler(handler EntityCountEventHandler)
  • func (self *EdgeEventDispatcher) RemoveSessionEventHandler(handler SessionEventHandler)
• type EdgeJsonFormatter
  • func (formatter *EdgeJsonFormatter) AcceptApiSessionEvent(event *ApiSessionEvent)
  • func (formatter *EdgeJsonFormatter) AcceptEntityCountEvent(event *EntityCountEvent)
  • func (formatter *EdgeJsonFormatter) AcceptSessionEvent(event *SessionEvent)
• type EntityCountEvent
  • func (event *EntityCountEvent) String() string
• type EntityCountEventHandler
• type JsonApiSessionEvent
  • func (event *JsonApiSessionEvent) Format() ([]byte, error)
  • func (event *JsonApiSessionEvent) GetEventType() string
• type JsonEntityCountEvent
  • func (event *JsonEntityCountEvent) Format() ([]byte, error)
  • func (event *JsonEntityCountEvent) GetEventType() string
• type JsonSessionEvent
  • func (event *JsonSessionEvent) Format() ([]byte, error)
  • func (event *JsonSessionEvent) GetEventType() string
• type SessionEvent
  • func (event *SessionEvent) String() string
• type SessionEventHandler
• type SessionEventHandlerWrapper

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"

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 ApiSessionEventHandler

type ApiSessionEventHandler interface {
	AcceptApiSessionEvent(event *ApiSessionEvent)
}

type ApiSessionEventHandlerWrapper

type ApiSessionEventHandlerWrapper interface {
	ApiSessionEventHandler
	IsWrapping(value ApiSessionEventHandler) bool
}

type EdgeEventDispatcher

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

func NewEdgeEventDispatcher

func NewEdgeEventDispatcher(n *network.Network, dbProvider persistence.DbProvider, stores *persistence.Stores, closeNotify <-chan struct{}) *EdgeEventDispatcher

func (*EdgeEventDispatcher) AddApiSessionEventHandler

func (self *EdgeEventDispatcher) AddApiSessionEventHandler(handler ApiSessionEventHandler)

func (*EdgeEventDispatcher) AddEntityCountEventHandler

func (self *EdgeEventDispatcher) AddEntityCountEventHandler(handler EntityCountEventHandler, interval time.Duration, onlyLeaderEvents bool)

func (*EdgeEventDispatcher) AddSessionEventHandler

func (self *EdgeEventDispatcher) AddSessionEventHandler(handler SessionEventHandler)

func (*EdgeEventDispatcher) InitializeEvents

func (self *EdgeEventDispatcher) InitializeEvents()

func (*EdgeEventDispatcher) RemoveApiSessionEventHandler

func (self *EdgeEventDispatcher) RemoveApiSessionEventHandler(handler ApiSessionEventHandler)

func (*EdgeEventDispatcher) RemoveEntityCountEventHandler

func (self *EdgeEventDispatcher) RemoveEntityCountEventHandler(handler EntityCountEventHandler)

func (*EdgeEventDispatcher) RemoveSessionEventHandler

func (self *EdgeEventDispatcher) RemoveSessionEventHandler(handler SessionEventHandler)

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

func (event *JsonApiSessionEvent) Format() ([]byte, error)

func (*JsonApiSessionEvent) GetEventType

func (event *JsonApiSessionEvent) GetEventType() string

type JsonEntityCountEvent

type JsonEntityCountEvent EntityCountEvent

func (*JsonEntityCountEvent) Format

func (event *JsonEntityCountEvent) Format() ([]byte, error)

func (*JsonEntityCountEvent) GetEventType

func (event *JsonEntityCountEvent) GetEventType() string

type JsonSessionEvent

type JsonSessionEvent SessionEvent

func (*JsonSessionEvent) Format

func (event *JsonSessionEvent) Format() ([]byte, error)

func (*JsonSessionEvent) GetEventType

func (event *JsonSessionEvent) GetEventType() string

type SessionEvent

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

func (event *SessionEvent) String() string

type SessionEventHandler

type SessionEventHandler interface {
	AcceptSessionEvent(event *SessionEvent)
}

type SessionEventHandlerWrapper

type SessionEventHandlerWrapper interface {
	SessionEventHandler
	IsWrapping(value SessionEventHandler) bool
}