events

Documentation

Index

• type AccountUpdateEvents
  • func NewAccountUpdateEvents() *AccountUpdateEvents
  • func (d *AccountUpdateEvents) Subscribe(to AccountUpdatePublisher)
• type AccountUpdatePublisher
• type ConfigEvents
  • func NewConfigEvents() *ConfigEvents
  • func (c *ConfigEvents) Subscribe(to ConfigPublisher)
• type ConfigPublisher
• type DataUpdateEvents
  • func NewDataUpdateEvents() *DataUpdateEvents
  • func (d *DataUpdateEvents) Subscribe(to DataUpdatePublisher)
• type DataUpdatePublisher
• type Events
  • func NewEvents(killswitch events.PublishSubcriber[bool], ...) *Events
  • func NewEventsEmpty() *Events
  • func (e *Events) Subscribe(to Publisher)
• type LoginEvents
  • func (l *LoginEvents) Subscribe(to LoginPublisher)
• type LoginPublisher
• type MockPublisherSubscriber
  • func (mp *MockPublisherSubscriber[T]) Publish(message T)
  • func (*MockPublisherSubscriber[T]) Subscribe(handler events.Handler[T])
• type Publisher
• type ServiceEvents
  • func (s *ServiceEvents) Subscribe(to ServicePublisher)
• type ServicePublisher
• type SettingsEvents
  • func (s *SettingsEvents) Publish(cfg config.Config)
  • func (s *SettingsEvents) Subscribe(to SettingsPublisher)
• type SettingsPublisher

Types

type AccountUpdateEvents

type AccountUpdateEvents struct {
	SubscriptionUpdate events.PublishSubcriber[*pb.AccountModification]
}

func NewAccountUpdateEvents

func NewAccountUpdateEvents() *AccountUpdateEvents

func (*AccountUpdateEvents) Subscribe

func (d *AccountUpdateEvents) Subscribe(to AccountUpdatePublisher)

type AccountUpdatePublisher

type AccountUpdatePublisher interface {
	NotifySubscriptionChanged(*pb.AccountModification) error
}

type ConfigEvents

type ConfigEvents struct {
	Config events.PublishSubcriber[*config.Config]
}

func NewConfigEvents

func NewConfigEvents() *ConfigEvents

func (*ConfigEvents) Subscribe

func (c *ConfigEvents) Subscribe(to ConfigPublisher)

type ConfigPublisher

type ConfigPublisher interface {
	NotifyConfigChanged(cfg *config.Config) error
}

type DataUpdateEvents

type DataUpdateEvents struct {
	ServersUpdate events.PublishSubcriber[any]
}

func NewDataUpdateEvents

func NewDataUpdateEvents() *DataUpdateEvents

func (*DataUpdateEvents) Subscribe

func (d *DataUpdateEvents) Subscribe(to DataUpdatePublisher)

type DataUpdatePublisher

type DataUpdatePublisher interface {
	NotifyServersListUpdate(any) error
}

type Events

type Events struct {
	Settings *SettingsEvents
	Service  *ServiceEvents
	User     *LoginEvents
}

func NewEvents

func NewEvents(
	killswitch events.PublishSubcriber[bool],
	autoconnect events.PublishSubcriber[bool],
	dns events.PublishSubcriber[events.DataDNS],
	tplite events.PublishSubcriber[bool],
	protocol events.PublishSubcriber[config.Protocol],
	allowlist events.PublishSubcriber[events.DataAllowlist],
	technology events.PublishSubcriber[config.Technology],
	obfuscate events.PublishSubcriber[bool],
	firewall events.PublishSubcriber[bool],
	routing events.PublishSubcriber[bool],
	analytics events.PublishSubcriber[bool],
	notify events.PublishSubcriber[bool],
	meshnet events.PublishSubcriber[bool],
	ipv6 events.PublishSubcriber[bool],
	defaults events.PublishSubcriber[any],
	connect events.PublishSubcriber[events.DataConnect],
	disconnect events.PublishSubcriber[events.DataDisconnect],
	accountCheck events.PublishSubcriber[any],
	uiItemsClick events.PublishSubcriber[events.UiItemsAction],
	heartBeat events.PublishSubcriber[int],
	deviceLocation events.PublishSubcriber[core.Insights],
	lanDiscovery events.PublishSubcriber[bool],
	virtualLocation events.PublishSubcriber[bool],
	postquantumVpn events.PublishSubcriber[bool],
	login events.PublishSubcriber[events.DataAuthorization],
	logout events.PublishSubcriber[events.DataAuthorization],
	mfa events.PublishSubcriber[bool],
) *Events

