federatingdb

Documentation

Index

• type DB
  • func New(db db.DB, fedWorker *concurrency.WorkerPool[messages.FromFederator]) DB

Types

type DB

type DB interface {
	pub.Database
	Undo(ctx context.Context, undo vocab.ActivityStreamsUndo) error
	Accept(ctx context.Context, accept vocab.ActivityStreamsAccept) error
	Reject(ctx context.Context, reject vocab.ActivityStreamsReject) error
	Announce(ctx context.Context, announce vocab.ActivityStreamsAnnounce) error
}

DB wraps the pub.Database interface with a couple of custom functions for GoToSocial.

func New

func New(db db.DB, fedWorker *concurrency.WorkerPool[messages.FromFederator]) DB

New returns a DB interface using the given database and config