grpcvtworkerserver

Documentation

Overview

Package grpcvtworkerserver contains the gRPC implementation of the server side of the remote execution of vtworker commands.

Index

• func StartServer(s *grpc.Server, wi *worker.Instance)
• type VtworkerServer
  • func NewVtworkerServer(wi *worker.Instance) *VtworkerServer
  • func (s *VtworkerServer) ExecuteVtworkerCommand(args *vtworkerdatapb.ExecuteVtworkerCommandRequest, ...) (err error)

Functions

func StartServer

func StartServer(s *grpc.Server, wi *worker.Instance)

StartServer registers the VtworkerServer for RPCs

Types

type VtworkerServer

type VtworkerServer struct {
	vtworkerservicepb.UnimplementedVtworkerServer
	// contains filtered or unexported fields
}

VtworkerServer is our RPC server

func NewVtworkerServer

func NewVtworkerServer(wi *worker.Instance) *VtworkerServer

NewVtworkerServer returns a new VtworkerServer for the given vtworker instance.

func (*VtworkerServer) ExecuteVtworkerCommand

func (s *VtworkerServer) ExecuteVtworkerCommand(args *vtworkerdatapb.ExecuteVtworkerCommandRequest, stream vtworkerservicepb.Vtworker_ExecuteVtworkerCommandServer) (err error)

ExecuteVtworkerCommand is part of the vtworkerdatapb.VtworkerServer interface