revolution

package
v1.24.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 26, 2024 License: MIT Imports: 14 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL