Versions in this module Expand all Collapse all v0 v0.1.14 Apr 23, 2024 v0.1.13 Mar 5, 2024 Changes in this version + type Datastore struct + func MakeDatastore(fileName string) (*Datastore, error) + func (d *Datastore) AddClient(ctx context.Context, id common.ClientID, data *db.ClientData) error + func (d *Datastore) AddClientLabel(ctx context.Context, id common.ClientID, l *fspb.Label) error + func (d *Datastore) BlacklistClient(ctx context.Context, id common.ClientID) error + func (d *Datastore) CleanupAllocation(ctx context.Context, bID ids.BroadcastID, aID ids.AllocationID) error + func (d *Datastore) ClientMessagesForProcessing(ctx context.Context, id common.ClientID, lim uint64, ...) ([]*fspb.Message, error) + func (d *Datastore) Close() error + func (d *Datastore) CreateAllocation(ctx context.Context, id ids.BroadcastID, frac float32, expiry time.Time) (*db.AllocationInfo, error) + func (d *Datastore) CreateBroadcast(ctx context.Context, b *spb.Broadcast, limit uint64) error + func (d *Datastore) DeletePendingMessages(ctx context.Context, ids []common.ClientID) error + func (d *Datastore) FetchResourceUsageRecords(ctx context.Context, id common.ClientID, ...) ([]*spb.ClientResourceUsageRecord, error) + func (d *Datastore) GetClientData(ctx context.Context, id common.ClientID) (*db.ClientData, error) + func (d *Datastore) GetMessageResult(ctx context.Context, id common.MessageID) (*fspb.MessageResult, error) + func (d *Datastore) GetMessages(ctx context.Context, ids []common.MessageID, wantData bool) ([]*fspb.Message, error) + func (d *Datastore) GetPendingMessageCount(ctx context.Context, ids []common.ClientID) (uint64, error) + func (d *Datastore) GetPendingMessages(ctx context.Context, ids []common.ClientID, offset uint64, limit uint64, ...) ([]*fspb.Message, error) + func (d *Datastore) IsNotFound(err error) bool + func (d *Datastore) LinkMessagesToContact(ctx context.Context, contact db.ContactID, ids []common.MessageID) error + func (d *Datastore) ListActiveBroadcasts(ctx context.Context) ([]*db.BroadcastInfo, error) + func (d *Datastore) ListClientContacts(ctx context.Context, id common.ClientID) ([]*spb.ClientContact, error) + func (d *Datastore) ListClients(ctx context.Context, ids []common.ClientID) ([]*spb.Client, error) + func (d *Datastore) ListSentBroadcasts(ctx context.Context, id common.ClientID) ([]ids.BroadcastID, error) + func (d *Datastore) ReadFile(ctx context.Context, service, name string) (data db.ReadSeekerCloser, modtime time.Time, err error) + func (d *Datastore) RecordClientContact(ctx context.Context, data db.ContactData) (db.ContactID, error) + func (d *Datastore) RecordResourceUsageData(ctx context.Context, id common.ClientID, rud *mpb.ResourceUsageData) error + func (d *Datastore) RegisterMessageProcessor(mp db.MessageProcessor) + func (d *Datastore) RemoveClientLabel(ctx context.Context, id common.ClientID, l *fspb.Label) error + func (d *Datastore) SaveBroadcastMessage(ctx context.Context, msg *fspb.Message, bID ids.BroadcastID, ...) error + func (d *Datastore) SetBroadcastLimit(ctx context.Context, id ids.BroadcastID, limit uint64) error + func (d *Datastore) SetMessageResult(ctx context.Context, dest common.ClientID, id common.MessageID, ...) error + func (d *Datastore) StatFile(ctx context.Context, service, name string) (time.Time, error) + func (d *Datastore) StopMessageProcessor() + func (d *Datastore) StoreFile(ctx context.Context, service, name string, data io.Reader) error + func (d *Datastore) StoreMessages(ctx context.Context, msgs []*fspb.Message, contact db.ContactID) error + func (d *Datastore) StreamClientContacts(ctx context.Context, id common.ClientID, ...) error + func (d *Datastore) StreamClientIds(ctx context.Context, includeBlacklisted bool, lastContactAfter *time.Time, ...) error