gorpcproto

Documentation

Index

• type ExecuteFetchArgs
• type GetSchemaArgs
• type GetSlavesReply
• type RunBlpUntilArgs
• type SnapshotStreamingReply
• type StopSlaveMinimumArgs
• type TabletExternallyReparentedArgs
• type WaitBlpPositionArgs
• type WaitSlavePositionArgs

Types

type ExecuteFetchArgs

type ExecuteFetchArgs struct {
	Query          string
	MaxRows        int
	WantFields     bool
	DisableBinlogs bool
	DBConfigName   dbconfigs.DbConfigName
}

type GetSchemaArgs

type GetSchemaArgs struct {
	Tables        []string
	ExcludeTables []string
	IncludeViews  bool
}

type GetSlavesReply

type GetSlavesReply struct {
	Addrs []string
}

type RunBlpUntilArgs

type RunBlpUntilArgs struct {
	BlpPositionList *blproto.BlpPositionList
	WaitTimeout     time.Duration
}

type SnapshotStreamingReply

type SnapshotStreamingReply struct {
	Log    *logutil.LoggerEvent
	Result *actionnode.SnapshotReply
}

type StopSlaveMinimumArgs

type StopSlaveMinimumArgs struct {
	Position myproto.ReplicationPosition
	WaitTime time.Duration
}

type TabletExternallyReparentedArgs

type TabletExternallyReparentedArgs struct {
	ExternalID string
}

type WaitBlpPositionArgs

type WaitBlpPositionArgs struct {
	BlpPosition blproto.BlpPosition
	WaitTimeout time.Duration
}

type WaitSlavePositionArgs

type WaitSlavePositionArgs struct {
	Position    myproto.ReplicationPosition
	WaitTimeout time.Duration // pass in zero to wait indefinitely
}