gorpcvtctlserver

Documentation

Overview

gorpcvtctlserver contains the Go RPC implementation of the server side of the remote execution of vtctl commands.

Index

• func StartServer(ts topo.Server)
• type VtctlServer
  • func (s *VtctlServer) ExecuteVtctlCommand(context context.Context, query *gorpcproto.ExecuteVtctlCommandArgs, ...) error

Functions

func StartServer

func StartServer(ts topo.Server)

StartServer registers the Server for RPCs

Types

type VtctlServer

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

VtctlServer is our RPC server

func (*VtctlServer) ExecuteVtctlCommand

func (s *VtctlServer) ExecuteVtctlCommand(context context.Context, query *gorpcproto.ExecuteVtctlCommandArgs, sendReply func(interface{}) error) error

ExecuteVtctlCommand is the server side method that will execute the query, and stream the results.