workers

type Job interface {
	Work(w *Worker)
}

type JobResp interface{}

type RoomAliasesJob struct {
	RoomID   string
	Page     int
	PageSize int
}

type RoomAliasesResp struct {
	RoomInfo    mxclient.RoomInfo
	RoomAliases mxclient.RoomAliases
	PageSize    int
	Page        int
}

type RoomEventsJob struct {
	RoomID   string
	Anchor   string
	Offset   int
	PageSize int
}

type RoomEventsResp struct {
	Events      []gomatrix.Event
	RoomInfo    mxclient.RoomInfo
	MemberMap   map[string]mxclient.MemberInfo
	AtTopEnd    bool
	AtBottomEnd bool
	Err         error
}

type RoomForwardPaginateJob struct {
	Wg      *sync.WaitGroup
	TTL     time.Duration
	KeepMin int
}

type RoomInitialSyncJob struct {
	RoomID string
}

type RoomInitialSyncResp struct {
	Err error
}

type RoomMemberInfoJob struct {
	RoomID string
	Mxid   string
}

type RoomMemberInfoResp struct {
	RoomInfo   mxclient.RoomInfo
	MemberInfo mxclient.MemberInfo
	Err        error
}

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

type RoomMembersJob struct {
	RoomID   string
	Page     int
	PageSize int
}

type RoomMembersResp struct {
	RoomInfo mxclient.RoomInfo
	Members  []mxclient.MemberInfo
	PageSize int
	Page     int
}

type RoomPowerLevelsJob struct {
	RoomID string
}

type RoomPowerLevelsResp struct {
	RoomInfo    mxclient.RoomInfo
	PowerLevels mxclient.PowerLevels
}

type RoomServersJob struct {
	RoomID   string
	Page     int
	PageSize int
}

type RoomServersResp struct {
	RoomInfo mxclient.RoomInfo
	Servers  mxclient.ServerUserCounts
	PageSize int
	Page     int
}

type Worker struct {
	ID int

	Queue  chan Job
	Output chan JobResp
	// contains filtered or unexported fields
}

type Workers struct {
	NumWorkers uint32
	// contains filtered or unexported fields
}