Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterVtworkerServer ¶
func RegisterVtworkerServer(s *grpc.Server, srv VtworkerServer)
Types ¶
type UnimplementedVtworkerServer ¶
type UnimplementedVtworkerServer struct {
}
UnimplementedVtworkerServer can be embedded to have forward compatible implementations.
func (*UnimplementedVtworkerServer) ExecuteVtworkerCommand ¶
func (*UnimplementedVtworkerServer) ExecuteVtworkerCommand(req *vtworkerdata.ExecuteVtworkerCommandRequest, srv Vtworker_ExecuteVtworkerCommandServer) error
type VtworkerClient ¶
type VtworkerClient interface {
// ExecuteVtworkerCommand allows to run a vtworker command by specifying the
// same arguments as on the command line.
ExecuteVtworkerCommand(ctx context.Context, in *vtworkerdata.ExecuteVtworkerCommandRequest, opts ...grpc.CallOption) (Vtworker_ExecuteVtworkerCommandClient, error)
}
VtworkerClient is the client API for Vtworker service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewVtworkerClient ¶
func NewVtworkerClient(cc *grpc.ClientConn) VtworkerClient
type VtworkerServer ¶
type VtworkerServer interface {
// ExecuteVtworkerCommand allows to run a vtworker command by specifying the
// same arguments as on the command line.
ExecuteVtworkerCommand(*vtworkerdata.ExecuteVtworkerCommandRequest, Vtworker_ExecuteVtworkerCommandServer) error
}
VtworkerServer is the server API for Vtworker service.
type Vtworker_ExecuteVtworkerCommandClient ¶
type Vtworker_ExecuteVtworkerCommandClient interface {
Recv() (*vtworkerdata.ExecuteVtworkerCommandResponse, error)
grpc.ClientStream
}
type Vtworker_ExecuteVtworkerCommandServer ¶
type Vtworker_ExecuteVtworkerCommandServer interface {
Send(*vtworkerdata.ExecuteVtworkerCommandResponse) error
grpc.ServerStream
}
Click to show internal directories.
Click to hide internal directories.