activitypub

Documentation

Index

• func GetTimestampStart() int64
• func NewSource(config *config.Module, checkpoint *engine.Checkpoint, ...) (engine.DataSource, error)
• func ValidatePublicationTimestamp(publicationTimestamp string) bool
• type Option
  • func NewOption(n network.Network, parameters *config.Parameters, isMonitor bool) (*Option, error)
• type State
• type Task
  • func (t Task) BuildActivity(options ...activityx.Option) (*activityx.Activity, error)
  • func (t Task) GetNetwork() network.Network
  • func (t Task) GetTimestamp() uint64
  • func (t Task) ID() string
  • func (t Task) Validate() error

Functions

func GetTimestampStart

func GetTimestampStart() int64

func NewSource

func NewSource(config *config.Module, checkpoint *engine.Checkpoint, databaseClient database.Client) (engine.DataSource, error)

NewSource creates a new data protocol instance

func ValidatePublicationTimestamp

func ValidatePublicationTimestamp(publicationTimestamp string) bool

ValidatePublicationTimestamp checks if a received ActivityPub message has an acceptable timestamp (within 3 months)

Types

type Option

type Option struct {
	RelayURLList   []string `json:"relay_url_list"`
	Port           int64    `json:"port"`
	TimestampStart int64    `json:"timestamp_start" mapstructure:"timestamp_start"`
}

Option represents the configuration options for the ActivityPub client.

func NewOption

func NewOption(n network.Network, parameters *config.Parameters, isMonitor bool) (*Option, error)

NewOption creates a new Option instance from the provided parameters.

type State

type State struct {
	LastOffset int64 `json:"last_offset"`
}

State represents the state of the ActivityPub data protocol.

type Task

type Task struct {
	Network network.Network
	Message activitypub.Object
}

func (Task) BuildActivity

func (t Task) BuildActivity(options ...activityx.Option) (*activityx.Activity, error)

func (Task) GetNetwork

func (t Task) GetNetwork() network.Network

func (Task) GetTimestamp

func (t Task) GetTimestamp() uint64

func (Task) ID

func (t Task) ID() string

func (Task) Validate

func (t Task) Validate() error