extension

package

v0.0.12 Latest Latest Go to latest Published: Dec 23, 2025 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/litesql/postgresql

Links

Open Source Insights

Documentation ¶

Index ¶

type CreateSlot
type DropSlot
type Identify
type Info
type PublicationTables
type SubscriptionModule
- func (m *SubscriptionModule) Connect(conn *sqlite.Conn, args []string, declare func(string) error) (sqlite.VirtualTable, error)
type SubscriptionVirtualTable
- func NewSubscriptionVirtualTable(virtualTableName string, conn *sqlite.Conn, timeout time.Duration, ...) (*SubscriptionVirtualTable, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CreateSlot ¶ added in v0.0.3

type CreateSlot struct {
}

func (*CreateSlot) Apply ¶ added in v0.0.3

func (m *CreateSlot) Apply(ctx *sqlite.Context, values ...sqlite.Value)

func (*CreateSlot) Args ¶ added in v0.0.3

func (m *CreateSlot) Args() int

func (*CreateSlot) Deterministic ¶ added in v0.0.3

func (m *CreateSlot) Deterministic() bool

type DropSlot ¶ added in v0.0.2

type DropSlot struct {
}

func (*DropSlot) Apply ¶ added in v0.0.2

func (m *DropSlot) Apply(ctx *sqlite.Context, values ...sqlite.Value)

func (*DropSlot) Args ¶ added in v0.0.2

func (m *DropSlot) Args() int

func (*DropSlot) Deterministic ¶ added in v0.0.2

func (m *DropSlot) Deterministic() bool

type Identify ¶ added in v0.0.2

type Identify struct {
}

func (*Identify) Apply ¶ added in v0.0.2

func (m *Identify) Apply(ctx *sqlite.Context, values ...sqlite.Value)

func (*Identify) Args ¶ added in v0.0.2

func (m *Identify) Args() int

func (*Identify) Deterministic ¶ added in v0.0.2

func (m *Identify) Deterministic() bool

type Info ¶

type Info struct {
}

func (*Info) Apply ¶

func (m *Info) Apply(ctx *sqlite.Context, values ...sqlite.Value)

func (*Info) Args ¶

func (m *Info) Args() int

func (*Info) Deterministic ¶

func (m *Info) Deterministic() bool

type PublicationTables ¶ added in v0.0.5

type PublicationTables struct {
}

func (*PublicationTables) Apply ¶ added in v0.0.5

func (m *PublicationTables) Apply(ctx *sqlite.Context, values ...sqlite.Value)

func (*PublicationTables) Args ¶ added in v0.0.5

func (m *PublicationTables) Args() int

func (*PublicationTables) Deterministic ¶ added in v0.0.5

func (m *PublicationTables) Deterministic() bool

type SubscriptionModule ¶ added in v0.0.5

type SubscriptionModule struct {
}

func (*SubscriptionModule) Connect ¶ added in v0.0.5

func (m *SubscriptionModule) Connect(conn *sqlite.Conn, args []string, declare func(string) error) (sqlite.VirtualTable, error)

type SubscriptionVirtualTable ¶ added in v0.0.5

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

func NewSubscriptionVirtualTable ¶ added in v0.0.5

func NewSubscriptionVirtualTable(virtualTableName string, conn *sqlite.Conn, timeout time.Duration, positionTrackerTable string, useNamespace bool, loggerDef string) (*SubscriptionVirtualTable, error)

func (*SubscriptionVirtualTable) BestIndex ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) BestIndex(in *sqlite.IndexInfoInput) (*sqlite.IndexInfoOutput, error)

func (*SubscriptionVirtualTable) Delete ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) Delete(v sqlite.Value) error

func (*SubscriptionVirtualTable) Destroy ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) Destroy() error

func (*SubscriptionVirtualTable) Disconnect ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) Disconnect() error

func (*SubscriptionVirtualTable) Insert ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) Insert(values ...sqlite.Value) (int64, error)

func (*SubscriptionVirtualTable) Open ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) Open() (sqlite.VirtualCursor, error)

func (*SubscriptionVirtualTable) Replace ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) Replace(old sqlite.Value, new sqlite.Value, _ ...sqlite.Value) error

func (*SubscriptionVirtualTable) Update ¶ added in v0.0.5

func (vt *SubscriptionVirtualTable) Update(_ sqlite.Value, _ ...sqlite.Value) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
loader

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL