event

Aug 8, 2023

Changes in this version

type LinkEventType

+ const LinkDuplicate

Jul 14, 2023

Changes in this version

type ClusterPeer

+ ServerCert []*x509.Certificate

May 4, 2023

Changes in this version

+ type UsageEventV3HandlerWrapper interface

+ IsWrapping func(value UsageEventV3Handler) bool

May 4, 2023

Changes in this version

type CircuitEvent

+ Tags map[string]string

Apr 25, 2023

Changes in this version

type Dispatcher

+ AddEntityChangeEventHandler func(handler EntityChangeEventHandler)

+ AddEntityChangeSource func(store boltz.Store)

+ AddGlobalEntityChangeMetadata func(k string, v any)

+ RemoveEntityChangeEventHandler func(handler EntityChangeEventHandler)

type DispatcherMock

+ func (d DispatcherMock) AcceptEntityChangeEvent(event *EntityChangeEvent)

+ func (d DispatcherMock) AddEntityChangeEventHandler(handler EntityChangeEventHandler)

+ func (d DispatcherMock) AddEntityChangeSource(store boltz.Store)

+ func (d DispatcherMock) AddGlobalEntityChangeMetadata(k string, v any)

+ func (d DispatcherMock) RemoveEntityChangeEventHandler(handler EntityChangeEventHandler)

+ type EntityChangeEvent struct

+ EntityType string

+ EventId string

+ EventType EntityChangeEventType

+ FinalState any

+ InitialState any

+ IsParentEvent *bool

+ IsRecoveryEvent bool

+ Metadata map[string]any

+ Namespace string

+ PropagateIndicator bool

+ Timestamp time.Time

+ type EntityChangeEventHandler interface

+ AcceptEntityChangeEvent func(event *EntityChangeEvent)

+ type EntityChangeEventHandlerWrapper interface

+ IsWrapping func(value EntityChangeEventHandler) bool

+ type EntityChangeEventType string

+ const EntityChangeEventsNs

+ const EntityChangeTypeCommitted

+ const EntityChangeTypeEntityCreated

+ const EntityChangeTypeEntityDeleted

+ const EntityChangeTypeEntityUpdated

Feb 20, 2023

Changes in this version

+ type ClusterEvent struct

+ EventType ClusterEventType

+ Index uint64

+ Namespace string

+ Peers []*ClusterPeer

+ Timestamp time.Time

+ func NewClusterEvent(eventType ClusterEventType) *ClusterEvent

+ func (event *ClusterEvent) String() string

+ type ClusterEventHandler interface

+ AcceptClusterEvent func(event *ClusterEvent)

+ type ClusterEventHandlerF func(event *ClusterEvent)

+ func (f ClusterEventHandlerF) AcceptClusterEvent(event *ClusterEvent)

+ type ClusterEventType string

+ const ClusterEventsNs

+ const ClusterLeadershipGained

+ const ClusterLeadershipLost

+ const ClusterMembersChanged

+ const ClusterPeerConnected

+ const ClusterPeerDisconnected

+ const ClusterStateReadOnly

+ const ClusterStateReadWrite

+ type ClusterPeer struct

+ Addr string

+ Id string

+ Version string

+ func (self *ClusterPeer) String() string

type Dispatcher

+ AddClusterEventHandler func(handler ClusterEventHandler)

+ RemoveClusterEventHandler func(handler ClusterEventHandler)

type DispatcherMock

+ func (d DispatcherMock) AcceptClusterEvent(*ClusterEvent)

+ func (d DispatcherMock) AddClusterEventHandler(ClusterEventHandler)

+ func (d DispatcherMock) RemoveClusterEventHandler(ClusterEventHandler)

Jan 25, 2023

Changes in this version

type CircuitPath

+ InitiatorLocalAddr string

+ InitiatorRemoteAddr string

Jan 20, 2023

Changes in this version

type CircuitEvent

+ Duration *time.Duration

Jan 4, 2023

Changes in this version

+ type CircuitEventHandlerWrapper interface

+ IsWrapping func(value CircuitEventHandler) bool

+ type MetricsEventHandlerWrapper interface

