integrationferry

Documentation

Index

• Constants
• func NewStandardConfig() (*ghostferry.Config, error)
• func Run(f *IntegrationFerry) error
• type IntegrationFerry
  • func Setup(c *RunCallbacks) *IntegrationFerry
  • func (f *IntegrationFerry) Main() error
  • func (f *IntegrationFerry) SendStatusAndWaitUntilContinue(status string, data ...string) error
  • func (f *IntegrationFerry) Start() error
• type RunCallbacks

Constants

const (

	// Could only be sent once by the main thread
	StatusReady                  string = "READY"
	StatusBinlogStreamingStarted string = "BINLOG_STREAMING_STARTED"
	StatusRowCopyCompleted       string = "ROW_COPY_COMPLETED"
	StatusVerifyDuringCutover    string = "VERIFY_DURING_CUTOVER"
	StatusVerified               string = "VERIFIED"
	StatusDone                   string = "DONE"

	// Could be sent by multiple goroutines in parallel
	StatusBeforeRowCopy     string = "BEFORE_ROW_COPY"
	StatusAfterRowCopy      string = "AFTER_ROW_COPY"
	StatusBeforeBinlogApply string = "BEFORE_BINLOG_APPLY"
	StatusAfterBinlogApply  string = "AFTER_BINLOG_APPLY"
)

Functions

func NewStandardConfig

func NewStandardConfig() (*ghostferry.Config, error)

func Run

func Run(f *IntegrationFerry) error

Types

type IntegrationFerry

type IntegrationFerry struct {
	*ghostferry.Ferry
	// contains filtered or unexported fields
}

func Setup

func Setup(c *RunCallbacks) *IntegrationFerry

func (*IntegrationFerry) Main

func (f *IntegrationFerry) Main() error

=========================================== Code to handle an almost standard Ferry run ===========================================

func (*IntegrationFerry) SendStatusAndWaitUntilContinue

func (f *IntegrationFerry) SendStatusAndWaitUntilContinue(status string, data ...string) error

func (*IntegrationFerry) Start

func (f *IntegrationFerry) Start() error

Method override for Start in order to send status to the integration server.

type RunCallbacks

type RunCallbacks struct {
	BeforeInitialize func(*IntegrationFerry) error
	AfterInitialize  func(*IntegrationFerry) error
}