gorpcvtctlserver

Documentation

Overview

Package 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 NewVtctlServer(ts topo.Server) *VtctlServer
  • func (s *VtctlServer) ExecuteVtctlCommand(ctx context.Context, query *gorpcproto.ExecuteVtctlCommandArgs, ...) (err 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 NewVtctlServer

func NewVtctlServer(ts topo.Server) *VtctlServer

NewVtctlServer returns a new Vtctl Server for the topo server.

func (*VtctlServer) ExecuteVtctlCommand

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

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