extension

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 20, 2025 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 JetStreamPublisherModule added in v0.0.2 

type JetStreamPublisherModule struct {
}

func (*JetStreamPublisherModule) Connect added in v0.0.2 

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

type JetStreamPublisherVirtualTable added in v0.0.2 

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

func NewJetStreamPublisherVirtualTable added in v0.0.2 

func NewJetStreamPublisherVirtualTable(name string, servers string, opts []nats.Option, timeout time.Duration, loggerDef string) (*JetStreamPublisherVirtualTable, error)

func (*JetStreamPublisherVirtualTable) BestIndex added in v0.0.2 

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

func (*JetStreamPublisherVirtualTable) Delete added in v0.0.2 

func (vt *JetStreamPublisherVirtualTable) Delete(_ sqlite.Value) error

func (*JetStreamPublisherVirtualTable) Destroy added in v0.0.2 

func (vt *JetStreamPublisherVirtualTable) Destroy() error

func (*JetStreamPublisherVirtualTable) Disconnect added in v0.0.2 

func (vt *JetStreamPublisherVirtualTable) Disconnect() error

func (*JetStreamPublisherVirtualTable) Insert added in v0.0.2 

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

func (*JetStreamPublisherVirtualTable) Open added in v0.0.2 

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

func (*JetStreamPublisherVirtualTable) Replace added in v0.0.2 

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

func (*JetStreamPublisherVirtualTable) Update added in v0.0.2 

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

type JetStreamSubscriberModule added in v0.0.2 

type JetStreamSubscriberModule struct {
}

func (*JetStreamSubscriberModule) Connect added in v0.0.2 

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

type JetStreamSubscriberVirtualTable added in v0.0.2 

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

func NewJetStreamSubscriberVirtualTable added in v0.0.2 

func NewJetStreamSubscriberVirtualTable(virtualTableName string, servers string, opts []nats.Option, timeout time.Duration, tableName string, conn *sqlite.Conn, loggerDef string) (*JetStreamSubscriberVirtualTable, error)

func (*JetStreamSubscriberVirtualTable) BestIndex added in v0.0.2 

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

func (*JetStreamSubscriberVirtualTable) Delete added in v0.0.2 

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

func (*JetStreamSubscriberVirtualTable) Destroy added in v0.0.2 

func (vt *JetStreamSubscriberVirtualTable) Destroy() error

func (*JetStreamSubscriberVirtualTable) Disconnect added in v0.0.2 

func (vt *JetStreamSubscriberVirtualTable) Disconnect() error

func (*JetStreamSubscriberVirtualTable) Insert added in v0.0.2 

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

func (*JetStreamSubscriberVirtualTable) Open added in v0.0.2 

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

func (*JetStreamSubscriberVirtualTable) Replace added in v0.0.2 

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

func (*JetStreamSubscriberVirtualTable) Update added in v0.0.2 

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

type PublisherModule 

type PublisherModule struct {
}

func (*PublisherModule) Connect 

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

type PublisherVirtualTable 

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

func NewPublisherVirtualTable 

func NewPublisherVirtualTable(name string, servers string, opts []nats.Option, loggerDef string) (*PublisherVirtualTable, error)

func (*PublisherVirtualTable) BestIndex 

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

func (*PublisherVirtualTable) Delete 

func (vt *PublisherVirtualTable) Delete(_ sqlite.Value) error

func (*PublisherVirtualTable) Destroy 

func (vt *PublisherVirtualTable) Destroy() error

func (*PublisherVirtualTable) Disconnect 

func (vt *PublisherVirtualTable) Disconnect() error

func (*PublisherVirtualTable) Insert 

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

func (*PublisherVirtualTable) Open 

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

func (*PublisherVirtualTable) Replace 

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

func (*PublisherVirtualTable) Update 

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

type SubscriberModule 

type SubscriberModule struct {
}

func (*SubscriberModule) Connect 

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

type SubscriberVirtualTable 

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

func NewSubscriberVirtualTable 

func NewSubscriberVirtualTable(virtualTableName string, servers string, opts []nats.Option, tableName string, conn *sqlite.Conn, loggerDef string) (*SubscriberVirtualTable, error)

func (*SubscriberVirtualTable) BestIndex 

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

func (*SubscriberVirtualTable) Delete 

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

func (*SubscriberVirtualTable) Destroy 

func (vt *SubscriberVirtualTable) Destroy() error

func (*SubscriberVirtualTable) Disconnect 

func (vt *SubscriberVirtualTable) Disconnect() error

func (*SubscriberVirtualTable) Insert 

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

func (*SubscriberVirtualTable) Open 

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

func (*SubscriberVirtualTable) Replace 

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

func (*SubscriberVirtualTable) Update 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.