firehose

package

v0.0.0-...-cf300fe Latest Latest Go to latest Published: Mar 31, 2024 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/uabluerail/bsky-tools

Links

Open Source Insights

Documentation ¶

Index ¶

func FeedPostURL(commit *comatproto.SyncSubscribeRepos_Commit, ...) string
type Firehose
- func New() *Firehose
- func (f *Firehose) Run(ctx context.Context) error
type Hook
type Predicate

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FeedPostURL ¶

func FeedPostURL(commit *comatproto.SyncSubscribeRepos_Commit, op *comatproto.SyncSubscribeRepos_RepoOp) string

Types ¶

type Firehose ¶

type Firehose struct {
	Hooks []Hook
	// contains filtered or unexported fields
}

func New ¶

func New() *Firehose

func (*Firehose) Run ¶

func (f *Firehose) Run(ctx context.Context) error

type Hook ¶

type Hook struct {
	Predicate Predicate
	Action    func(ctx context.Context, commit *comatproto.SyncSubscribeRepos_Commit, op *comatproto.SyncSubscribeRepos_RepoOp, record cbg.CBORMarshaler)
}

type Predicate ¶

type Predicate func(ctx context.Context, commit *comatproto.SyncSubscribeRepos_Commit, op *comatproto.SyncSubscribeRepos_RepoOp, record cbg.CBORMarshaler) bool

func AllOf ¶

func AllOf(predicates ...Predicate) Predicate

func AnyOf ¶

func AnyOf(predicates ...Predicate) Predicate

func CreateOrUpdateOp ¶

func CreateOrUpdateOp() Predicate

func DeleteOp ¶

func DeleteOp() Predicate

func From ¶

func From(did string) Predicate

func IsBlock ¶

func IsBlock() Predicate

func IsFollow ¶

func IsFollow() Predicate

func IsInCollection ¶

func IsInCollection(collection string) Predicate

func IsPost ¶

func IsPost() Predicate

func MentionsDID ¶

func MentionsDID(did string) Predicate

func Not ¶

func Not(predicate Predicate) Predicate

func SenderInSet ¶

func SenderInSet(set didset.QueryableDIDSet) Predicate

func SenderNotInSet ¶

func SenderNotInSet(set didset.QueryableDIDSet) Predicate

Source Files ¶

View all Source files

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