runner

package

v0.0.0-...-22ef2e9 Latest Latest Go to latest Published: Feb 17, 2023 License: Apache-2.0 Imports: 34 Imported by: 0

Details

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

Repository

github.com/DevopsArtFactory/escli

Links

Open Source Insights

Documentation ¶

Index ¶

type Runner
- func New(flags *builder.Flags, config *schema.Config) Runner
type SegmentError
- func (s *SegmentError) PrintError()
type SnapshotSegment

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Runner ¶

type Runner struct {
	Client client.Client
	Flag   *builder.Flags
	Config *schema.Config
}

func New ¶

func New(flags *builder.Flags, config *schema.Config) Runner

func (*Runner) AddObjectSegments ¶

func (r *Runner) AddObjectSegments(bucket, prefix string, token *string) []SnapshotSegment

AddObjectSegments gather all segments recursively

func (Runner) AddProfile ¶

func (r Runner) AddProfile(out io.Writer) error

func (Runner) ArchiveSnapshot ¶

func (r Runner) ArchiveSnapshot(out io.Writer, args []string) error

func (Runner) CatHealth ¶

func (r Runner) CatHealth(out io.Writer) error

func (Runner) CatIndices ¶

func (r Runner) CatIndices(out io.Writer) error

func (Runner) CatNodes ¶

func (r Runner) CatNodes(out io.Writer) error

func (Runner) CatShards ¶

func (r Runner) CatShards(out io.Writer) error

func (Runner) ClusterReroute ¶

func (r Runner) ClusterReroute(out io.Writer) error

func (Runner) ClusterSettings ¶

func (r Runner) ClusterSettings(out io.Writer, args []string) error

func (Runner) CreateIndex ¶

func (r Runner) CreateIndex(out io.Writer, args []string) error

func (Runner) CreateSnapshot ¶

func (r Runner) CreateSnapshot(out io.Writer, args []string) error

func (Runner) DeleteIndex ¶

func (r Runner) DeleteIndex(out io.Writer, args []string) error

func (Runner) DeleteSnapshot ¶

func (r Runner) DeleteSnapshot(out io.Writer, args []string) error

func (Runner) DiagCluster ¶

func (r Runner) DiagCluster(out io.Writer) error

func (Runner) Fix ¶

func (r Runner) Fix(out io.Writer) error

Old Version: "0.0.3" Current Version: "0.0.4"

func (Runner) IndexSettings ¶

func (r Runner) IndexSettings(out io.Writer, args []string) error

func (Runner) ListProfile ¶

func (r Runner) ListProfile(out io.Writer) error

func (Runner) ListSnapshot ¶

func (r Runner) ListSnapshot(out io.Writer) error

func (Runner) RemoveProfile ¶

func (r Runner) RemoveProfile(out io.Writer, args []string) error

func (*Runner) RestoreSnapshot ¶

func (r *Runner) RestoreSnapshot(out io.Writer, args []string) error

RestoreSnapshot is main function of restoring snapshot process

func (*Runner) RunConcurrentRestore ¶

func (r *Runner) RunConcurrentRestore(out io.Writer, bucket string, segments []SnapshotSegment, maxSemaphore int64) (bool, error)

RunConcurrentRestore runs restore process concurrently This only runs if user uses --force option

func (Runner) Stats ¶

func (r Runner) Stats(out io.Writer, args []string) error

func (Runner) StatsIndex ¶

func (r Runner) StatsIndex(out io.Writer, args []string) error

func (Runner) Update ¶

func (r Runner) Update(out io.Writer) error

type SegmentError ¶

type SegmentError struct {
	Key   string
	Error error
}

func (*SegmentError) PrintError ¶

func (s *SegmentError) PrintError()

type SnapshotSegment ¶

type SnapshotSegment struct {
	Key          string
	StorageClass string
}

Source Files ¶

View all Source files

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