postgresql

Documentation

Index

• Constants
• type Fields
• type Index
  • func (index *Index) GetSelectQuery() string
  • func (index *Index) GetWhereRelationQuery(relationUpdates types.RelationsUpdate) string
• type Relation
  • func (rel *Relation) GetLeftJoinField() string
  • func (rel *Relation) GetLeftJoinQuery(parentTable string) string
  • func (rel *Relation) GetReverseSelectQuery(table string, events []*types.RelationUpdateEvent, subExists string) string
  • func (rel *Relation) GetSelectQuery() string
• type Subscriber
  • func (pg *Subscriber) GetAllRecordsForIndex(index *types.Index) <-chan types.Record
  • func (pg *Subscriber) GetConditionQuery(index *types.Index) string
  • func (pg *Subscriber) GetFullRecordsForIndex(references []string, index *types.Index) <-chan types.Record
  • func (pg *Subscriber) GetFullRecordsForRelationUpdate(relationUpdates types.RelationsUpdate, idx *types.Index) <-chan types.Record
  • func (pg *Subscriber) GetWhereQuery(index *types.Index) string
  • func (pg *Subscriber) Init(config map[string]any)
  • func (pg *Subscriber) Listen()
  • func (pg *Subscriber) PrepareListen(indices []*types.Index)
  • func (pg *Subscriber) Terminate()
• type Wheres
  • func (wheres *Wheres) GetConditionSql(table string, stripQuote bool) string
  • func (wheres *Wheres) GetWhereSql(table string) string

Constants

const (
	ApplicationName             = "PgSync_Listener"
	PoolMinConn                 = 2
	PoolMaxConn                 = 5
	EventName                   = "pgsync_event"
	NotifyTriggerFunctionPrefix = "pgsync_trigger"
	MaxRelationsFilter          = 50
	SchemaName                  = "pgsync"
)

Types

type Fields

type Fields types.Fields

type Index

type Index types.Index

func (*Index) GetSelectQuery

func (index *Index) GetSelectQuery() string

func (*Index) GetWhereRelationQuery

func (index *Index) GetWhereRelationQuery(relationUpdates types.RelationsUpdate) string

type Relation

type Relation types.Relation

func (*Relation) GetLeftJoinField

func (rel *Relation) GetLeftJoinField() string

func (*Relation) GetLeftJoinQuery

func (rel *Relation) GetLeftJoinQuery(parentTable string) string

func (*Relation) GetReverseSelectQuery

func (rel *Relation) GetReverseSelectQuery(table string, events []*types.RelationUpdateEvent, subExists string) string

func (*Relation) GetSelectQuery

func (rel *Relation) GetSelectQuery() string

type Subscriber

type Subscriber struct {
	subscribers.Subscriber
	// contains filtered or unexported fields
}

func (*Subscriber) GetAllRecordsForIndex

func (pg *Subscriber) GetAllRecordsForIndex(index *types.Index) <-chan types.Record

func (*Subscriber) GetConditionQuery

func (pg *Subscriber) GetConditionQuery(index *types.Index) string

func (*Subscriber) GetFullRecordsForIndex

func (pg *Subscriber) GetFullRecordsForIndex(references []string, index *types.Index) <-chan types.Record

func (*Subscriber) GetFullRecordsForRelationUpdate

func (pg *Subscriber) GetFullRecordsForRelationUpdate(relationUpdates types.RelationsUpdate, idx *types.Index) <-chan types.Record

func (*Subscriber) GetWhereQuery

func (pg *Subscriber) GetWhereQuery(index *types.Index) string

func (*Subscriber) Init

func (pg *Subscriber) Init(config map[string]any)

func (*Subscriber) Listen

func (pg *Subscriber) Listen()

func (*Subscriber) PrepareListen

func (pg *Subscriber) PrepareListen(indices []*types.Index)

func (*Subscriber) Terminate

func (pg *Subscriber) Terminate()

type Wheres

type Wheres types.Wheres

func (*Wheres) GetConditionSql

func (wheres *Wheres) GetConditionSql(table string, stripQuote bool) string

func (*Wheres) GetWhereSql

func (wheres *Wheres) GetWhereSql(table string) string