xrqlite

Documentation

Index

• Constants
• func NewConnection(connURL string) (*gorqlite.Connection, error)
• func NewModule(name string) fx.Option
• func RegisterLifecycle(lc fx.Lifecycle, rqlc *Lifecycle)
• type Lifecycle
  • func NewLifecycle(conn *gorqlite.Connection) *Lifecycle
  • func (s *Lifecycle) OnStart(ctx context.Context) error
  • func (s *Lifecycle) OnStop(ctx context.Context) error

Constants

const (
	DefaultConnURLKey = "DB_DSN"
	DefaultConnURL    = "http://localhost"
)

Functions

func NewConnection

func NewConnection(connURL string) (*gorqlite.Connection, error)

func NewModule

func NewModule(name string) fx.Option

Module provides the RQLite dependencies to Uber FX

func RegisterLifecycle

func RegisterLifecycle(lc fx.Lifecycle, rqlc *Lifecycle)

Types

type Lifecycle

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

func NewLifecycle

func NewLifecycle(conn *gorqlite.Connection) *Lifecycle

func (*Lifecycle) OnStart

func (s *Lifecycle) OnStart(ctx context.Context) error

OnStart pings the database

func (*Lifecycle) OnStop

func (s *Lifecycle) OnStop(ctx context.Context) error

OnStop gracefully shuts down the rqlite connection