revolution

Documentation

Overview

This file is part of kuberpult.

Kuberpult is free software: you can redistribute it and/or modify it under the terms of the Expat(MIT) License as published by the Free Software Foundation.

Kuberpult is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the MIT License for more details.

You should have received a copy of the MIT License along with kuberpult. If not, see <https://directory.fsf.org/wiki/License:Expat>.

Copyright 2023 freiheit.com

Index

• type Config
• type Subscriber
  • func New(config Config) *Subscriber
  • func (s *Subscriber) Subscribe(ctx context.Context, b *service.Broadcast) error

Types

type Config

type Config struct {
	URL         string
	Token       []byte
	Concurrency int
	MaxEventAge time.Duration
}

type Subscriber

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

func New

func New(config Config) *Subscriber

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(ctx context.Context, b *service.Broadcast) error