data

Documentation

Index

• type Data
  • func New(path string) (*Data, error)
  • func (d *Data) AddRoomBatch(ctx context.Context, room *model.MatrixRoom)
  • func (d *Data) AddServer(ctx context.Context, server *model.MatrixServer) error
  • func (d *Data) BanRoom(ctx context.Context, roomID string) error
  • func (d *Data) BatchServers(ctx context.Context, servers []string) error
  • func (d *Data) Close() error
  • func (d *Data) EachRoom(ctx context.Context, handler func(roomID string, data *model.MatrixRoom) bool)
  • func (d *Data) FilterServers(ctx context.Context, filter func(server *model.MatrixServer) bool) map[string]*model.MatrixServer
  • func (d *Data) FlushRoomBatch(ctx context.Context)
  • func (d *Data) GetBannedRooms(ctx context.Context, serverName ...string) ([]string, error)
  • func (d *Data) GetBiggestRooms(ctx context.Context, limit, offset int) []*model.MatrixRoom
  • func (d *Data) GetIndexStats(ctx context.Context) *model.IndexStats
  • func (d *Data) GetIndexStatsTL(ctx context.Context, prefix string) (map[time.Time]*model.IndexStats, error)
  • func (d *Data) GetReportedRooms(ctx context.Context, serverName ...string) (map[string]string, error)
  • func (d *Data) GetRoom(ctx context.Context, roomID string) (*model.MatrixRoom, error)
  • func (d *Data) GetServerInfo(ctx context.Context, name string) (*model.MatrixServer, error)
  • func (d *Data) GetServersRoomsCount(ctx context.Context) map[string]int
  • func (d *Data) HasServer(ctx context.Context, name string) bool
  • func (d *Data) IsReported(ctx context.Context, roomID string) bool
  • func (d *Data) MarkServersOffline(ctx context.Context, keys []string)
  • func (d *Data) RemoveRooms(ctx context.Context, keys []string)
  • func (d *Data) RemoveServer(ctx context.Context, name string) error
  • func (d *Data) RemoveServers(ctx context.Context, keys []string)
  • func (d *Data) ReportRoom(ctx context.Context, roomID, reason string) error
  • func (d *Data) SaveServersRooms(ctx context.Context, data map[string][]string) error
  • func (d *Data) SetBiggestRooms(ctx context.Context, ids []string) error
  • func (d *Data) SetFinishedAt(ctx context.Context, process string, finishedAt time.Time) error
  • func (d *Data) SetIndexBannedRooms(ctx context.Context, rooms int) error
  • func (d *Data) SetIndexBlockedServers(ctx context.Context, servers int) error
  • func (d *Data) SetIndexIndexableServers(ctx context.Context, servers int) error
  • func (d *Data) SetIndexIndexedRooms(ctx context.Context, rooms int) error
  • func (d *Data) SetIndexOnlineServers(ctx context.Context, servers int) error
  • func (d *Data) SetIndexParsedRooms(ctx context.Context, rooms int) error
  • func (d *Data) SetIndexReportedRooms(ctx context.Context, rooms int) error
  • func (d *Data) SetIndexStatsTL(ctx context.Context, calculatedAt time.Time, stats *model.IndexStats) error
  • func (d *Data) SetServersRoomsCount(ctx context.Context, data map[string]int) error
  • func (d *Data) SetStartedAt(ctx context.Context, process string, startedAt time.Time) error
  • func (d *Data) UnbanRoom(ctx context.Context, roomID string) error
  • func (d *Data) UnreportRoom(ctx context.Context, roomID string) error

Types

type Data

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

func New

func New(path string) (*Data, error)

func (*Data) AddRoomBatch

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

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