ressyncrsync

Documentation

Index

• Variables
• func New() resource.Driver
• type T
  • func (t T) Full(ctx context.Context) error
  • func (t T) Info(ctx context.Context) (resource.InfoKeys, error)
  • func (t T) IsRunning() bool
  • func (t *T) Kill(ctx context.Context) error
  • func (t T) Label(_ context.Context) string
  • func (t T) Manifest() *manifest.T
  • func (t T) Provisioned() (provisioned.T, error)
  • func (t T) ScheduleOptions() resource.ScheduleOptions
  • func (t *T) Status(ctx context.Context) status.T
  • func (t T) Update(ctx context.Context) error

Variables

var (
	Keywords = []keywords.Keyword{
		{
			Attr:      "Timeout",
			Converter: converters.Duration,
			Example:   "5m",
			Option:    "timeout",
			Scopable:  true,
			Text:      keywords.NewText(fs, "text/kw/timeout"),
		},
		{
			Attr:    "Src",
			Example: "/srv/{fqdn}/",
			Option:  "src",

			Scopable: true,
			Text:     keywords.NewText(fs, "text/kw/src"),
		},
		{
			Attr:     "Dst",
			Example:  "/srv/{fqdn}",
			Option:   "dst",
			Scopable: true,
			Text:     keywords.NewText(fs, "text/kw/dst"),
		},
		{
			Attr:     "DstFS",
			Example:  "/srv/{fqdn}",
			Option:   "dstfs",
			Scopable: true,
			Text:     keywords.NewText(fs, "text/kw/dstfs"),
		},
		{
			Attr:      "Options",
			Converter: converters.Shlex,
			Example:   "--acls --xattrs --exclude foo/bar",
			Option:    "options",
			Scopable:  true,
			Text:      keywords.NewText(fs, "text/kw/options"),
		},
		{
			Attr:      "ResetOptions",
			Converter: converters.Bool,
			Option:    "reset_options",
			Text:      keywords.NewText(fs, "text/kw/reset_options"),
		},
		{
			Attr:       "Target",
			Candidates: []string{"nodes", "drpnodes"},
			Converter:  converters.List,
			Option:     "target",

			Scopable: true,
			Text:     keywords.NewText(fs, "text/kw/target"),
		},
		{
			Attr:      "Snap",
			Converter: converters.Bool,
			Option:    "snap",
			Text:      keywords.NewText(fs, "text/kw/snap"),
		},
		{
			Attr:   "BandwidthLimit",
			Option: "bwlimit",
			Text:   keywords.NewText(fs, "text/kw/bwlimit"),
		},
	}
)

Functions

func New

func New() resource.Driver

Types

type T

type T struct {
	ressync.T
	BandwidthLimit string
	Src            string
	Dst            string
	DstFS          string
	User           string
	Options        []string
	Target         []string
	Schedule       string
	ResetOptions   bool
	Snap           bool
	Snooze         *time.Duration
	Nodes          []string
	DRPNodes       []string
	ObjectID       uuid.UUID
	Timeout        *time.Duration
	Topology       topology.T
}

T is the driver structure.

func (T) Full

func (t T) Full(ctx context.Context) error

func (T) Info

func (t T) Info(ctx context.Context) (resource.InfoKeys, error)

func (T) IsRunning

func (t T) IsRunning() bool

func (*T) Kill

func (t *T) Kill(ctx context.Context) error

func (T) Label

func (t T) Label(_ context.Context) string

Label implements Label from resource.Driver interface, it returns a formatted short description of the Resource

func (T) Manifest

func (t T) Manifest() *manifest.T

Manifest ...

func (T) Provisioned

func (t T) Provisioned() (provisioned.T, error)

func (T) ScheduleOptions

func (t T) ScheduleOptions() resource.ScheduleOptions

func (*T) Status

func (t *T) Status(ctx context.Context) status.T

func (T) Update

func (t T) Update(ctx context.Context) error