service

package

v0.0.0-...-966ed75 Latest Latest Go to latest Published: Oct 3, 2025 License: Apache-2.0 Imports: 11 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Address  string // Server address to listen on
	NodeName string // Name of the run I'm running now
}

Config for the storage provisioner

type Provisioner struct {
	Log logging.Logger
	Config
}

Provisioner implements a Local storage provisioner

func New(config Config) (*Provisioner, error)

New creates a new local storage provisioner

func (p *Provisioner) GetInfo(ctx context.Context, localPath string) (provisioner.Info, error)

GetInfo fetches information from the filesystem containing the given local path.

func (p *Provisioner) GetNodeInfo(ctx context.Context) (provisioner.NodeInfo, error)

GetNodeInfo fetches information from the current node.

func (p *Provisioner) Prepare(ctx context.Context, localPath string) error

Prepare a volume at the given local path

func (p *Provisioner) Remove(ctx context.Context, localPath string) error

Remove a volume with the given local path

func (p *Provisioner) Run(ctx context.Context)

Run the provisioner until the given context is canceled.

func (p *Provisioner) WrapLogger(in *zerolog.Event) *zerolog.Event