blobstash: a4.io/blobstash/pkg/oplog Index | Files

package oplog

import "a4.io/blobstash/pkg/oplog"

Package oplog provides an HTTP Server-Sent Events (SSE) endpoint for real-time replication of the BlobStore.

Index

Package Files

oplog.go

type Broker Uses

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

func (*Broker) ServeHTTP Uses

func (b *Broker) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Op Uses

type Op struct {
    Event, Data string
}

type Oplog Uses

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

func New Uses

func New(logger log.Logger, conf *config.Config, h *hub.Hub) (*Oplog, error)

func (*Oplog) Register Uses

func (o *Oplog) Register(r *mux.Router, basicAuth func(http.Handler) http.Handler)

Package oplog imports 10 packages (graph) and is imported by 1 packages. Updated 2020-03-20. Refresh now. Tools for package owners.