+ IsWrapping func(value MetricsEventHandler) bool

+ type MetricsMessageHandlerWrapper interface

+ IsWrapping func(value MetricsEventHandler) bool

type TerminatorEvent

+ PropagateIndicator bool

+ func (event *TerminatorEvent) IsModelEvent() bool

+ type TerminatorEventHandlerWrapper interface

+ IsWrapping func(value TerminatorEventHandler) bool

Dec 20, 2022

Changes in this version

type Dispatcher

+ GetFormatterFactory func(formatterType string) FormatterFactory

+ ProcessSubscriptions func(handler interface{}, subscriptions []*Subscription) error

+ RegisterEventTypeFunctions func(eventType string, registrationHandler RegistrationHandler, ...)

+ RegisterFormatterFactory func(formatterType string, factory FormatterFactory)

+ RemoveAllSubscriptions func(handler interface{})

type DispatcherMock

+ func (d DispatcherMock) GetFormatterFactory(formatterType string) FormatterFactory

+ func (d DispatcherMock) ProcessSubscriptions(interface{}, []*Subscription) error

+ func (d DispatcherMock) RegisterEventTypeFunctions(string, RegistrationHandler, UnregistrationHandler)

+ func (d DispatcherMock) RegisterFormatterFactory(string, FormatterFactory)

+ func (d DispatcherMock) RemoveAllSubscriptions(interface{})

+ type FormattedEventSink interface

+ AcceptFormattedEvent func(eventType string, formattedEvent []byte)

+ type FormatterFactory interface

+ NewFormatter func(sink FormattedEventSink) io.Closer

+ type FormatterFactoryF func(sink FormattedEventSink) io.Closer

+ func (self FormatterFactoryF) NewFormatter(sink FormattedEventSink) io.Closer

+ type Subscription struct

+ Options map[string]interface{}

+ Type string

+ type TypeRegistrar interface

+ Register func(handler interface{}, config map[string]interface{}) error

+ Unregister func(handler interface{})

+ type UnregistrationHandler func(handler interface{})

Sep 16, 2022

Changes in this version

type UsageEvent

+ Tags map[string]string

+ type UsageEventV3 struct

+ CircuitId string

+ IntervalLength uint64

+ IntervalStartUTC int64

+ Namespace string

+ SourceId string

+ Tags map[string]string

+ Usage map[string]uint64

+ Version uint32

+ func (event *UsageEventV3) String() string

+ type UsageEventV3Handler interface

+ AcceptUsageEventV3 func(event *UsageEventV3)

Sep 9, 2022

Changes in this version

type CircuitPath

+ TerminatorRemoteAddr string

Sep 9, 2022

Changes in this version

type TerminatorEvent

+ HostId string

Jul 19, 2022

Changes in this version

+ const MetricsEventsNs

+ const MetricsEventsVersion

+ const ServiceEventsNs

+ const UsageEventsNs

+ const UsageEventsVersion

+ var CircuitEventTypes = []CircuitEventType

+ type CircuitEvent struct

+ CircuitId string

+ ClientId string

+ Cost *uint32

+ CreationTimespan *time.Duration

+ EventType CircuitEventType

+ FailureCause *string

+ InstanceId string

+ LinkCount int

+ Namespace string

+ Path CircuitPath

+ ServiceId string

+ TerminatorId string

+ Timestamp time.Time

+ Version uint32

+ func (event *CircuitEvent) String() string

+ type CircuitEventHandler interface

+ AcceptCircuitEvent func(event *CircuitEvent)

+ type CircuitEventType string

+ const CircuitCreated

+ const CircuitDeleted

+ const CircuitEventsNs

+ const CircuitEventsVersion

+ const CircuitFailed

+ const CircuitUpdated

+ type CircuitPath struct

+ EgressId string

+ IngressId string

+ Links []string

+ Nodes []string

+ TerminatorLocalAddr string

+ func (self *CircuitPath) String() string

type Dispatcher

+ AddCircuitEventHandler func(handler CircuitEventHandler)

+ AddLinkEventHandler func(handler LinkEventHandler)

+ AddMetricsEventHandler func(handler MetricsEventHandler)

