Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pub

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 9, 2020

Changes in this version

+ const PublicActivityPubIRI

+ var ErrObjectRequired = errors.New("object property required on the provided activity")

+ var ErrTargetRequired = errors.New("target property required on the provided activity")

+ func GetId(t vocab.Type) (*url.URL, error)

+ func IsPublic(s string) bool

+ func ToId(i IdProperty) (*url.URL, error)

+ type Activity interface

+ GetActivityStreamsActor func() vocab.ActivityStreamsActorProperty

+ GetActivityStreamsAttributedTo func() vocab.ActivityStreamsAttributedToProperty

+ GetActivityStreamsAudience func() vocab.ActivityStreamsAudienceProperty

+ GetActivityStreamsBcc func() vocab.ActivityStreamsBccProperty

+ GetActivityStreamsBto func() vocab.ActivityStreamsBtoProperty

+ GetActivityStreamsCc func() vocab.ActivityStreamsCcProperty

+ GetActivityStreamsObject func() vocab.ActivityStreamsObjectProperty

+ GetActivityStreamsTo func() vocab.ActivityStreamsToProperty

+ SetActivityStreamsActor func(i vocab.ActivityStreamsActorProperty)

+ SetActivityStreamsAttributedTo func(i vocab.ActivityStreamsAttributedToProperty)

+ SetActivityStreamsBcc func(i vocab.ActivityStreamsBccProperty)

+ SetActivityStreamsBto func(i vocab.ActivityStreamsBtoProperty)

+ SetActivityStreamsObject func(i vocab.ActivityStreamsObjectProperty)

+ SetActivityStreamsTo func(i vocab.ActivityStreamsToProperty)

+ type Actor interface

+ GetInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ GetOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ PostInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ PostOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ func NewSocialActor(c CommonBehavior, c2s SocialProtocol, db Database, clock Clock) Actor

+ type CommonBehavior interface

+ AuthenticateGetInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ AuthenticateGetOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ GetOutbox func(c context.Context, r *http.Request) (vocab.ActivityStreamsOrderedCollectionPage, error)

+ NewTransport func(c context.Context, actorBoxIRI *url.URL, gofedAgent string) (t Transport, err error)

+ type Database interface

+ ActorForInbox func(c context.Context, inboxIRI *url.URL) (actorIRI *url.URL, err error)

+ ActorForOutbox func(c context.Context, outboxIRI *url.URL) (actorIRI *url.URL, err error)

+ Create func(c context.Context, asType vocab.Type) error

+ Delete func(c context.Context, id *url.URL) error

+ Exists func(c context.Context, id *url.URL) (exists bool, err error)

+ Followers func(c context.Context, actorIRI *url.URL) (followers vocab.ActivityStreamsCollection, err error)

+ Following func(c context.Context, actorIRI *url.URL) (followers vocab.ActivityStreamsCollection, err error)

+ Get func(c context.Context, id *url.URL) (value vocab.Type, err error)

+ GetInbox func(c context.Context, inboxIRI *url.URL) (inbox vocab.ActivityStreamsOrderedCollectionPage, err error)

+ GetOutbox func(c context.Context, outboxIRI *url.URL) (inbox vocab.ActivityStreamsOrderedCollectionPage, err error)

+ InboxContains func(c context.Context, inbox, id *url.URL) (contains bool, err error)

+ Liked func(c context.Context, actorIRI *url.URL) (followers vocab.ActivityStreamsCollection, err error)

+ Lock func(c context.Context, id *url.URL) error

+ NewID func(c context.Context, t vocab.Type) (id *url.URL, err error)

+ OutboxForInbox func(c context.Context, inboxIRI *url.URL) (outboxIRI *url.URL, err error)

+ Owns func(c context.Context, id *url.URL) (owns bool, err error)

+ SetInbox func(c context.Context, inbox vocab.ActivityStreamsOrderedCollectionPage) error

+ SetOutbox func(c context.Context, outbox vocab.ActivityStreamsOrderedCollectionPage) error

+ Unlock func(c context.Context, id *url.URL) error

+ Update func(c context.Context, asType vocab.Type) error

+ type DelegateActor interface

+ AddNewIDs func(c context.Context, a Activity) error

+ AuthenticateGetInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ AuthenticateGetOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ AuthenticatePostInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ AuthenticatePostOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ AuthorizePostInbox func(c context.Context, w http.ResponseWriter, activity Activity) (authorized bool, err error)

+ Deliver func(c context.Context, outbox *url.URL, activity Activity) error

+ GetInbox func(c context.Context, r *http.Request) (vocab.ActivityStreamsOrderedCollectionPage, error)

+ GetOutbox func(c context.Context, r *http.Request) (vocab.ActivityStreamsOrderedCollectionPage, error)

+ InboxForwarding func(c context.Context, inboxIRI *url.URL, activity Activity) error

+ PostInbox func(c context.Context, inboxIRI *url.URL, activity Activity) error

