Package longpoll

import "actshad.dev/longpoll"

Overview
Index

Overview

Implementation of a HTTP Longpoll client and server.

This package is heavily inspired by J Cuga's `golongpoll` package (https://github.com/jcuga/golongpoll). It provides a longpoll client and server and supports both last-value cache (LVC) or a full event history.

Index

Variables
func MillisecondEpoch(now time.Time) int64
func SetLogger(l logr.Logger)
type Event
type Manager
func NewManager(opts ...ManagerOption) *Manager
func (this *Manager) Publish(data interface{}) error
func (this *Manager) ServeHTTP(w http.ResponseWriter, r *http.Request)
func (this *Manager) Start(ctx context.Context) error
type ManagerOption
func LVC(l bool) ManagerOption
func MaxTimeout(m int) ManagerOption
type Message
type Watcher
func NewWatcher(opts ...WatcherOption) *Watcher
func (this *Watcher) Watch(ctx context.Context, path string, events chan Event) error
type WatcherOption
func Endpoint(e string) WatcherOption
func Since(s time.Time) WatcherOption
func Transport(t *http.Transport) WatcherOption

Package files

doc.go longpoll.go manager.go option.go util.go watcher.go

Variables

var ErrNoSubscribers = errors.New("no subscribers")

func MillisecondEpoch

func MillisecondEpoch(now time.Time) int64

func SetLogger

func SetLogger(l logr.Logger)

type Event

type Event struct {
    Data json.RawMessage `json:"data"`
}

type Manager

type Manager struct {
    sync.Mutex
    // contains filtered or unexported fields
}

func NewManager

func NewManager(opts ...ManagerOption) *Manager

func (*Manager) Publish

func (this *Manager) Publish(data interface{}) error

func (*Manager) ServeHTTP

func (this *Manager) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Manager) Start

func (this *Manager) Start(ctx context.Context) error

type ManagerOption

type ManagerOption func(*managerOptions)

func LVC

func LVC(l bool) ManagerOption

func MaxTimeout

func MaxTimeout(m int) ManagerOption

type Message

type Message struct {
    Error     string  `json:"error"`
    Timestamp int64   `json:"timestamp"`
    Events    []Event `json:"events"`
}

type Watcher

type Watcher struct {
    sync.RWMutex
    // contains filtered or unexported fields
}

func NewWatcher

func NewWatcher(opts ...WatcherOption) *Watcher

func (*Watcher) Watch

func (this *Watcher) Watch(ctx context.Context, path string, events chan Event) error

type WatcherOption

type WatcherOption func(*watcherOptions)

func Endpoint

func Endpoint(e string) WatcherOption

func Since

func Since(s time.Time) WatcherOption

func Transport

func Transport(t *http.Transport) WatcherOption

actshad.dev/longpoll

Golang HTTP Longpoll Server

Main Changes