+ AddMetricsMapper func(mapper MetricsMapper)

+ AddMetricsMessageHandler func(handler MetricsMessageHandler)

+ AddRouterEventHandler func(handler RouterEventHandler)

+ AddServiceEventHandler func(handler ServiceEventHandler)

+ AddTerminatorEventHandler func(handler TerminatorEventHandler)

+ AddUsageEventHandler func(handler UsageEventHandler)

+ NewFilteredMetricsAdapter func(sourceFilter *regexp.Regexp, metricFilter *regexp.Regexp, ...) MetricsMessageHandler

+ RegisterEventHandlerFactory func(eventHandlerType string, factory HandlerFactory)

+ RegisterEventType func(eventType string, registrationHandler RegistrationHandler)

+ RemoveCircuitEventHandler func(handler CircuitEventHandler)

+ RemoveLinkEventHandler func(handler LinkEventHandler)

+ RemoveMetricsEventHandler func(handler MetricsEventHandler)

+ RemoveMetricsMessageHandler func(handler MetricsMessageHandler)

+ RemoveRouterEventHandler func(handler RouterEventHandler)

+ RemoveServiceEventHandler func(handler ServiceEventHandler)

+ RemoveTerminatorEventHandler func(handler TerminatorEventHandler)

+ RemoveUsageEventHandler func(handler UsageEventHandler)

+ type DispatcherMock struct

+ func (d DispatcherMock) AcceptCircuitEvent(*CircuitEvent)

+ func (d DispatcherMock) AcceptLinkEvent(*LinkEvent)

+ func (d DispatcherMock) AcceptMetricsEvent(*MetricsEvent)

+ func (d DispatcherMock) AcceptMetricsMsg(*metrics_pb.MetricsMessage)

+ func (d DispatcherMock) AcceptRouterEvent(*RouterEvent)

+ func (d DispatcherMock) AcceptServiceEvent(*ServiceEvent)

+ func (d DispatcherMock) AcceptTerminatorEvent(*TerminatorEvent)

+ func (d DispatcherMock) AcceptUsageEvent(*UsageEvent)

+ func (d DispatcherMock) AddCircuitEventHandler(CircuitEventHandler)

+ func (d DispatcherMock) AddLinkEventHandler(LinkEventHandler)

+ func (d DispatcherMock) AddMetricsEventHandler(MetricsEventHandler)

+ func (d DispatcherMock) AddMetricsMapper(MetricsMapper)

+ func (d DispatcherMock) AddMetricsMessageHandler(MetricsMessageHandler)

+ func (d DispatcherMock) AddRouterEventHandler(RouterEventHandler)

+ func (d DispatcherMock) AddServiceEventHandler(ServiceEventHandler)

+ func (d DispatcherMock) AddTerminatorEventHandler(TerminatorEventHandler)

+ func (d DispatcherMock) AddUsageEventHandler(UsageEventHandler)

+ func (d DispatcherMock) Dispatch(Event)

+ func (d DispatcherMock) NewFilteredMetricsAdapter(*regexp.Regexp, *regexp.Regexp, MetricsEventHandler) MetricsMessageHandler

+ func (d DispatcherMock) RegisterEventHandlerFactory(string, HandlerFactory)

+ func (d DispatcherMock) RegisterEventType(string, RegistrationHandler)

+ func (d DispatcherMock) RemoveCircuitEventHandler(CircuitEventHandler)

+ func (d DispatcherMock) RemoveLinkEventHandler(LinkEventHandler)

+ func (d DispatcherMock) RemoveMetricsEventHandler(MetricsEventHandler)

+ func (d DispatcherMock) RemoveMetricsMessageHandler(MetricsMessageHandler)

+ func (d DispatcherMock) RemoveRouterEventHandler(RouterEventHandler)

+ func (d DispatcherMock) RemoveServiceEventHandler(ServiceEventHandler)

+ func (d DispatcherMock) RemoveTerminatorEventHandler(TerminatorEventHandler)

+ func (d DispatcherMock) RemoveUsageEventHandler(UsageEventHandler)

+ type HandlerFactory interface

