jetstream

Documentation

Index

• type DB
• type JetstreamClient
  • func NewJetstreamClient(endpoint, ident string, collections []string, cfg *client.ClientConfig, ...) (*JetstreamClient, error)
  • func (j *JetstreamClient) AddDid(did string)
  • func (j *JetstreamClient) RemoveDid(did string)
  • func (j *JetstreamClient) StartJetstream(ctx context.Context, processFunc func(context.Context, *models.Event) error) error
• type Set

Types

type DB

type DB interface {
	GetLastTimeUs() (int64, error)
	SaveLastTimeUs(int64) error
}

type JetstreamClient

type JetstreamClient struct {
	// contains filtered or unexported fields
}

func NewJetstreamClient

func NewJetstreamClient(endpoint, ident string, collections []string, cfg *client.ClientConfig, logger *slog.Logger, db DB, waitForDid, logDids bool) (*JetstreamClient, error)

func (*JetstreamClient) AddDid

func (j *JetstreamClient) AddDid(did string)

func (*JetstreamClient) RemoveDid

func (j *JetstreamClient) RemoveDid(did string)

func (*JetstreamClient) StartJetstream

func (j *JetstreamClient) StartJetstream(ctx context.Context, processFunc func(context.Context, *models.Event) error) error

StartJetstream starts the jetstream client and processes events using the provided processFunc. The caller is responsible for saving the last time_us to the database (just use your db.UpdateLastTimeUs).

type Set

type Set[T comparable] map[T]struct{}