command

package
v0.0.0-...-45e1a9a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 15, 2024 License: Apache-2.0 Imports: 122 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SyncKeyPrefix           = "sync."
	DefaultConcurrencyLimit = 32
)
View Source
const (
	BackupKeyPrefix = "backup."
)

Variables

View Source
var Commands = []*Command{
	cmdAutocomplete,
	cmdUnautocomplete,
	cmdBackup,
	cmdBenchmark,
	cmdCompact,
	cmdDownload,
	cmdExport,
	cmdFiler,
	cmdFilerBackup,
	cmdFilerCat,
	cmdFilerCopy,
	cmdFilerMetaBackup,
	cmdFilerMetaTail,
	cmdFilerRemoteGateway,
	cmdFilerRemoteSynchronize,
	cmdFilerReplicate,
	cmdFilerSynchronize,
	cmdFix,
	cmdFuse,
	cmdIam,
	cmdMaster,
	cmdMasterFollower,
	cmdMount,
	cmdMqBroker,
	cmdS3,
	cmdScaffold,
	cmdServer,
	cmdUpdate,
	cmdUpload,
	cmdVersion,
	cmdVolume,
	cmdWebDav,
}
View Source
var (
	False = false
)
View Source
var (
	MetaBackupKey = []byte("metaBackup")
)

Functions

func AutocompleteMain

func AutocompleteMain(commands []*Command) bool

func Readln

func Readln(r *bufio.Reader) ([]byte, error)

func RunMount

func RunMount(option *MountOptions, umask os.FileMode) bool

func SaveToIdx

func SaveToIdx(scaner *VolumeFileScanner4Fix, idxName string) (ret error)

func WriteFile

func WriteFile(filename string, data []byte, perm os.FileMode) error

Types

type Asset

type Asset struct {
	ID   int    `json:"id"`
	Name string `json:"name"`
	URL  string `json:"url"`
}

Asset is a file uploaded and attached to a release.

type BackupOptions

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

type BenchmarkOptions

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

type Command

type Command struct {
	// Run runs the command.
	// The args are the arguments after the command name.
	Run func(cmd *Command, args []string) bool

	// UsageLine is the one-line usage message.
	// The first word in the line is taken to be the command name.
	UsageLine string

	// Short is the short description shown in the 'go help' output.
	Short string

	// Long is the long message shown in the 'go help <this-command>' output.
	Long string

	// Flag is a set of flags specific to this command.
	Flag flag.FlagSet

	IsDebug *bool
}

func (*Command) Name

func (c *Command) Name() string

Name returns the command's name: the first word in the usage line.

func (*Command) Runnable

func (c *Command) Runnable() bool

Runnable reports whether the command can be run; otherwise it is a documentation pseudo-command such as importpath.

func (*Command) Usage

func (c *Command) Usage()

type CopyOptions

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

type DownloadOptions

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

type ExportOptions

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

type FakeReader

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

a fake reader to generate content to upload

func (*FakeReader) Read

func (l *FakeReader) Read(p []byte) (n int, err error)

func (*FakeReader) WriteTo

func (l *FakeReader) WriteTo(w io.Writer) (n int64, err error)

type FileCopyTask

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

type FileCopyWorker

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

func (*FileCopyWorker) AdjustedUrl

func (worker *FileCopyWorker) AdjustedUrl(location *filer_pb.Location) string

func (*FileCopyWorker) GetDataCenter

func (worker *FileCopyWorker) GetDataCenter() string

func (*FileCopyWorker) WithFilerClient

func (worker *FileCopyWorker) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) (err error)

type FilerBackupOptions

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

type FilerCatOptions

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

func (*FilerCatOptions) GetLookupFileIdFunction

func (fco *FilerCatOptions) GetLookupFileIdFunction() wdclient.LookupFileIdFunctionType

type FilerMetaBackupOptions

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

func (*FilerMetaBackupOptions) AdjustedUrl

func (metaBackup *FilerMetaBackupOptions) AdjustedUrl(location *filer_pb.Location) string

func (*FilerMetaBackupOptions) GetDataCenter

func (metaBackup *FilerMetaBackupOptions) GetDataCenter() string

func (*FilerMetaBackupOptions) WithFilerClient

func (metaBackup *FilerMetaBackupOptions) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error

type FilerOptions

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

type IamOptions

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

type Info

