push

package

v1.34.4 Latest Latest Go to latest Published: Nov 28, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

View Source

var ErrInvalidPushMode = errors.New("invalid push mode")

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 = client.Event

type Mode string

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

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

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

func (s *Service) Enqueue(token string, event 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.