Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PluginOptions ¶
type PluginOptions struct { KubeConfigPath string SrcContext string DstContext string SrcPluginAddress string DstPluginAddress string SrcClusterIp string DstClusterIp string SrcESNodePort int64 DstESNodePort int64 IndexName string IndexFrom string EsName string EsNamespace string SrcKubeClient kubernetes.Interface DstKubeClient kubernetes.Interface SrcDmClient dynamic.Interface DstDmClient dynamic.Interface Debug bool }
func (*PluginOptions) InsertIndex ¶
func (opt *PluginOptions) InsertIndex() error
InsertIndex insert a index in the source Elasticsearch
func (*PluginOptions) Setup ¶
func (opt *PluginOptions) Setup() error
func (*PluginOptions) ShowIndexes ¶
func (opt *PluginOptions) ShowIndexes() (string, error)
ShowIndexes shows all the indexes from the source/destination Elasticsearch based on "index-from" flag If the value of "index-from" flag is "active" then it shows indexes of the source ES. Otherwise, it shows indexes from the destination ES.
func (*PluginOptions) TriggerInit ¶
func (opt *PluginOptions) TriggerInit() error
TriggerInit prepare source and destination Elasticsearch to backup and restore from a Minio repository
func (*PluginOptions) TriggerSync ¶
func (opt *PluginOptions) TriggerSync() error
TriggerSync calls SYNC API of the plugin in source cluster to initiate backup. Then, it waits for the backup to be completed. It continuously calls STATUS API to to check backup state. Once the backup is completed, it calls SYNC API of the plugin in destination cluster which initiate a restore. Then, it's wait for restore to be completed. Again, it uses STATUS API to check the restore sate.