type Info struct {
	// ID is a unique identifier of the mount (may be reused after umount).
	ID int

	// Parent indicates the ID of the mount parent (or of self for the top of the
	// mount tree).
	Parent int

	// Major indicates one half of the device ID which identifies the device class.
	Major int

	// Minor indicates one half of the device ID which identifies a specific
	// instance of device.
	Minor int

	// Root of the mount within the filesystem.
	Root string

	// Mountpoint indicates the mount point relative to the process's root.
	Mountpoint string

	// Opts represents mount-specific options.
	Opts string

	// Optional represents optional fields.
	Optional string

	// Fstype indicates the type of filesystem, such as EXT3.
	Fstype string

	// Source indicates filesystem specific information or "none".
	Source string

	// VfsOpts represents per super block options.
	VfsOpts string
}

Info reveals information about a particular mounted filesystem. This struct is populated from the content in the /proc/<pid>/mountinfo file.

type MasterOptions

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

type MessageQueueBrokerOptions

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

type MetadataProcessor

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

func NewMetadataProcessor

func NewMetadataProcessor(fn pb.ProcessMetadataFunc, concurrency int, offsetTsNs int64) *MetadataProcessor

func (*MetadataProcessor) AddSyncJob

type MountOptions

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

type Release

type Release struct {
	Name        string    `json:"name"`
	TagName     string    `json:"tag_name"`
	Draft       bool      `json:"draft"`
	PreRelease  bool      `json:"prerelease"`
	PublishedAt time.Time `json:"published_at"`
	Assets      []Asset   `json:"assets"`

	Version string `json:"-"` // set manually in the code
}

Release collects data about a single release on GitHub.

func GitHubLatestRelease

func GitHubLatestRelease(ctx context.Context, ver string, owner, repo string) (Release, error)

GitHubLatestRelease uses the GitHub API to get information about the specific release of a repository.

type RemoteGatewayOptions

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

func (*RemoteGatewayOptions) AdjustedUrl

func (option *RemoteGatewayOptions) AdjustedUrl(location *filer_pb.Location) string

func (*RemoteGatewayOptions) GetDataCenter

func (option *RemoteGatewayOptions) GetDataCenter() string

func (*RemoteGatewayOptions) WithFilerClient

func (option *RemoteGatewayOptions) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error

type RemoteSyncOptions

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

func (*RemoteSyncOptions) AdjustedUrl

func (option *RemoteSyncOptions) AdjustedUrl(location *filer_pb.Location) string

func (*RemoteSyncOptions) GetDataCenter

func (option *RemoteSyncOptions) GetDataCenter() string

func (*RemoteSyncOptions) WithFilerClient

func (option *RemoteSyncOptions) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error

type S3Options

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

func (*S3Options) GetCertificateWithUpdate

func (S3opt *S3Options) GetCertificateWithUpdate(*tls.ClientHelloInfo) (*tls.Certificate, error)

GetCertificateWithUpdate Auto refreshing TSL certificate

type ServerOptions

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

type SyncOptions

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

type UpdateOptions

type UpdateOptions struct {
	Version *string
	// contains filtered or unexported fields
}

type UploadOptions

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

type VolumeFileScanner4Export

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

func (*VolumeFileScanner4Export) ReadNeedleBody

func (scanner *VolumeFileScanner4Export) ReadNeedleBody() bool

func (*VolumeFileScanner4Export) VisitNeedle

func (scanner *VolumeFileScanner4Export) VisitNeedle(n *needle.Needle, offset int64, needleHeader, needleBody []byte) error

func (*VolumeFileScanner4Export) VisitSuperBlock

func (scanner *VolumeFileScanner4Export) VisitSuperBlock(superBlock super_block.SuperBlock) error

type VolumeFileScanner4Fix

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

func (*VolumeFileScanner4Fix) ReadNeedleBody

func (scanner *VolumeFileScanner4Fix) ReadNeedleBody() bool

func (*VolumeFileScanner4Fix) VisitNeedle

func (scanner *VolumeFileScanner4Fix) VisitNeedle(n *needle.Needle, offset int64, needleHeader, needleBody []byte) error

func (*VolumeFileScanner4Fix) VisitSuperBlock

func (scanner *VolumeFileScanner4Fix) VisitSuperBlock(superBlock super_block.SuperBlock) error

type VolumeServerOptions

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

type WebDavOption

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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