database

Documentation

Index

• type TriggerConfig
• type TriggerConfigs
• type TriggerRun
  • func (t *TriggerRun) Done() bool
  • func (t *TriggerRun) Run(ctx context.Context, payload []byte)
• type TriggerRunner
  • func NewTrigger(logger log.Logger, db *db.Connections, configFile string) (*TriggerRunner, error)
  • func (t *TriggerRunner) Run(ctx context.Context) error

Types

type TriggerConfig

type TriggerConfig struct {
	Name         string `json:"name"`
	DatabaseName string `json:"databaseName"`
	Query        string `json:"query"`
	Key          string `json:"key"`
}

type TriggerConfigs

type TriggerConfigs struct {
	Triggers []TriggerConfig `json:"triggers"`
}

type TriggerRun

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

func (*TriggerRun) Done

func (t *TriggerRun) Done() bool

func (*TriggerRun) Run

func (t *TriggerRun) Run(ctx context.Context, payload []byte)

type TriggerRunner

type TriggerRunner struct {
	trigger.ExecutionRegister
	// contains filtered or unexported fields
}

func NewTrigger

func NewTrigger(
	logger log.Logger,
	db *db.Connections,
	configFile string,
) (*TriggerRunner, error)

func (*TriggerRunner) Run

func (t *TriggerRunner) Run(ctx context.Context) error