+ NewEventHandler func(config map[interface{}]interface{}) (interface{}, error)

+ type LinkConnection struct

+ Id string

+ LocalAddr string

+ RemoteAddr string

+ type LinkEvent struct

+ Connections []*LinkConnection

+ Cost int32

+ DialAddress string

+ DstRouterId string

+ EventType LinkEventType

+ LinkId string

+ Namespace string

+ Protocol string

+ SrcRouterId string

+ Timestamp time.Time

+ func (event *LinkEvent) String() string

+ type LinkEventHandler interface

+ AcceptLinkEvent func(event *LinkEvent)

+ type LinkEventType string

+ const LinkConnected

+ const LinkDialed

+ const LinkEventsNs

+ const LinkFault

+ const LinkFromRouterDisconnectedDest

+ const LinkFromRouterKnown

+ const LinkFromRouterNew

+ type MetricsEvent struct

+ Metric string

+ MetricType string

+ Metrics map[string]interface{}

+ Namespace string

+ SourceAppId string

+ SourceEntityId string

+ SourceEventId string

+ Tags map[string]string

+ Timestamp *timestamppb.Timestamp

+ Version uint32

+ type MetricsEventHandler interface

+ AcceptMetricsEvent func(event *MetricsEvent)

+ type MetricsEventHandlerF func(event *MetricsEvent)

+ func (self MetricsEventHandlerF) AcceptMetricsEvent(event *MetricsEvent)

+ type MetricsMapper func(msg *metrics_pb.MetricsMessage, event *MetricsEvent)

+ type MetricsMessageHandler interface

+ AcceptMetricsMsg func(message *metrics_pb.MetricsMessage)

+ type MetricsMessageHandlerF func(msg *metrics_pb.MetricsMessage)

+ func (self MetricsMessageHandlerF) AcceptMetricsMsg(msg *metrics_pb.MetricsMessage)

+ type RegistrationHandler func(handler interface{}, config map[interface{}]interface{}) error

+ type RouterEvent struct

+ EventType RouterEventType

+ Namespace string

+ RouterId string

+ RouterOnline bool

+ Timestamp time.Time

+ func (event *RouterEvent) String() string

+ type RouterEventHandler interface

+ AcceptRouterEvent func(event *RouterEvent)

+ type RouterEventType string

+ const RouterEventsNs

+ const RouterOffline

+ const RouterOnline

+ type ServiceEvent struct

+ Count uint64

+ EventType string

+ IntervalLength uint64

+ IntervalStartUTC int64

+ Namespace string

+ ServiceId string

+ TerminatorId string

+ Version uint32

+ func (event *ServiceEvent) String() string

+ type ServiceEventHandler interface

+ AcceptServiceEvent func(event *ServiceEvent)

+ type TerminatorEvent struct

+ DynamicCost uint16

+ EventType TerminatorEventType

+ Namespace string

+ Precedence string

+ RouterId string

+ RouterOnline bool

+ ServiceId string

+ StaticCost uint16

+ TerminatorId string

+ Timestamp time.Time

+ TotalTerminators int

+ UsableDefaultTerminators int

+ UsableRequiredTerminators int

+ func (event *TerminatorEvent) String() string

+ type TerminatorEventHandler interface

+ AcceptTerminatorEvent func(event *TerminatorEvent)

+ type TerminatorEventType string

+ const TerminatorCreated

+ const TerminatorDeleted

+ const TerminatorEventsNs

+ const TerminatorRouterOffline

+ const TerminatorRouterOnline

+ const TerminatorUpdated

+ type UsageEvent struct

+ CircuitId string

+ EventType string

+ IntervalLength uint64

+ IntervalStartUTC int64

+ Namespace string

+ SourceId string

+ Usage uint64

+ Version uint32

+ func (event *UsageEvent) String() string

+ type UsageEventHandler interface

+ AcceptUsageEvent func(event *UsageEvent)

Jan 20, 2022

Changes in this version

+ type Dispatcher interface

+ Dispatch func(event Event)

+ func NewDispatcher(closeNotify <-chan struct{}) Dispatcher

+ type Event interface

+ Handle func()