vulcanizer

package module

Go to main page

Versions in this module

v0

v0.5.3

Sep 30, 2020

v0.5.2

Dec 30, 2019

Changes in this version

type Client

+ func (c *Client) GetNodeAllocations() ([]Node, error)

+ type DiskAllocation struct

+ DiskAvail string

+ DiskIndices string

+ DiskPercent string

+ DiskTotal string

+ DiskUsed string

+ Ip string

+ Name string

+ Node string

+ Shards string

type Node

+ DiskAvail string

+ DiskIndices string

+ DiskPercent string

+ DiskTotal string

+ DiskUsed string

+ Shards string

v0.5.1

Oct 7, 2019

v0.5.0

May 23, 2019

Changes in this version

+ type Alias struct

+ Filter string

+ IndexName string

+ Name string

+ RoutingIndex string

+ RoutingSearch string

+ type AliasAction struct

+ ActionType AliasActionType

+ AliasName string

+ IndexName string

+ func (ac *AliasAction) MarshalJSON() ([]byte, error)

+ type AliasActionType string

+ const AddAlias

+ const RemoveAlias

type Client

+ Path string

+ func (c *Client) CloseIndex(indexName string) error

+ func (c *Client) GetAliases(alias string) ([]Alias, error)

+ func (c *Client) GetAllAliases() ([]Alias, error)

+ func (c *Client) GetAllIndices() ([]Index, error)

+ func (c *Client) GetShardOverlap(nodes []string) (map[string]ShardOverlap, error)

+ func (c *Client) GetShardRecovery(nodes []string, onlyActive bool) ([]ShardRecovery, error)

+ func (c *Client) GetShards(nodes []string) ([]Shard, error)

+ func (c *Client) ModifyAliases(actions []AliasAction) error

+ func (c *Client) OpenIndex(indexName string) error

type Node

+ Version string

+ type Shard struct

+ Docs string

+ IP string

+ Index string

+ Node string

+ Shard string

+ State string

+ Store string

+ Type string

+ type ShardOverlap struct

+ Index string

+ PrimaryFound bool

+ ReplicasFound int

+ ReplicasTotal int

+ Shard string

+ func (s ShardOverlap) SafeToRemove() bool

+ type ShardRecovery struct

+ Bytes int

+ BytesPercent string

+ BytesRecovered int

+ BytesTotal int

+ Files int

+ FilesPercent string

+ FilesRecovered int

+ FilesTotal int

+ Index string

+ Repository string

+ Shard string

+ Snapshot string

+ SourceHost string

+ SourceNode string

+ Stage string

+ TargetHost string

+ TargetNode string

+ Time string

+ TranslogOps int

+ TranslogOpsPercent string

+ TranslogOpsRecovered int

+ Type string

+ func (s ShardRecovery) TimeRemaining() (time.Duration, error)

type Snapshot

+ func (s *Snapshot) GetDuration() int

+ func (s *Snapshot) GetEndTime() string

v0.4.0

Feb 28, 2019

Changes in this version

+ type Auth struct

+ Password string

+ User string

type Client

+ Secure bool

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ func (c *Client) AnalyzeText(analyzer, text string) ([]Token, error)

+ func (c *Client) AnalyzeTextWithField(index, field, text string) ([]Token, error)

+ func (c *Client) DeleteIndex(indexName string) error

+ func (c *Client) GetClusterSettings() (ClusterSettings, error)

+ func (c *Client) GetIndexSettings(index string) ([]Setting, error)

+ func (c *Client) GetPrettyIndexMappings(index string) (string, error)

+ func (c *Client) GetPrettyIndexSettings(index string) (string, error)

+ func (c *Client) SetClusterSetting(setting string, value string) (string, string, error)

+ func (c *Client) SetIndexSetting(index, setting, value string) (string, string, error)

+ type Setting struct

+ Setting string

+ Value string

+ type Token struct

+ EndOffset int

+ Position int

+ StartOffset int

+ Text string

+ Type string

v0.3.0

Dec 19, 2018

Changes in this version

type Client

+ func (c *Client) GetRepositories() ([]Repository, error)

+ func (c *Client) RestoreSnapshotIndices(repository string, snapshot string, indices []string, ...) error

+ func (c *Client) SnapshotAllIndices(repository string, snapshot string) error

+ func (c *Client) SnapshotIndices(repository string, snapshot string, indices []string) error

type ClusterHealth

+ ActiveShards int

+ HealthyIndices []IndexHealth

+ RawIndices map[string]IndexHealth

+ UnhealthyIndices []IndexHealth

+ type IndexHealth struct

+ ActiveShards int

+ InitializingShards int

+ Name string

+ RelocatingShards int

+ Status string

+ UnassignedShards int

type Node

+ Jdk string

+ type Repository struct

+ Name string

+ Settings map[string]interface{}

+ Type string

v0.2.0

Oct 29, 2018

Changes in this version

type Client

+ func (c *Client) DeleteSnapshot(repository string, snapshot string) error

+ func (c *Client) VerifyRepository(repository string) (bool, error)

v0.1.0

Sep 17, 2018

Changes in this version

+ type ClusterHealth struct

+ ActiveShardsPercentage string

+ Cluster string

+ InitializingShards int

+ Message string

+ RelocatingShards int

+ Status string

+ UnassignedShards int

+ type ClusterSetting struct

+ Setting string

+ Value string

+ type ClusterSettings struct

+ PersistentSettings []ClusterSetting

+ TransientSettings []ClusterSetting

+ type Index struct

+ DocumentCount int

+ Health string

+ IndexSize string

+ Name string

+ PrimaryShards int

+ ReplicaCount int

+ Status string

+ type Node struct

+ Id string

+ Ip string

+ Master string

+ Name string

+ Role string

+ type Snapshot struct

+ DurationMillis int

+ EndTime time.Time

+ Failures []struct{ ... }

+ Indices []string

+ Name string

+ Shards struct{ ... }

+ StartTime time.Time

+ State string

v0.0.1

Sep 12, 2018

Changes in this version

+ type Client struct

+ Host string

+ Port int

+ func NewClient(host string, port int) *Client

+ func (c *Client) DrainServer(serverToDrain string, namesExcluded string) (excludedServers string)

+ func (c *Client) FillAll() *ExcludeSettings

+ func (c *Client) FillOneServer(serverToFill string) (serverFilling, excludedServers string)

+ func (c *Client) GetClusterExcludeSettings() *ExcludeSettings

+ func (c *Client) GetHealth() (string, [][]string, []string)

+ func (c *Client) GetIndices() ([][]string, []string)

+ func (c *Client) GetNodes() ([][]string, []string)

+ func (c *Client) GetSettings() ([][]string, []string)

+ func (c *Client) GetSnapshotStatus(repository string, snapshot string) ([][]string, []string)

+ func (c *Client) GetSnapshots(repository string) ([][]string, []string)

+ func (c *Client) PerformSnapshotsCheck(cluster string) ([]string, []string)

+ func (c *Client) SetAllocation(allocation string) string

+ func (c *Client) SetSetting(setting string, value string) (string, string, error)

+ type ExcludeSettings struct

+ Hosts []string

+ Ips []string

+ Names []string

+ func ExcludeSettingsFromJson(settings []gjson.Result) *ExcludeSettings

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