outbox

Documentation

Index

• type Config
• type Outbox
  • func New(cfg *Config, s store.Store, pubSub pubSub, t httpTransport, ...) (*Outbox, error)
  • func (h *Outbox) Post(activity *vocab.ActivityType) (*url.URL, error)

Types

type Config

type Config struct {
	ServiceName           string
	ServiceIRI            *url.URL
	Topic                 string
	RedeliveryConfig      *redelivery.Config
	MaxRecipients         int
	MaxConcurrentRequests int
}

Config holds configuration parameters for the outbox.

type Outbox

type Outbox struct {
	*Config
	*lifecycle.Lifecycle
	// contains filtered or unexported fields
}

Outbox implements the ActivityPub outbox.

func New

func New(cfg *Config, s store.Store, pubSub pubSub, t httpTransport, activityHandler service.ActivityHandler,
	apClient activityPubClient, resourceResolver resourceResolver, handlerOpts ...service.HandlerOpt) (*Outbox, error)

New returns a new ActivityPub Outbox.

func (*Outbox) Post

func (h *Outbox) Post(activity *vocab.ActivityType) (*url.URL, error)

Post posts an activity to the outbox and returns the ID of the activity that was posted. If the activity does not specify an ID then a unique ID will be generated. The 'actor' of the activity is also assigned to the service IRI of the outbox.