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 

func (t *MetadataProcessor) AddSyncJob(resp *filer_pb.SubscribeMetadataResponse)

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
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.