jobs

Documentation

Index

• type Dispatcher
  • func (dispatcher *Dispatcher) Comment(comment federation.EntityComment)
  • func (dispatcher *Dispatcher) Contact(contact federation.EntityContact)
  • func (dispatcher *Dispatcher) Like(like federation.EntityLike)
  • func (dispatcher *Dispatcher) Reshare(reshare federation.EntityReshare)
  • func (dispatcher *Dispatcher) Retraction(retraction federation.EntityRetraction)
  • func (dispatcher Dispatcher) Run()
  • func (dispatcher Dispatcher) Send(parentPost models.Post, parentUser models.User, entityXml []byte, orderID uint)
  • func (dispatcher *Dispatcher) StatusMessage(message federation.EntityStatusMessage)
• type FetchAuthor
  • func (fetch *FetchAuthor) Run()
• type Receiver
  • func (receiver *Receiver) CheckAuthor(author string) (models.Person, bool)
  • func (receiver *Receiver) Comment(entity federation.EntityComment)
  • func (receiver *Receiver) Contact(entity federation.EntityContact)
  • func (receiver *Receiver) Like(entity federation.EntityLike)
  • func (receiver *Receiver) Profile(profile federation.EntityProfile)
  • func (receiver *Receiver) Reshare(entity federation.EntityReshare)
  • func (r *Receiver) Retraction(retraction federation.EntityRetraction)
  • func (receiver Receiver) Run()
  • func (receiver *Receiver) StatusMessage(entity federation.EntityStatusMessage)
• type Recovery
  • func (recovery Recovery) Run()
• type Session
  • func (s Session) Run()

Types

type Dispatcher

type Dispatcher struct {
	User    models.User
	Model   interface{}
	Message interface{}
	Relay   bool
}

func (*Dispatcher) Comment

func (dispatcher *Dispatcher) Comment(comment federation.EntityComment)

func (*Dispatcher) Contact

func (dispatcher *Dispatcher) Contact(contact federation.EntityContact)

func (*Dispatcher) Like

func (dispatcher *Dispatcher) Like(like federation.EntityLike)

func (*Dispatcher) Reshare

func (dispatcher *Dispatcher) Reshare(reshare federation.EntityReshare)

func (*Dispatcher) Retraction

func (dispatcher *Dispatcher) Retraction(retraction federation.EntityRetraction)

func (Dispatcher) Run

func (dispatcher Dispatcher) Run()

func (Dispatcher) Send

func (dispatcher Dispatcher) Send(parentPost models.Post, parentUser models.User, entityXml []byte, orderID uint)

XXX do not relay the entity to the sender again

func (*Dispatcher) StatusMessage

func (dispatcher *Dispatcher) StatusMessage(message federation.EntityStatusMessage)

type FetchAuthor

type FetchAuthor struct {
	Author string
	Person models.Person
	Err    error
}

func (*FetchAuthor) Run

func (fetch *FetchAuthor) Run()

type Receiver

type Receiver struct {
	Message federation.Message
	Entity  federation.Entity
	Guid    string
}

func (*Receiver) CheckAuthor

func (receiver *Receiver) CheckAuthor(author string) (models.Person, bool)

func (*Receiver) Comment

func (receiver *Receiver) Comment(entity federation.EntityComment)

func (*Receiver) Contact

func (receiver *Receiver) Contact(entity federation.EntityContact)

func (*Receiver) Like

func (receiver *Receiver) Like(entity federation.EntityLike)

func (*Receiver) Profile

func (receiver *Receiver) Profile(profile federation.EntityProfile)

func (*Receiver) Reshare

func (receiver *Receiver) Reshare(entity federation.EntityReshare)

func (*Receiver) Retraction

func (r *Receiver) Retraction(retraction federation.EntityRetraction)

func (Receiver) Run

func (receiver Receiver) Run()

func (*Receiver) StatusMessage

func (receiver *Receiver) StatusMessage(entity federation.EntityStatusMessage)

type Recovery

type Recovery struct {
	Shareable string
	Guid      string
}

func (Recovery) Run

func (recovery Recovery) Run()

type Session

type Session struct{}

func (Session) Run

func (s Session) Run()

Run will clean-up all sessions older then two days