push

package

v1.32.0 Latest Latest Go to latest Published: Oct 28, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func Module() fx.Option

type BlacklistOperation string

const (
	BlacklistOperationAdded   BlacklistOperation = "added"
	BlacklistOperationSkipped BlacklistOperation = "skipped"
)

type Config struct {
	Mode Mode

	ClientOptions map[string]string

	Debounce time.Duration
	Timeout  time.Duration
}

type Event = types.Event

type Mode string

const (
	ModeFCM      Mode = "fcm"
	ModeUpstream Mode = "upstream"
)

type RetryOutcome string

const (
	RetryOutcomeRetried     RetryOutcome = "retried"
	RetryOutcomeMaxAttempts RetryOutcome = "max_attempts"
)

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

func New(
	config Config,
	client client,
	cacheFactory cache.Factory,
	metrics *metrics,
	logger *zap.Logger,
) (*Service, error)

func (s *Service) Enqueue(token string, event types.Event) error

Enqueue adds the data to the cache and immediately sends all messages if the debounce is 0.

func (s *Service) Run(ctx context.Context)

Run starts a ticker that triggers the sendAll function every debounce interval. It runs indefinitely until the provided context is canceled.