go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/worker/grpcvtworkerserver Index | Files

package grpcvtworkerserver

import "gopkg.in/src-d/go-vitess.v1/vt/worker/grpcvtworkerserver"

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


Package Files


func StartServer Uses

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

StartServer registers the VtworkerServer for RPCs

type VtworkerServer Uses

type VtworkerServer struct {
    // contains filtered or unexported fields

VtworkerServer is our RPC server

func NewVtworkerServer Uses

func NewVtworkerServer(wi *worker.Instance) *VtworkerServer

NewVtworkerServer returns a new VtworkerServer for the given vtworker instance.

func (*VtworkerServer) ExecuteVtworkerCommand Uses

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

ExecuteVtworkerCommand is part of the vtworkerdatapb.VtworkerServer interface

Package grpcvtworkerserver imports 9 packages (graph). Updated 2019-06-13. Refresh now. Tools for package owners.