crud_stream

Documentation

Index

• Constants
• type CrudEvent
• type Options
• type Plugin
  • func Init(options *Options) *Plugin
  • func (p *Plugin) GetCode() string
  • func (p *Plugin) InterfaceInitEntitySchema(schema beeorm.SettableEntitySchema, _ *beeorm.Registry) error
  • func (p *Plugin) PluginInterfaceEntityFlushed(engine beeorm.Engine, event beeorm.EventEntityFlushed, ...)
  • func (p *Plugin) PluginInterfaceEntityFlushing(engine beeorm.Engine, event beeorm.EventEntityFlushing)
  • func (p *Plugin) PluginInterfaceInitRegistry(registry *beeorm.Registry)

Constants

const ChannelName = "beeorm-crud-stream"

const PluginCode = "github.com/latolukasz/beeorm/plugins/crud_stream"

Types

type CrudEvent

type CrudEvent struct {
	EntityName string
	ID         uint64
	Action     beeorm.FlushType
	Before     beeorm.Bind
	Changes    beeorm.Bind
	MetaData   beeorm.Bind
	Updated    time.Time
}

type Options

type Options struct {
	TagName          string
	DefaultRedisPool string
}

type Plugin

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

func Init

func Init(options *Options) *Plugin

func (*Plugin) GetCode

func (p *Plugin) GetCode() string

func (*Plugin) InterfaceInitEntitySchema

func (p *Plugin) InterfaceInitEntitySchema(schema beeorm.SettableEntitySchema, _ *beeorm.Registry) error

func (*Plugin) PluginInterfaceEntityFlushed

func (p *Plugin) PluginInterfaceEntityFlushed(engine beeorm.Engine, event beeorm.EventEntityFlushed, cacheFlusher beeorm.FlusherCacheSetter)

func (*Plugin) PluginInterfaceEntityFlushing

func (p *Plugin) PluginInterfaceEntityFlushing(engine beeorm.Engine, event beeorm.EventEntityFlushing)

func (*Plugin) PluginInterfaceInitRegistry

func (p *Plugin) PluginInterfaceInitRegistry(registry *beeorm.Registry)