processors

Documentation

Index

• func NewCacheEncryptAlgorithmProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewCacheEncryptDeviceKeyProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewCacheEncryptOnetimeKeyProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
• func NewDBEncryptAlgorithmProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• func NewDBEncryptDeviceKeyProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• func NewDBEncryptOnetimeKeyProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
• type CacheEncryptAlgorithmProcessor
  • func (p *CacheEncryptAlgorithmProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheEncryptAlgorithmProcessor) Start()
• type CacheEncryptDeviceKeyProcessor
  • func (p *CacheEncryptDeviceKeyProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheEncryptDeviceKeyProcessor) Start()
• type CacheEncryptOnetimeKeyProcessor
  • func (p *CacheEncryptOnetimeKeyProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
  • func (p *CacheEncryptOnetimeKeyProcessor) Start()
• type DBEncryptAlgorithmProcessor
  • func (p *DBEncryptAlgorithmProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBEncryptAlgorithmProcessor) Start()
• type DBEncryptDeviceKeyProcessor
  • func (p *DBEncryptDeviceKeyProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBEncryptDeviceKeyProcessor) Start()
• type DBEncryptOnetimeKeyProcessor
  • func (p *DBEncryptOnetimeKeyProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
  • func (p *DBEncryptOnetimeKeyProcessor) Start()

Functions

func NewCacheEncryptAlgorithmProcessor

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

func NewCacheEncryptDeviceKeyProcessor

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

func NewCacheEncryptOnetimeKeyProcessor

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

func NewDBEncryptAlgorithmProcessor

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

func NewDBEncryptDeviceKeyProcessor

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

func NewDBEncryptOnetimeKeyProcessor

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

Types

type CacheEncryptAlgorithmProcessor

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

func (*CacheEncryptAlgorithmProcessor) Process

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

func (*CacheEncryptAlgorithmProcessor) Start

func (p *CacheEncryptAlgorithmProcessor) Start()

type CacheEncryptDeviceKeyProcessor

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

func (*CacheEncryptDeviceKeyProcessor) Process

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

func (*CacheEncryptDeviceKeyProcessor) Start

func (p *CacheEncryptDeviceKeyProcessor) Start()

type CacheEncryptOnetimeKeyProcessor

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

func (*CacheEncryptOnetimeKeyProcessor) Process

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

func (*CacheEncryptOnetimeKeyProcessor) Start

func (p *CacheEncryptOnetimeKeyProcessor) Start()

type DBEncryptAlgorithmProcessor

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

func (*DBEncryptAlgorithmProcessor) Process

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

func (*DBEncryptAlgorithmProcessor) Start

func (p *DBEncryptAlgorithmProcessor) Start()

type DBEncryptDeviceKeyProcessor

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

func (*DBEncryptDeviceKeyProcessor) Process

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

func (*DBEncryptDeviceKeyProcessor) Start

func (p *DBEncryptDeviceKeyProcessor) Start()

type DBEncryptOnetimeKeyProcessor

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

func (*DBEncryptOnetimeKeyProcessor) Process

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

func (*DBEncryptOnetimeKeyProcessor) Start

func (p *DBEncryptOnetimeKeyProcessor) Start()