replication

Documentation

Index

• Constants
• Variables
• type ReplicationCreateCommand
  • func NewReplicationCreateCommand() *ReplicationCreateCommand
  • func (rcc *ReplicationCreateCommand) CommandName() string
  • func (rcc *ReplicationCreateCommand) Run() (err error)
  • func (rcc *ReplicationCreateCommand) ServerDetails() (*config.ServerDetails, error)
  • func (rcc *ReplicationCreateCommand) SetServerDetails(serverDetails *config.ServerDetails) *ReplicationCreateCommand
  • func (rcc *ReplicationCreateCommand) SetTemplatePath(path string) *ReplicationCreateCommand
  • func (rcc *ReplicationCreateCommand) SetVars(vars string) *ReplicationCreateCommand
• type ReplicationDeleteCommand
  • func NewReplicationDeleteCommand() *ReplicationDeleteCommand
  • func (rdc *ReplicationDeleteCommand) CommandName() string
  • func (rdc *ReplicationDeleteCommand) Run() (err error)
  • func (rdc *ReplicationDeleteCommand) ServerDetails() (*config.ServerDetails, error)
  • func (rdc *ReplicationDeleteCommand) SetQuiet(quiet bool) *ReplicationDeleteCommand
  • func (rdc *ReplicationDeleteCommand) SetRepoKey(repoKey string) *ReplicationDeleteCommand
  • func (rdc *ReplicationDeleteCommand) SetServerDetails(serverDetails *config.ServerDetails) *ReplicationDeleteCommand
• type ReplicationTemplateCommand
  • func NewReplicationTemplateCommand() *ReplicationTemplateCommand
  • func (rtc *ReplicationTemplateCommand) CommandName() string
  • func (rtc *ReplicationTemplateCommand) Run() (err error)
  • func (rtc *ReplicationTemplateCommand) ServerDetails() (*config.ServerDetails, error)
  • func (rtc *ReplicationTemplateCommand) SetTemplatePath(path string) *ReplicationTemplateCommand

Constants

const (
	// Strings for prompt questions
	SelectConfigKeyMsg = "Select the next configuration key" + utils.PressTabMsg

	// Template types
	TemplateType = "templateType"
	JobType      = "jobType"
	Create       = "create"
	Pull         = "pull"
	Push         = "push"

	// Common replication configuration JSON keys
	ServerId               = "serverId"
	CronExp                = "cronExp"
	RepoKey                = "repoKey"
	TargetRepoKey          = "targetRepoKey"
	EnableEventReplication = "enableEventReplication"
	Enabled                = "enabled"
	SyncDeletes            = "syncDeletes"
	SyncProperties         = "syncProperties"
	SyncStatistics         = "syncStatistics"
	PathPrefix             = "pathPrefix"
	SocketTimeoutMillis    = "socketTimeoutMillis"
)

Variables

var BoolToStringQuestionInfo = utils.QuestionInfo{
	Options:   utils.GetBoolSuggests(),
	AllowVars: true,
	Writer:    utils.WriteStringAnswer,
}

Specific writers for repo templates, since all the values in the templates should be written as string.

Types

type ReplicationCreateCommand

type ReplicationCreateCommand struct {
	// contains filtered or unexported fields
}

func NewReplicationCreateCommand

func NewReplicationCreateCommand() *ReplicationCreateCommand

func (*ReplicationCreateCommand) CommandName

func (rcc *ReplicationCreateCommand) CommandName() string

func (*ReplicationCreateCommand) Run

func (rcc *ReplicationCreateCommand) Run() (err error)

func (*ReplicationCreateCommand) ServerDetails

func (rcc *ReplicationCreateCommand) ServerDetails() (*config.ServerDetails, error)

func (*ReplicationCreateCommand) SetServerDetails

func (rcc *ReplicationCreateCommand) SetServerDetails(serverDetails *config.ServerDetails) *ReplicationCreateCommand

func (*ReplicationCreateCommand) SetTemplatePath

func (rcc *ReplicationCreateCommand) SetTemplatePath(path string) *ReplicationCreateCommand

func (*ReplicationCreateCommand) SetVars

func (rcc *ReplicationCreateCommand) SetVars(vars string) *ReplicationCreateCommand

type ReplicationDeleteCommand

type ReplicationDeleteCommand struct {
	// contains filtered or unexported fields
}

func NewReplicationDeleteCommand

func NewReplicationDeleteCommand() *ReplicationDeleteCommand

func (*ReplicationDeleteCommand) CommandName

func (rdc *ReplicationDeleteCommand) CommandName() string

func (*ReplicationDeleteCommand) Run

func (rdc *ReplicationDeleteCommand) Run() (err error)

func (*ReplicationDeleteCommand) ServerDetails

func (rdc *ReplicationDeleteCommand) ServerDetails() (*config.ServerDetails, error)

func (*ReplicationDeleteCommand) SetQuiet

func (rdc *ReplicationDeleteCommand) SetQuiet(quiet bool) *ReplicationDeleteCommand

func (*ReplicationDeleteCommand) SetRepoKey

func (rdc *ReplicationDeleteCommand) SetRepoKey(repoKey string) *ReplicationDeleteCommand

func (*ReplicationDeleteCommand) SetServerDetails

func (rdc *ReplicationDeleteCommand) SetServerDetails(serverDetails *config.ServerDetails) *ReplicationDeleteCommand

type ReplicationTemplateCommand

type ReplicationTemplateCommand struct {
	// contains filtered or unexported fields
}

func NewReplicationTemplateCommand

func NewReplicationTemplateCommand() *ReplicationTemplateCommand

func (*ReplicationTemplateCommand) CommandName

func (rtc *ReplicationTemplateCommand) CommandName() string

func (*ReplicationTemplateCommand) Run

func (rtc *ReplicationTemplateCommand) Run() (err error)

func (*ReplicationTemplateCommand) ServerDetails

func (rtc *ReplicationTemplateCommand) ServerDetails() (*config.ServerDetails, error)

func (*ReplicationTemplateCommand) SetTemplatePath

func (rtc *ReplicationTemplateCommand) SetTemplatePath(path string) *ReplicationTemplateCommand