processors

Documentation

Index

• func NewCacheAccountDataProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewCacheAccountFilterProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewCacheAccountProfileProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewCacheAccountRoomTagsProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewCacheAccountUserInfoProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewDBAccountAccountsProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• func NewDBAccountDataProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• func NewDBAccountFilterProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• func NewDBAccountProfileProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• func NewDBAccountRoomTagProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• func NewDBAccountUserInfoProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• type CacheAccountDataProcessor
  • func (p *CacheAccountDataProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheAccountDataProcessor) Start()
• type CacheAccountFilterProcessor
  • func (p *CacheAccountFilterProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheAccountFilterProcessor) Start()
• type CacheAccountProfileProcessor
  • func (p *CacheAccountProfileProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheAccountProfileProcessor) Start()
• type CacheAccountRoomTagsProcessor
  • func (p *CacheAccountRoomTagsProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheAccountRoomTagsProcessor) Start()
• type CacheAccountUserInfoProcessor
  • func (p *CacheAccountUserInfoProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheAccountUserInfoProcessor) Start()
• type DBAccountAccountsProcessor
  • func (p *DBAccountAccountsProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBAccountAccountsProcessor) Start()
• type DBAccountDataProcessor
  • func (p *DBAccountDataProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBAccountDataProcessor) Start()
• type DBAccountFilterProcessor
  • func (p *DBAccountFilterProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBAccountFilterProcessor) Start()
• type DBAccountProfileProcessor
  • func (p *DBAccountProfileProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBAccountProfileProcessor) Start()
• type DBAccountRoomTagProcessor
  • func (p *DBAccountRoomTagProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBAccountRoomTagProcessor) Start()
• type DBAccountUserInfoProcessor
  • func (p *DBAccountUserInfoProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBAccountUserInfoProcessor) Start()

Functions

func NewCacheAccountDataProcessor

func NewCacheAccountDataProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor

func NewCacheAccountFilterProcessor

func NewCacheAccountFilterProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor

func NewCacheAccountProfileProcessor

func NewCacheAccountProfileProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor

func NewCacheAccountRoomTagsProcessor

func NewCacheAccountRoomTagsProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor

func NewCacheAccountUserInfoProcessor

func NewCacheAccountUserInfoProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor

func NewDBAccountAccountsProcessor

func NewDBAccountAccountsProcessor(
	name string,
	cfg *config.Dendrite,
) dbupdatetypes.DBEventSeqProcessor

func NewDBAccountDataProcessor

func NewDBAccountDataProcessor(
	name string,
	cfg *config.Dendrite,
) dbupdatetypes.DBEventSeqProcessor

func NewDBAccountFilterProcessor

func NewDBAccountFilterProcessor(
	name string,
	cfg *config.Dendrite,
) dbupdatetypes.DBEventSeqProcessor

func NewDBAccountProfileProcessor

func NewDBAccountProfileProcessor(
	name string,
	cfg *config.Dendrite,
) dbupdatetypes.DBEventSeqProcessor

func NewDBAccountRoomTagProcessor

func NewDBAccountRoomTagProcessor(
	name string,
	cfg *config.Dendrite,
) dbupdatetypes.DBEventSeqProcessor

func NewDBAccountUserInfoProcessor

func NewDBAccountUserInfoProcessor(
	name string,
	cfg *config.Dendrite,
) dbupdatetypes.DBEventSeqProcessor

Types

type CacheAccountDataProcessor

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

func (*CacheAccountDataProcessor) Process

func (p *CacheAccountDataProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error

func (*CacheAccountDataProcessor) Start

func (p *CacheAccountDataProcessor) Start()

type CacheAccountFilterProcessor

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

func (*CacheAccountFilterProcessor) Process

func (p *CacheAccountFilterProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error

func (*CacheAccountFilterProcessor) Start

func (p *CacheAccountFilterProcessor) Start()

type CacheAccountProfileProcessor

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

func (*CacheAccountProfileProcessor) Process

func (p *CacheAccountProfileProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error

func (*CacheAccountProfileProcessor) Start

func (p *CacheAccountProfileProcessor) Start()

type CacheAccountRoomTagsProcessor

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

func (*CacheAccountRoomTagsProcessor) Process

func (p *CacheAccountRoomTagsProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error

func (*CacheAccountRoomTagsProcessor) Start

func (p *CacheAccountRoomTagsProcessor) Start()

type CacheAccountUserInfoProcessor

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

func (*CacheAccountUserInfoProcessor) Process

func (p *CacheAccountUserInfoProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error

func (*CacheAccountUserInfoProcessor) Start

func (p *CacheAccountUserInfoProcessor) Start()

type DBAccountAccountsProcessor

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

func (*DBAccountAccountsProcessor) Process

func (p *DBAccountAccountsProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error

func (*DBAccountAccountsProcessor) Start

func (p *DBAccountAccountsProcessor) Start()

type DBAccountDataProcessor

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

func (*DBAccountDataProcessor) Process

func (p *DBAccountDataProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error

func (*DBAccountDataProcessor) Start

func (p *DBAccountDataProcessor) Start()

type DBAccountFilterProcessor

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

func (*DBAccountFilterProcessor) Process

func (p *DBAccountFilterProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error

func (*DBAccountFilterProcessor) Start

func (p *DBAccountFilterProcessor) Start()

type DBAccountProfileProcessor

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

func (*DBAccountProfileProcessor) Process

func (p *DBAccountProfileProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error

func (*DBAccountProfileProcessor) Start

func (p *DBAccountProfileProcessor) Start()

type DBAccountRoomTagProcessor

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

func (*DBAccountRoomTagProcessor) Process

func (p *DBAccountRoomTagProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error

func (*DBAccountRoomTagProcessor) Start

func (p *DBAccountRoomTagProcessor) Start()

type DBAccountUserInfoProcessor

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

func (*DBAccountUserInfoProcessor) Process

func (p *DBAccountUserInfoProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error

func (*DBAccountUserInfoProcessor) Start

func (p *DBAccountUserInfoProcessor) Start()