func NewEventsEmpty

func NewEventsEmpty() *Events

func (*Events) Subscribe

func (e *Events) Subscribe(to Publisher)

type LoginEvents

type LoginEvents struct {
	Login  events.PublishSubcriber[events.DataAuthorization]
	Logout events.PublishSubcriber[events.DataAuthorization]
	MFA    events.PublishSubcriber[bool]
}

func (*LoginEvents) Subscribe

func (l *LoginEvents) Subscribe(to LoginPublisher)

type LoginPublisher

type LoginPublisher interface {
	NotifyLogin(events.DataAuthorization) error
	NotifyLogout(events.DataAuthorization) error
	NotifyMFA(bool) error
}

type MockPublisherSubscriber

type MockPublisherSubscriber[T any] struct {
	EventPublished bool
	Event          T
}

func (*MockPublisherSubscriber[T]) Publish

func (mp *MockPublisherSubscriber[T]) Publish(message T)

func (*MockPublisherSubscriber[T]) Subscribe

func (*MockPublisherSubscriber[T]) Subscribe(handler events.Handler[T])

type Publisher

type Publisher interface {
	SettingsPublisher
	ServicePublisher
	LoginPublisher
}

type ServiceEvents

type ServiceEvents struct {
	Connect        events.PublishSubcriber[events.DataConnect]
	Disconnect     events.PublishSubcriber[events.DataDisconnect]
	AccountCheck   events.PublishSubcriber[any]
	UiItemsClick   events.PublishSubcriber[events.UiItemsAction]
	DeviceLocation events.PublishSubcriber[core.Insights]
}

func (*ServiceEvents) Subscribe

func (s *ServiceEvents) Subscribe(to ServicePublisher)

type ServicePublisher

type ServicePublisher interface {
	NotifyConnect(events.DataConnect) error
	NotifyDisconnect(events.DataDisconnect) error
	NotifyAccountCheck(any) error
	NotifyUiItemsClick(events.UiItemsAction) error
	NotifyDeviceLocation(core.Insights) error
}

type SettingsEvents

type SettingsEvents struct {
	Killswitch           events.PublishSubcriber[bool]
	Autoconnect          events.PublishSubcriber[bool]
	DNS                  events.PublishSubcriber[events.DataDNS]
	ThreatProtectionLite events.PublishSubcriber[bool]
	Protocol             events.PublishSubcriber[config.Protocol]
	Allowlist            events.PublishSubcriber[events.DataAllowlist]
	Technology           events.PublishSubcriber[config.Technology]
	Obfuscate            events.PublishSubcriber[bool]
	Firewall             events.PublishSubcriber[bool]
	Routing              events.PublishSubcriber[bool]
	Notify               events.PublishSubcriber[bool]
	Meshnet              events.PublishSubcriber[bool]
	Ipv6                 events.PublishSubcriber[bool]
	Defaults             events.PublishSubcriber[any]
	LANDiscovery         events.PublishSubcriber[bool]
	VirtualLocation      events.PublishSubcriber[bool]
	PostquantumVPN       events.PublishSubcriber[bool]
}

func (*SettingsEvents) Publish

func (s *SettingsEvents) Publish(cfg config.Config)

func (*SettingsEvents) Subscribe

func (s *SettingsEvents) Subscribe(to SettingsPublisher)

type SettingsPublisher

type SettingsPublisher interface {
	NotifyKillswitch(bool) error
	NotifyAutoconnect(bool) error
	NotifyDNS(events.DataDNS) error
	NotifyThreatProtectionLite(bool) error
	NotifyProtocol(config.Protocol) error
	NotifyAllowlist(events.DataAllowlist) error
	NotifyTechnology(config.Technology) error
	NotifyObfuscate(bool) error
	NotifyFirewall(bool) error
	NotifyRouting(bool) error
	NotifyNotify(bool) error
	NotifyMeshnet(bool) error
	NotifyIpv6(bool) error
	NotifyDefaults(any) error
	NotifyLANDiscovery(bool) error
	NotifyVirtualLocation(bool) error
	NotifyPostquantumVpn(bool) error
}