endpoint

package

v0.1.1 Latest Latest Go to latest Published: Apr 6, 2019 License: MIT Imports: 10 Imported by: 0

Details

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

Repository

github.com/calistoc/zrepl

Links

Open Source Insights

Documentation ¶

Overview ¶

Package endpoint implements replication endpoints for use with package replication.

Index ¶

Constants
func TestClientIdentity(rootFS *zfs.DatasetPath, clientIdentity string) error
func WithLogger(ctx context.Context, log Logger) context.Context
type FSFilter
type FSMap
type Logger
type Receiver
- func NewReceiver(rootDataset *zfs.DatasetPath, appendClientIdentity bool) *Receiver
type Sender
- func NewSender(fsf zfs.DatasetFilter) *Sender

Constants ¶

View Source

const (
	ClientIdentityKey contextKey
)

Variables ¶

This section is empty.

Functions ¶

func TestClientIdentity ¶

func TestClientIdentity(rootFS *zfs.DatasetPath, clientIdentity string) error

func WithLogger ¶

func WithLogger(ctx context.Context, log Logger) context.Context

Types ¶

type FSFilter ¶

type FSFilter interface {
	Filter(path *zfs.DatasetPath) (pass bool, err error)
}

type FSMap ¶

type FSMap interface {
	FSFilter
	Map(path *zfs.DatasetPath) (*zfs.DatasetPath, error)
	Invert() (FSMap, error)
	AsFilter() FSFilter
}

FIXME: can we get away without error types here?

type Logger ¶

type Logger = logger.Logger

type Receiver ¶

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

Receiver implements replication.ReplicationEndpoint for a receiving side

func NewReceiver ¶

func NewReceiver(rootDataset *zfs.DatasetPath, appendClientIdentity bool) *Receiver

func (*Receiver) DestroySnapshots ¶

func (s *Receiver) DestroySnapshots(ctx context.Context, req *pdu.DestroySnapshotsReq) (*pdu.DestroySnapshotsRes, error)

func (*Receiver) ListFilesystemVersions ¶

func (s *Receiver) ListFilesystemVersions(ctx context.Context, req *pdu.ListFilesystemVersionsReq) (*pdu.ListFilesystemVersionsRes, error)

func (*Receiver) ListFilesystems ¶

func (s *Receiver) ListFilesystems(ctx context.Context, req *pdu.ListFilesystemReq) (*pdu.ListFilesystemRes, error)

func (*Receiver) Ping ¶

func (s *Receiver) Ping(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

func (*Receiver) PingDataconn ¶

func (s *Receiver) PingDataconn(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

func (*Receiver) Receive ¶

func (s *Receiver) Receive(ctx context.Context, req *pdu.ReceiveReq, receive zfs.StreamCopier) (*pdu.ReceiveRes, error)

func (*Receiver) ReplicationCursor ¶

func (s *Receiver) ReplicationCursor(context.Context, *pdu.ReplicationCursorReq) (*pdu.ReplicationCursorRes, error)

func (*Receiver) Send ¶

func (s *Receiver) Send(ctx context.Context, req *pdu.SendReq) (*pdu.SendRes, zfs.StreamCopier, error)

func (*Receiver) WaitForConnectivity ¶

func (s *Receiver) WaitForConnectivity(ctx context.Context) error

type Sender ¶

type Sender struct {
	FSFilter zfs.DatasetFilter
}

Sender implements replication.ReplicationEndpoint for a sending side

func NewSender ¶

func NewSender(fsf zfs.DatasetFilter) *Sender

func (*Sender) DestroySnapshots ¶

func (p *Sender) DestroySnapshots(ctx context.Context, req *pdu.DestroySnapshotsReq) (*pdu.DestroySnapshotsRes, error)

func (*Sender) ListFilesystemVersions ¶

func (s *Sender) ListFilesystemVersions(ctx context.Context, r *pdu.ListFilesystemVersionsReq) (*pdu.ListFilesystemVersionsRes, error)

func (*Sender) ListFilesystems ¶

func (s *Sender) ListFilesystems(ctx context.Context, r *pdu.ListFilesystemReq) (*pdu.ListFilesystemRes, error)

func (*Sender) Ping ¶

func (p *Sender) Ping(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

func (*Sender) PingDataconn ¶

func (p *Sender) PingDataconn(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

func (*Sender) Receive ¶

func (p *Sender) Receive(ctx context.Context, r *pdu.ReceiveReq, receive zfs.StreamCopier) (*pdu.ReceiveRes, error)

func (*Sender) ReplicationCursor ¶

func (p *Sender) ReplicationCursor(ctx context.Context, req *pdu.ReplicationCursorReq) (*pdu.ReplicationCursorRes, error)

func (*Sender) Send ¶

func (s *Sender) Send(ctx context.Context, r *pdu.SendReq) (*pdu.SendRes, zfs.StreamCopier, error)

func (*Sender) WaitForConnectivity ¶

func (p *Sender) WaitForConnectivity(ctx context.Context) error

Source Files ¶

View all Source files

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