sys

Documentation

Index

• Constants
• type OS
  • func DefaultOS(stateDir string, socketGroup string, createDir bool) (*OS, error)
  • func (s *OS) ClusterCert() (*shared.CertInfo, error)
  • func (s *OS) ControlSocket() api.URL
  • func (s *OS) DatabasePath() string
  • func (s *OS) ServerCert() (*shared.CertInfo, error)
• type Watcher
  • func NewWatcher(ctx context.Context, root string) (*Watcher, error)
  • func (w *Watcher) Watch(path string, fileExt string, f func(path string, event fsnotify.Op) error)

Constants

const (
	// DqliteSocket is the configurable location of the dqlite socket.
	DqliteSocket = "DQLITE_SOCKET"

	// StateDir is the location of the daemon state directory.
	StateDir = "STATE_DIR"

	// SchemaUpdate is the path to the schema update to run.
	SchemaUpdate = "SCHEMA_UPDATE"

	// SocketGroup is the configurable group of the socket.
	SocketGroup = "SOCKET_GROUP"
)

Types

type OS

type OS struct {
	StateDir    string
	DatabaseDir string
	TrustDir    string
	LogFile     string
	SocketGroup string
}

OS contains fields and methods for interacting with the state directory.

func DefaultOS

func DefaultOS(stateDir string, socketGroup string, createDir bool) (*OS, error)

DefaultOS returns a fresh uninitialized OS instance with default values.

func (*OS) ClusterCert

func (s *OS) ClusterCert() (*shared.CertInfo, error)

ClusterCert gets the local cluster certificate from the state directory.

func (*OS) ControlSocket

func (s *OS) ControlSocket() api.URL

ControlSocket returns the full path to the control.socket file that this daemon is listening on.

func (*OS) DatabasePath

func (s *OS) DatabasePath() string

DatabasePath returns the path of the database file managed by dqlite.

func (*OS) ServerCert

func (s *OS) ServerCert() (*shared.CertInfo, error)

ServerCert gets the local server certificate from the state directory.

type Watcher

type Watcher struct {
	*fsnotify.Watcher
	// contains filtered or unexported fields
}

Watcher represents an fsnotify watcher.

func NewWatcher

func NewWatcher(ctx context.Context, root string) (*Watcher, error)

NewWatcher returns a watcher listening for fsnotify events down the given dir.

func (*Watcher) Watch

func (w *Watcher) Watch(path string, fileExt string, f func(path string, event fsnotify.Op) error)

Watch adds a hook to be executed on create/remove events on files with the given extension under the given path.