fedbackfill

Documentation

Index

• type BackFillJob
• type BackFillRecord
• type BackfillItem
• type BackfillJobFinishItem
• type BackfillProcessor
  • func (p *BackfillProcessor) Process(job *BackFillJob)
  • func (p *BackfillProcessor) Start()
• type FederationBackFill
  • func NewFederationBackFill(cfg *config.Fed, fedClient *client.FedClientWrap, ...) *FederationBackFill
  • func (c *FederationBackFill) AddRequest(ctx context.Context, evs []gomatrixserverlib.Event, limit bool) error
  • func (c *FederationBackFill) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)

Types

type BackFillJob

type BackFillJob struct {
	PDUs            []*gomatrixserverlib.Event
	Limit           int
	Depth           int64
	FinishedDomains map[string]*BackfillJobFinishItem
}

type BackFillRecord

type BackFillRecord struct {
	RoomID string

	InitState []gomatrixserverlib.Event
}

type BackfillItem

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

type BackfillJobFinishItem

type BackfillJobFinishItem struct {
	EventID      string
	StartEventID string
	StartOffset  int64
	Finished     bool
}

type BackfillProcessor

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

func (*BackfillProcessor) Process

func (p *BackfillProcessor) Process(job *BackFillJob)

func (*BackfillProcessor) Start

func (p *BackfillProcessor) Start()

type FederationBackFill

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

func NewFederationBackFill

func NewFederationBackFill(
	cfg *config.Fed,
	fedClient *client.FedClientWrap,
	feddomains *common.FedDomains,
	repo *repos.BackfillRepo,
) *FederationBackFill

func (*FederationBackFill) AddRequest

func (c *FederationBackFill) AddRequest(ctx context.Context, evs []gomatrixserverlib.Event, limit bool) error

func (*FederationBackFill) OnMessage

func (c *FederationBackFill) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})