+ PostInboxRequestBodyHook func(c context.Context, r *http.Request, activity Activity) (context.Context, error)

+ PostOutbox func(c context.Context, a Activity, outboxIRI *url.URL, ...) (deliverable bool, e error)

+ PostOutboxRequestBodyHook func(c context.Context, r *http.Request, data vocab.Type) (context.Context, error)

+ WrapInCreate func(c context.Context, value vocab.Type, outboxIRI *url.URL) (vocab.ActivityStreamsCreate, error)

+ type FederatingActor interface

+ Send func(c context.Context, outbox *url.URL, t vocab.Type) (Activity, error)

+ func NewActor(c CommonBehavior, c2s SocialProtocol, s2s FederatingProtocol, db Database, ...) FederatingActor

+ func NewCustomActor(delegate DelegateActor, enableSocialProtocol, enableFederatedProtocol bool, ...) FederatingActor

+ func NewFederatingActor(c CommonBehavior, s2s FederatingProtocol, db Database, clock Clock) FederatingActor

+ type FederatingProtocol interface

+ AuthenticatePostInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ Blocked func(c context.Context, actorIRIs []*url.URL) (blocked bool, err error)

+ DefaultCallback func(c context.Context, activity Activity) error

+ FederatingCallbacks func(c context.Context) (wrapped FederatingWrappedCallbacks, other []interface{}, err error)

+ FilterForwarding func(c context.Context, potentialRecipients []*url.URL, a Activity) (filteredRecipients []*url.URL, err error)

+ GetInbox func(c context.Context, r *http.Request) (vocab.ActivityStreamsOrderedCollectionPage, error)

+ MaxDeliveryRecursionDepth func(c context.Context) int

+ MaxInboxForwardingRecursionDepth func(c context.Context) int

+ PostInboxRequestBodyHook func(c context.Context, r *http.Request, activity Activity) (context.Context, error)

+ type FederatingWrappedCallbacks struct

+ Accept func(context.Context, vocab.ActivityStreamsAccept) error

+ Add func(context.Context, vocab.ActivityStreamsAdd) error

+ Announce func(context.Context, vocab.ActivityStreamsAnnounce) error

+ Block func(context.Context, vocab.ActivityStreamsBlock) error

+ Create func(context.Context, vocab.ActivityStreamsCreate) error

+ Delete func(context.Context, vocab.ActivityStreamsDelete) error

+ Follow func(context.Context, vocab.ActivityStreamsFollow) error

+ Like func(context.Context, vocab.ActivityStreamsLike) error

+ OnFollow OnFollowBehavior

+ Reject func(context.Context, vocab.ActivityStreamsReject) error

+ Remove func(context.Context, vocab.ActivityStreamsRemove) error

+ Undo func(context.Context, vocab.ActivityStreamsUndo) error

+ Update func(context.Context, vocab.ActivityStreamsUpdate) error

type HandlerFunc

+ func NewActivityStreamsHandler(db Database, clock Clock) HandlerFunc

+ type HttpSigTransport struct

+ func NewHttpSigTransport(client HttpClient, appAgent string, clock Clock, ...) *HttpSigTransport

+ func (h HttpSigTransport) BatchDeliver(c context.Context, b []byte, recipients []*url.URL) error

+ func (h HttpSigTransport) Deliver(c context.Context, b []byte, to *url.URL) error

+ func (h HttpSigTransport) Dereference(c context.Context, iri *url.URL) ([]byte, error)

+ type IdProperty interface

+ GetIRI func() *url.URL

+ GetType func() vocab.Type

+ IsIRI func() bool

+ type OnFollowBehavior int

+ const OnFollowAutomaticallyAccept

+ const OnFollowAutomaticallyReject

+ const OnFollowDoNothing

+ type SocialProtocol interface

+ AuthenticatePostOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (out context.Context, authenticated bool, err error)

+ DefaultCallback func(c context.Context, activity Activity) error

+ PostOutboxRequestBodyHook func(c context.Context, r *http.Request, data vocab.Type) (context.Context, error)

+ SocialCallbacks func(c context.Context) (wrapped SocialWrappedCallbacks, other []interface{}, err error)

+ type SocialWrappedCallbacks struct

+ Add func(context.Context, vocab.ActivityStreamsAdd) error

+ Block func(context.Context, vocab.ActivityStreamsBlock) error

+ Create func(context.Context, vocab.ActivityStreamsCreate) error

+ Delete func(context.Context, vocab.ActivityStreamsDelete) error

+ Follow func(context.Context, vocab.ActivityStreamsFollow) error

+ Like func(context.Context, vocab.ActivityStreamsLike) error

+ Remove func(context.Context, vocab.ActivityStreamsRemove) error

+ Undo func(context.Context, vocab.ActivityStreamsUndo) error

+ Update func(context.Context, vocab.ActivityStreamsUpdate) error

+ type Transport interface

+ BatchDeliver func(c context.Context, b []byte, recipients []*url.URL) error

