etcd

package

v0.0.0-...-711078c Latest Latest Go to latest Published: Dec 16, 2019 License: BSD-2-Clause Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/lateefj/shylock

Links

Open Source Insights

Documentation ¶

Overview ¶

Package etcd ... This was influenced by https://github.com/Merovius/etcdfs/blob/master/etcdfs.go since both fuse and etcd are the same.

Index ¶

func Exit() error
func Mount(mountPoint string, ioMap *qos.IOMap) error
type EDDir
type EDFS
- func NewEDFS(mountPoint string, servers []string, readOnly bool) (*EDFS, error)
- func (ed *EDFS) Root() (fs.Node, error)
type EDFile

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Exit ¶

func Exit() error

Exit ... Exit hook

func Mount ¶

func Mount(mountPoint string, ioMap *qos.IOMap) error

Mount ... Place to mount etcd

Types ¶

type EDDir ¶

type EDDir struct {
	Key  string
	FS   *EDFS
	Node *client.Node
}

EDDir ... Directory entry in etcd

func (*EDDir) Attr ¶

func (e *EDDir) Attr(ctx context.Context, attr *fuse.Attr) error

Attr ... Required for fuse

func (*EDDir) Create ¶

func (e *EDDir) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)

Create ... file creating implementation

func (*EDDir) Lookup ¶

func (e *EDDir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.LookupResponse) (fs.Node, error)

Lookup ... Fuse lookup

func (*EDDir) Mkdir ¶

func (e *EDDir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error)

Mkdir ... Fuse make directory hook

func (*EDDir) ReadDirAll ¶

func (e *EDDir) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)

ReadDirAll ... Get everything in a directory

type EDFS ¶

type EDFS struct {
	Path     string
	KApi     client.KeysAPI
	ReadOnly bool
}

EDFS ... etcd root structure

func NewEDFS ¶

func NewEDFS(mountPoint string, servers []string, readOnly bool) (*EDFS, error)

NewEDFS ... Create a new EDFS instance

func (*EDFS) Root ¶

func (ed *EDFS) Root() (fs.Node, error)

Root ... Required for fuse system

type EDFile ¶

type EDFile struct {
	Key  string
	FS   *EDFS
	Node *client.Node
}

EDFile ... File entry in etcd

func (*EDFile) Attr ¶

func (ef *EDFile) Attr(ctx context.Context, attr *fuse.Attr) error

Attr ... Fuse atter

func (*EDFile) Open ¶

func (ef *EDFile) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse) (fs.Handle, error)

Open ... manage cache ect

func (*EDFile) ReadAll ¶

func (ef *EDFile) ReadAll(ctx context.Context) ([]byte, error)

ReadAll ... Etcd files are small so read the entire thing

func (*EDFile) Write ¶

func (ef *EDFile) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error

Write ... Implements write fuse handler

Source Files ¶

View all Source files

edfs.go

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