data

func (*Data) AddRoomBatch ¶

func (d *Data) AddRoomBatch(ctx context.Context, room *model.MatrixRoom)

AddRoomBatch info

func (*Data) AddServer ¶

func (d *Data) AddServer(ctx context.Context, server *model.MatrixServer) error

AddServer info

func (*Data) BanRoom ¶

func (d *Data) BanRoom(ctx context.Context, roomID string) error

BanRoom

func (*Data) BatchServers ¶

func (d *Data) BatchServers(ctx context.Context, servers []string) error

BatchServers adds a batch of servers at once

func (*Data) Close ¶

func (d *Data) Close() error

Close data repository

func (*Data) EachRoom ¶

func (d *Data) EachRoom(ctx context.Context, handler func(roomID string, data *model.MatrixRoom) bool)

EachRoom allows to work with each known room

func (*Data) FilterServers ¶

func (d *Data) FilterServers(ctx context.Context, filter func(server *model.MatrixServer) bool) map[string]*model.MatrixServer

func (*Data) FlushRoomBatch ¶

func (d *Data) FlushRoomBatch(ctx context.Context)

FlushRoomBatch to ensure nothing is left

func (*Data) GetBannedRooms ¶

func (d *Data) GetBannedRooms(ctx context.Context, serverName ...string) ([]string, error)

GetBannedRooms returns full list of the banned rooms

func (*Data) GetBiggestRooms ¶

func (d *Data) GetBiggestRooms(ctx context.Context, limit, offset int) []*model.MatrixRoom

func (*Data) GetIndexStats ¶

func (d *Data) GetIndexStats(ctx context.Context) *model.IndexStats

GetIndexStats returns index stats

func (*Data) GetIndexStatsTL ¶

func (d *Data) GetIndexStatsTL(ctx context.Context, prefix string) (map[time.Time]*model.IndexStats, error)

GetIndexStatsTL returns index stats for the given time prefix in RFC3339 format

func (*Data) GetReportedRooms ¶

func (d *Data) GetReportedRooms(ctx context.Context, serverName ...string) (map[string]string, error)

GetReportedRooms returns full list of the banned rooms with reasons

func (*Data) GetRoom ¶

func (d *Data) GetRoom(ctx context.Context, roomID string) (*model.MatrixRoom, error)

GetRoom info

func (*Data) GetServerInfo ¶

func (d *Data) GetServerInfo(ctx context.Context, name string) (*model.MatrixServer, error)

GetServerInfo

func (*Data) GetServersRoomsCount ¶

func (d *Data) GetServersRoomsCount(ctx context.Context) map[string]int

GetServersRoomsCount returns the count of rooms for each server

func (*Data) HasServer ¶

func (d *Data) HasServer(ctx context.Context, name string) bool

HasServer checks if server is already exists

func (*Data) IsReported ¶

func (d *Data) IsReported(ctx context.Context, roomID string) bool

IsReported returns true if room was already reported

func (*Data) MarkServersOffline ¶

func (d *Data) MarkServersOffline(ctx context.Context, keys []string)

MarkServersOffline from db

func (*Data) RemoveRooms ¶

func (d *Data) RemoveRooms(ctx context.Context, keys []string)

RemoveRooms from db

func (*Data) RemoveServer ¶

func (d *Data) RemoveServer(ctx context.Context, name string) error

RemoveServer info

func (*Data) RemoveServers ¶

func (d *Data) RemoveServers(ctx context.Context, keys []string)

RemoveServers from db

func (*Data) ReportRoom ¶

func (d *Data) ReportRoom(ctx context.Context, roomID, reason string) error

ReportRoom

func (*Data) SaveServersRooms ¶

func (d *Data) SaveServersRooms(ctx context.Context, data map[string][]string) error

SaveServersRooms saves the rooms for each server

func (*Data) SetBiggestRooms ¶

func (d *Data) SetBiggestRooms(ctx context.Context, ids []string) error

func (*Data) SetFinishedAt ¶

func (d *Data) SetFinishedAt(ctx context.Context, process string, finishedAt time.Time) error

SetFinishedAt sets end time of the finished process

func (*Data) SetIndexBannedRooms ¶

func (d *Data) SetIndexBannedRooms(ctx context.Context, rooms int) error

SetIndexBannedRooms sets count of banned rooms

func (*Data) SetIndexBlockedServers ¶

func (d *Data) SetIndexBlockedServers(ctx context.Context, servers int) error

SetIndexBlockedServers sets count of discovered online servers

func (*Data) SetIndexIndexableServers ¶

func (d *Data) SetIndexIndexableServers(ctx context.Context, servers int) error

SetIndexIndexableServers sets count of discovered indexable servers

func (*Data) SetIndexIndexedRooms ¶

func (d *Data) SetIndexIndexedRooms(ctx context.Context, rooms int) error

SetIndexIndexedRooms sets count of indexed rooms

func (*Data) SetIndexOnlineServers ¶

func (d *Data) SetIndexOnlineServers(ctx context.Context, servers int) error

SetIndexOnlineServers sets count of discovered online servers

func (*Data) SetIndexParsedRooms ¶

func (d *Data) SetIndexParsedRooms(ctx context.Context, rooms int) error

SetIndexParsedRooms sets count of parsed rooms

func (*Data) SetIndexReportedRooms ¶

func (d *Data) SetIndexReportedRooms(ctx context.Context, rooms int) error

SetIndexReportedRooms sets count of banned rooms

func (*Data) SetIndexStatsTL ¶

func (d *Data) SetIndexStatsTL(ctx context.Context, calculatedAt time.Time, stats *model.IndexStats) error

SetIndexStatsTL sets index stats for the given time

func (*Data) SetServersRoomsCount ¶

func (d *Data) SetServersRoomsCount(ctx context.Context, data map[string]int) error

SetServersRoomsCount sets the count of rooms for each server

func (*Data) SetStartedAt ¶

func (d *Data) SetStartedAt(ctx context.Context, process string, startedAt time.Time) error

SetStartedAt sets start time of the new process

func (*Data) UnbanRoom ¶

func (d *Data) UnbanRoom(ctx context.Context, roomID string) error

UnbanRoom

func (*Data) UnreportRoom ¶

func (d *Data) UnreportRoom(ctx context.Context, roomID string) error

UnreportRoom