+ Deliver func(c context.Context, b []byte, to *url.URL) error

+ Dereference func(c context.Context, iri *url.URL) ([]byte, error)

v0

v0.4.0

Nov 17, 2018

v0.3.0

Aug 28, 2018

v0.2.1

Aug 19, 2018

v0.2.0

Aug 4, 2018

v0.1.1

Jun 13, 2018

v0.1.0

May 30, 2018

Changes in this version

+ type Application interface

+ CanAdd func(c context.Context, o vocab.ObjectType, t vocab.ObjectType) bool

+ CanRemove func(c context.Context, o vocab.ObjectType, t vocab.ObjectType) bool

+ Get func(c context.Context, id *url.URL, rw RWType) (PubObject, error)

+ GetAsVerifiedUser func(c context.Context, id, authdUser *url.URL, rw RWType) (PubObject, error)

+ GetInbox func(c context.Context, r *http.Request, rw RWType) (vocab.OrderedCollectionType, error)

+ GetOutbox func(c context.Context, r *http.Request, rw RWType) (vocab.OrderedCollectionType, error)

+ GetPublicKey func(c context.Context, publicKeyId string) (pubKey crypto.PublicKey, algo httpsig.Algorithm, user *url.URL, err error)

+ Has func(c context.Context, id *url.URL) (bool, error)

+ NewId func(c context.Context, t Typer) *url.URL

+ Owns func(c context.Context, id *url.URL) bool

+ Set func(c context.Context, o PubObject) error

+ type Callbacker interface

+ Accept func(c context.Context, s *streams.Accept) error

+ Add func(c context.Context, s *streams.Add) error

+ Block func(c context.Context, s *streams.Block) error

+ Create func(c context.Context, s *streams.Create) error

+ Delete func(c context.Context, s *streams.Delete) error

+ Follow func(c context.Context, s *streams.Follow) error

+ Like func(c context.Context, s *streams.Like) error

+ Reject func(c context.Context, s *streams.Reject) error

+ Remove func(c context.Context, s *streams.Remove) error

+ Undo func(c context.Context, s *streams.Undo) error

+ Update func(c context.Context, s *streams.Update) error

+ type Clock interface

+ Now func() time.Time

+ type Deliverer interface

+ Do func(b []byte, to *url.URL, toDo func(b []byte, u *url.URL) error)

+ type FederateAPI interface

+ FilterForwarding func(c context.Context, activity vocab.ActivityType, iris []*url.URL) ([]*url.URL, error)

+ NewSigner func() (httpsig.Signer, error)

+ OnFollow func(c context.Context, s *streams.Follow) FollowResponse

+ PrivateKey func(boxIRI *url.URL) (privKey crypto.PrivateKey, pubKeyId string, err error)

+ Unblocked func(c context.Context, actorIRIs []*url.URL) error

+ type FederateApplication interface

+ type FollowResponse int

+ const AutomaticAccept

+ const AutomaticReject

+ const DoNothing

+ type HandlerFunc func(context.Context, http.ResponseWriter, *http.Request) (bool, error)

+ func ServeActivityPubObject(a Application, clock Clock) HandlerFunc

+ func ServeActivityPubObjectWithVerificationMethod(a Application, clock Clock, verifierFn func(context.Context) SocialAPIVerifier) HandlerFunc

+ type HttpClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type PubObject interface

+ AppendType func(interface{})

+ GetId func() *url.URL

+ HasId func() bool

+ RemoveType func(int)

+ SetId func(*url.URL)

+ func ToPubObject(m map[string]interface{}) (t []PubObject, e error)

+ type Pubber interface

+ GetInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ GetOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ PostInbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ PostOutbox func(c context.Context, w http.ResponseWriter, r *http.Request) (bool, error)

+ func NewFederatingPubber(clock Clock, app FederateApplication, cb Callbacker, d Deliverer, ...) Pubber

+ func NewPubber(clock Clock, app SocialFederateApplication, client, server Callbacker, ...) Pubber

+ func NewSocialPubber(clock Clock, app SocialApplication, cb Callbacker) Pubber

+ type RWType int

+ const Read

+ const ReadWrite

+ type SocialAPI interface

+ ActorIRI func(c context.Context, r *http.Request) (*url.URL, error)

+ GetPublicKeyForOutbox func(c context.Context, publicKeyId string, boxIRI *url.URL) (crypto.PublicKey, httpsig.Algorithm, error)

+ GetSocialAPIVerifier func(c context.Context) SocialAPIVerifier

+ type SocialAPIVerifier interface

+ Verify func(r *http.Request) (authenticatedUser *url.URL, authn, authz bool, err error)

+ VerifyForOutbox func(r *http.Request, outbox *url.URL) (authn, authz bool, err error)

+ type SocialApplication interface

+ type SocialFederateApplication interface

+ type Typer interface

+ GetType func(index int) (v interface{})

+ TypeLen func() (l int)