lightningcache

Documentation

Index

• func NewLightningCache(emitter *debezium.Emitter, input []abstract.ChangeItem, isSnapshot bool) (packer.SessionPackers, error)
• type PackerLightningCache
  • func NewPackerLightningCache(currPacker packer.Packer) *PackerLightningCache
  • func (c *PackerLightningCache) BuildFinalSchema(_ *abstract.ChangeItem, _ packer.BuilderFunc) ([]byte, error)
  • func (c *PackerLightningCache) GetAndSaveSchemaID(changeItem *abstract.ChangeItem, finalSchema []byte) error
  • func (c *PackerLightningCache) GetSchemaIDResolver() packer.SchemaIDResolver
  • func (c *PackerLightningCache) IsDropSchema() bool
  • func (c *PackerLightningCache) IsNewSchema(changeItem *abstract.ChangeItem) bool
  • func (c *PackerLightningCache) IsUseAnyCache() bool
  • func (c *PackerLightningCache) IsUseSchemaID() bool
  • func (c *PackerLightningCache) Pack(changeItem *abstract.ChangeItem, payloadBuilder packer.BuilderFunc, ...) ([]byte, error)
  • func (c *PackerLightningCache) PackWithSchemaID(schemaID uint32, payload []byte) ([]byte, error)
  • func (c *PackerLightningCache) ResolveSchemaID(schema []byte, table abstract.TableID) (uint32, error)
• type SessionPackersSchemaIDCache
  • func NewSessionPackersSchemaIDCache(keyPacker, valPacker packer.Packer) (*SessionPackersSchemaIDCache, error)
  • func (c *SessionPackersSchemaIDCache) GetAndSaveFinalSchemaAndMaybeSchemaID(isKey bool, changeItem *abstract.ChangeItem, finalSchema []byte) error
  • func (c *SessionPackersSchemaIDCache) IsNewSchema(isKey bool, changeItem *abstract.ChangeItem) bool
  • func (c *SessionPackersSchemaIDCache) IsUseAnyCache() bool
  • func (c *SessionPackersSchemaIDCache) IsUseCache(isKey bool) bool
  • func (c *SessionPackersSchemaIDCache) IsUseSchemaID(isKey bool) bool
  • func (c *SessionPackersSchemaIDCache) Packer(isKey bool) packer.Packer

Functions

func NewLightningCache

func NewLightningCache(emitter *debezium.Emitter, input []abstract.ChangeItem, isSnapshot bool) (packer.SessionPackers, error)

NewLightningCache after NewLightningCache there are all schemaID/finalSchemas should be known

Types

type PackerLightningCache

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

func NewPackerLightningCache

func NewPackerLightningCache(currPacker packer.Packer) *PackerLightningCache

func (*PackerLightningCache) BuildFinalSchema

func (c *PackerLightningCache) BuildFinalSchema(_ *abstract.ChangeItem, _ packer.BuilderFunc) ([]byte, error)

func (*PackerLightningCache) GetAndSaveSchemaID

func (c *PackerLightningCache) GetAndSaveSchemaID(changeItem *abstract.ChangeItem, finalSchema []byte) error

func (*PackerLightningCache) GetSchemaIDResolver

func (c *PackerLightningCache) GetSchemaIDResolver() packer.SchemaIDResolver

func (*PackerLightningCache) IsDropSchema

func (c *PackerLightningCache) IsDropSchema() bool

func (*PackerLightningCache) IsNewSchema

func (c *PackerLightningCache) IsNewSchema(changeItem *abstract.ChangeItem) bool

func (*PackerLightningCache) IsUseAnyCache

func (c *PackerLightningCache) IsUseAnyCache() bool

func (*PackerLightningCache) IsUseSchemaID

func (c *PackerLightningCache) IsUseSchemaID() bool

func (*PackerLightningCache) Pack

func (c *PackerLightningCache) Pack(
	changeItem *abstract.ChangeItem,
	payloadBuilder packer.BuilderFunc,
	schemaBuilder packer.BuilderFunc,
	maybeCachedRawSchema []byte,
) ([]byte, error)

func (*PackerLightningCache) PackWithSchemaID

func (c *PackerLightningCache) PackWithSchemaID(schemaID uint32, payload []byte) ([]byte, error)

func (*PackerLightningCache) ResolveSchemaID

func (c *PackerLightningCache) ResolveSchemaID(schema []byte, table abstract.TableID) (uint32, error)

type SessionPackersSchemaIDCache

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

func NewSessionPackersSchemaIDCache

func NewSessionPackersSchemaIDCache(keyPacker, valPacker packer.Packer) (*SessionPackersSchemaIDCache, error)

func (*SessionPackersSchemaIDCache) GetAndSaveFinalSchemaAndMaybeSchemaID

func (c *SessionPackersSchemaIDCache) GetAndSaveFinalSchemaAndMaybeSchemaID(isKey bool, changeItem *abstract.ChangeItem, finalSchema []byte) error

func (*SessionPackersSchemaIDCache) IsNewSchema

func (c *SessionPackersSchemaIDCache) IsNewSchema(isKey bool, changeItem *abstract.ChangeItem) bool

func (*SessionPackersSchemaIDCache) IsUseAnyCache

func (c *SessionPackersSchemaIDCache) IsUseAnyCache() bool

func (*SessionPackersSchemaIDCache) IsUseCache

func (c *SessionPackersSchemaIDCache) IsUseCache(isKey bool) bool

func (*SessionPackersSchemaIDCache) IsUseSchemaID

func (c *SessionPackersSchemaIDCache) IsUseSchemaID(isKey bool) bool

func (*SessionPackersSchemaIDCache) Packer

func (c *SessionPackersSchemaIDCache) Packer(isKey bool) packer.Packer