notifications

Documentation

Index

• func GenerateProcessedMetric(count int) proton.ObservabilityMetric
• func GenerateReceivedMetric(count int) proton.ObservabilityMetric
• type Service
  • func NewService(userID string, service userevents.Subscribable, ...) *Service
  • func (s *Service) HandleNotificationEvents(ctx context.Context, notificationEvents []proton.NotificationEvent) error
  • func (s *Service) Start(ctx context.Context, group *orderedtasks.OrderedCancelGroup)
• type Store
  • func NewStore(getCachePath func() (string, error)) *Store

Functions

func GenerateProcessedMetric

func GenerateProcessedMetric(count int) proton.ObservabilityMetric

func GenerateReceivedMetric

func GenerateReceivedMetric(count int) proton.ObservabilityMetric

Types

type Service

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

func NewService

func NewService(userID string, service userevents.Subscribable, eventPublisher events.EventPublisher, store *Store,
	getFlagFn unleash.GetFlagValueFn, observabilitySender observability.Sender) *Service

func (*Service) HandleNotificationEvents

func (s *Service) HandleNotificationEvents(ctx context.Context, notificationEvents []proton.NotificationEvent) error

func (*Service) Start

func (s *Service) Start(ctx context.Context, group *orderedtasks.OrderedCancelGroup)

type Store

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

func NewStore

func NewStore(getCachePath func() (string, error)) *Store