replay

Documentation

Index

• func ReplayOplog(r io.Reader, controller ratecontroller.Controller, alwaysUpsert bool, ...) error
• type FailedOperationError
  • func NewFailedOperationError(op map[string]interface{}) *FailedOperationError
  • func (e *FailedOperationError) Error() string

Functions

func ReplayOplog

func ReplayOplog(r io.Reader, controller ratecontroller.Controller, alwaysUpsert bool, host string) error

ReplayOplog replays an oplog onto the specified host. If there are any errors this function terminates and returns the error immediately.

Types

type FailedOperationError

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

FailedOperationError means that an operation failed to apply.

func NewFailedOperationError

func NewFailedOperationError(op map[string]interface{}) *FailedOperationError

NewFailedOperationError creates and returns a FailedOperationsError for the given op.

func (*FailedOperationError) Error

func (e *FailedOperationError) Error() string