inbox

package

v0.0.0-...-dfe7f75 Latest Latest Go to latest Published: Feb 17, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dimkr/tootik

Documentation ¶

Overview ¶

Package inbox processes activities received from other servers.

Incoming activites are received and queued by fed.Listener.

Index ¶

Variables
type FeedUpdater
- func (u FeedUpdater) Run(ctx context.Context) error
type Queue
- func (q *Queue) Process(ctx context.Context) error
- func (q *Queue) ProcessBatch(ctx context.Context) (int, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrActivityTooNested = errors.New("exceeded activity depth limit")

Functions ¶

This section is empty.

Types ¶

type FeedUpdater ¶

type FeedUpdater struct {
	Domain string
	Config *cfg.Config
	DB     *sql.DB
}

func (FeedUpdater) Run ¶

func (u FeedUpdater) Run(ctx context.Context) error

type Queue ¶

type Queue struct {
	Domain    string
	Config    *cfg.Config
	BlockList *fed.BlockList
	DB        *sql.DB
	Resolver  ap.Resolver
	Key       httpsig.Key
}

func (*Queue) Process ¶

func (q *Queue) Process(ctx context.Context) error

Process polls the queue of incoming activities and processes them.

func (*Queue) ProcessBatch ¶

func (q *Queue) ProcessBatch(ctx context.Context) (int, error)

ProcessBatch processes one batch of incoming activites in the queue.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
note Package note handles insertion of posts.	Package note handles insertion of posts.

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