grpcvtctlserver

Documentation

Overview

Package grpcvtctlserver contains the gRPC implementation of the server side of the remote execution of vtctl commands.

Index

• func StartServer(s *grpc.Server, ts *topo.Server)
• type VtctlServer
  • func NewVtctlServer(ts *topo.Server) *VtctlServer
  • func (s *VtctlServer) ExecuteVtctlCommand(args *vtctldatapb.ExecuteVtctlCommandRequest, ...) (err error)

Functions

func StartServer

func StartServer(s *grpc.Server, ts *topo.Server)

StartServer registers the VtctlServer for RPCs

Types

type VtctlServer

type VtctlServer struct {
	vtctlservicepb.UnimplementedVtctlServer
	// 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(args *vtctldatapb.ExecuteVtctlCommandRequest, stream vtctlservicepb.Vtctl_ExecuteVtctlCommandServer) (err error)

ExecuteVtctlCommand is part of the vtctldatapb.VtctlServer interface