libs

Documentation

Index

• Constants
• Variables
• func DryRunTable()
• func InitConfig()
• func InitLogging(level string, logFormat string)
• func MoveCommandsToTable(input []MoveCommand)
• func RebalanceInfoToTable(input rebalanceInfo)
• func RerouteResponseToTable(input rerouteResponse)
• func Run()
• func SettingsToTable(input map[string]interface{})
• func ShardsAvailableForMoveToTable(input []shard)
• type Elastic
  • func (e Elastic) ExecuteMoveCommands(url string, moveCommands ShardsReroute, dryRun bool) rerouteResponse
  • func (e Elastic) GetDiskSpaceInfo(url string, allowedPercentOfDifference int, fromNode string, toNode string) rebalanceInfo
  • func (e Elastic) GetShardsInfo(url string, diskSpaceInfo rebalanceInfo, shardsToMove int) []shard
  • func (e Elastic) PrepareMoveCommand(shards []shard, fromNode, toNode string) ShardsReroute
• type MoveCommand
• type ShardsReroute

Constants

const AppName = "elasticsearch-reroute-shards"

const AppVersion = "v1.0.0"

Variables

var (
	CfgFile      string
	Listen       string
	CacheEnabled bool
)

Functions

func DryRunTable

func DryRunTable()

func InitConfig

func InitConfig()

func InitLogging

func InitLogging(level string, logFormat string)

func MoveCommandsToTable

func MoveCommandsToTable(input []MoveCommand)

func RebalanceInfoToTable

func RebalanceInfoToTable(input rebalanceInfo)

func RerouteResponseToTable

func RerouteResponseToTable(input rerouteResponse)

func Run

func Run()

func SettingsToTable

func SettingsToTable(input map[string]interface{})

func ShardsAvailableForMoveToTable

func ShardsAvailableForMoveToTable(input []shard)

Types

type Elastic

type Elastic struct {
	HttpClient   *http.Client
	HttpUsername string
	HttpPassword string
}

func (Elastic) ExecuteMoveCommands

func (e Elastic) ExecuteMoveCommands(url string, moveCommands ShardsReroute, dryRun bool) rerouteResponse

func (Elastic) GetDiskSpaceInfo

func (e Elastic) GetDiskSpaceInfo(url string, allowedPercentOfDifference int, fromNode string, toNode string) rebalanceInfo

GetDiskSpaceInfo func

func (Elastic) GetShardsInfo

func (e Elastic) GetShardsInfo(url string, diskSpaceInfo rebalanceInfo, shardsToMove int) []shard

func (Elastic) PrepareMoveCommand

func (e Elastic) PrepareMoveCommand(shards []shard, fromNode, toNode string) ShardsReroute

type MoveCommand

type MoveCommand struct {
	Move struct {
		Index    string `json:"index"`
		Shard    string `json:"shard"`
		FromNode string `json:"from_node"`
		ToNode   string `json:"to_node"`
	} `json:"move"`
}

type ShardsReroute

type ShardsReroute struct {
	Commands []MoveCommand `json:"commands"`
}