sys

package

v5.0.0 Latest Latest Go to latest Published: Jul 16, 2024 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

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

Repository

github.com/masnax/microclustertest

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type OS
- func DefaultOS(stateDir string, socketGroup string, createDir bool) (*OS, 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 ¶

View Source

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"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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.

Source Files ¶

View all Source files

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