Update protos
This commit is contained in:
sophia
Paul Hinze
parent
3c52682226
commit
6805d81301
@ -1,17 +1,17 @@
|
||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.25.0
|
||||
// protoc v3.15.6
|
||||
// protoc-gen-go v1.23.0
|
||||
// protoc v3.13.0
|
||||
// source: proto/ruby_vagrant/ruby-server.proto
|
||||
|
||||
package ruby_vagrant
|
||||
|
||||
import (
|
||||
proto "github.com/golang/protobuf/proto"
|
||||
any "github.com/golang/protobuf/ptypes/any"
|
||||
empty "github.com/golang/protobuf/ptypes/empty"
|
||||
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
||||
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
||||
anypb "google.golang.org/protobuf/types/known/anypb"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
reflect "reflect"
|
||||
sync "sync"
|
||||
)
|
||||
@ -298,7 +298,7 @@ type Provisioner struct {
|
||||
unknownFields protoimpl.UnknownFields
|
||||
|
||||
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
|
||||
Config *anypb.Any `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
|
||||
Config *any.Any `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
|
||||
}
|
||||
|
||||
func (x *Provisioner) Reset() {
|
||||
@ -340,7 +340,7 @@ func (x *Provisioner) GetName() string {
|
||||
return ""
|
||||
}
|
||||
|
||||
func (x *Provisioner) GetConfig() *anypb.Any {
|
||||
func (x *Provisioner) GetConfig() *any.Any {
|
||||
if x != nil {
|
||||
return x.Config
|
||||
}
|
||||
@ -421,7 +421,7 @@ type Communicator struct {
|
||||
// This is the config that belongs to the communicator.
|
||||
// Should be a message type from the core plugin or defined
|
||||
// by a plugin author
|
||||
Config *anypb.Any `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
|
||||
Config *any.Any `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
|
||||
}
|
||||
|
||||
func (x *Communicator) Reset() {
|
||||
@ -463,7 +463,7 @@ func (x *Communicator) GetName() string {
|
||||
return ""
|
||||
}
|
||||
|
||||
func (x *Communicator) GetConfig() *anypb.Any {
|
||||
func (x *Communicator) GetConfig() *any.Any {
|
||||
if x != nil {
|
||||
return x.Config
|
||||
}
|
||||
@ -662,8 +662,8 @@ var file_proto_ruby_vagrant_ruby_server_proto_goTypes = []interface{}{
|
||||
(*MachineConfig)(nil), // 6: hashicorp.vagrant.MachineConfig
|
||||
(*Communicator)(nil), // 7: hashicorp.vagrant.Communicator
|
||||
(*Vagrantfile)(nil), // 8: hashicorp.vagrant.Vagrantfile
|
||||
(*anypb.Any)(nil), // 9: google.protobuf.Any
|
||||
(*emptypb.Empty)(nil), // 10: google.protobuf.Empty
|
||||
(*any.Any)(nil), // 9: google.protobuf.Any
|
||||
(*empty.Empty)(nil), // 10: google.protobuf.Empty
|
||||
}
|
||||
var file_proto_ruby_vagrant_ruby_server_proto_depIdxs = []int32{
|
||||
2, // 0: hashicorp.vagrant.GetPluginsResponse.plugins:type_name -> hashicorp.vagrant.Plugin
|
||||
|
||||
@ -4,15 +4,14 @@ package ruby_vagrant
|
||||
|
||||
import (
|
||||
context "context"
|
||||
empty "github.com/golang/protobuf/ptypes/empty"
|
||||
grpc "google.golang.org/grpc"
|
||||
codes "google.golang.org/grpc/codes"
|
||||
status "google.golang.org/grpc/status"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
)
|
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7
|
||||
|
||||
// RubyVagrantClient is the client API for RubyVagrant service.
|
||||
@ -20,7 +19,7 @@ const _ = grpc.SupportPackageIsVersion7
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
||||
type RubyVagrantClient interface {
|
||||
// Gets available ruby plugins
|
||||
GetPlugins(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error)
|
||||
GetPlugins(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error)
|
||||
ParseVagrantfile(ctx context.Context, in *ParseVagrantfileRequest, opts ...grpc.CallOption) (*ParseVagrantfileResponse, error)
|
||||
}
|
||||
|
||||
@ -32,7 +31,7 @@ func NewRubyVagrantClient(cc grpc.ClientConnInterface) RubyVagrantClient {
|
||||
return &rubyVagrantClient{cc}
|
||||
}
|
||||
|
||||
func (c *rubyVagrantClient) GetPlugins(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error) {
|
||||
func (c *rubyVagrantClient) GetPlugins(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error) {
|
||||
out := new(GetPluginsResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.RubyVagrant/GetPlugins", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -55,7 +54,7 @@ func (c *rubyVagrantClient) ParseVagrantfile(ctx context.Context, in *ParseVagra
|
||||
// for forward compatibility
|
||||
type RubyVagrantServer interface {
|
||||
// Gets available ruby plugins
|
||||
GetPlugins(context.Context, *emptypb.Empty) (*GetPluginsResponse, error)
|
||||
GetPlugins(context.Context, *empty.Empty) (*GetPluginsResponse, error)
|
||||
ParseVagrantfile(context.Context, *ParseVagrantfileRequest) (*ParseVagrantfileResponse, error)
|
||||
mustEmbedUnimplementedRubyVagrantServer()
|
||||
}
|
||||
@ -64,7 +63,7 @@ type RubyVagrantServer interface {
|
||||
type UnimplementedRubyVagrantServer struct {
|
||||
}
|
||||
|
||||
func (UnimplementedRubyVagrantServer) GetPlugins(context.Context, *emptypb.Empty) (*GetPluginsResponse, error) {
|
||||
func (UnimplementedRubyVagrantServer) GetPlugins(context.Context, *empty.Empty) (*GetPluginsResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetPlugins not implemented")
|
||||
}
|
||||
func (UnimplementedRubyVagrantServer) ParseVagrantfile(context.Context, *ParseVagrantfileRequest) (*ParseVagrantfileResponse, error) {
|
||||
@ -80,11 +79,11 @@ type UnsafeRubyVagrantServer interface {
|
||||
}
|
||||
|
||||
func RegisterRubyVagrantServer(s grpc.ServiceRegistrar, srv RubyVagrantServer) {
|
||||
s.RegisterService(&RubyVagrant_ServiceDesc, srv)
|
||||
s.RegisterService(&_RubyVagrant_serviceDesc, srv)
|
||||
}
|
||||
|
||||
func _RubyVagrant_GetPlugins_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -96,7 +95,7 @@ func _RubyVagrant_GetPlugins_Handler(srv interface{}, ctx context.Context, dec f
|
||||
FullMethod: "/hashicorp.vagrant.RubyVagrant/GetPlugins",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(RubyVagrantServer).GetPlugins(ctx, req.(*emptypb.Empty))
|
||||
return srv.(RubyVagrantServer).GetPlugins(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -119,10 +118,7 @@ func _RubyVagrant_ParseVagrantfile_Handler(srv interface{}, ctx context.Context,
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
// RubyVagrant_ServiceDesc is the grpc.ServiceDesc for RubyVagrant service.
|
||||
// It's only intended for direct use with grpc.RegisterService,
|
||||
// and not to be introspected or modified (even as a copy)
|
||||
var RubyVagrant_ServiceDesc = grpc.ServiceDesc{
|
||||
var _RubyVagrant_serviceDesc = grpc.ServiceDesc{
|
||||
ServiceName: "hashicorp.vagrant.RubyVagrant",
|
||||
HandlerType: (*RubyVagrantServer)(nil),
|
||||
Methods: []grpc.MethodDesc{
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@ -4,15 +4,14 @@ package vagrant_server
|
||||
|
||||
import (
|
||||
context "context"
|
||||
empty "github.com/golang/protobuf/ptypes/empty"
|
||||
grpc "google.golang.org/grpc"
|
||||
codes "google.golang.org/grpc/codes"
|
||||
status "google.golang.org/grpc/status"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
)
|
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7
|
||||
|
||||
// VagrantClient is the client API for Vagrant service.
|
||||
@ -22,11 +21,11 @@ type VagrantClient interface {
|
||||
// GetVersionInfo returns information about the server. This RPC call does
|
||||
// NOT require authentication. It can be used by clients to determine if they
|
||||
// are capable of talking to this server.
|
||||
GetVersionInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error)
|
||||
GetVersionInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error)
|
||||
UpsertBasis(ctx context.Context, in *UpsertBasisRequest, opts ...grpc.CallOption) (*UpsertBasisResponse, error)
|
||||
GetBasis(ctx context.Context, in *GetBasisRequest, opts ...grpc.CallOption) (*GetBasisResponse, error)
|
||||
FindBasis(ctx context.Context, in *FindBasisRequest, opts ...grpc.CallOption) (*FindBasisResponse, error)
|
||||
ListBasis(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error)
|
||||
ListBasis(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error)
|
||||
// ListTasks returns the tasks.
|
||||
ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
|
||||
// GetTask returns a task
|
||||
@ -44,13 +43,13 @@ type VagrantClient interface {
|
||||
// ListProjects returns a list of all the projects. There is no equivalent
|
||||
// ListApplications because applications are a part of projects and you
|
||||
// can use GetProject to get more information about the project.
|
||||
ListProjects(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error)
|
||||
ListProjects(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error)
|
||||
// UpsertTarget upserts a target with a project. If the target
|
||||
// is already registered this does nothing.
|
||||
UpsertTarget(ctx context.Context, in *UpsertTargetRequest, opts ...grpc.CallOption) (*UpsertTargetResponse, error)
|
||||
GetTarget(ctx context.Context, in *GetTargetRequest, opts ...grpc.CallOption) (*GetTargetResponse, error)
|
||||
FindTarget(ctx context.Context, in *FindTargetRequest, opts ...grpc.CallOption) (*FindTargetResponse, error)
|
||||
ListTargets(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error)
|
||||
ListTargets(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error)
|
||||
// GetLogStream reads the log stream for a deployment. This will immediately
|
||||
// send a single LogEntry with the lines we have so far. If there are no
|
||||
// available lines this will NOT block and instead will return an error.
|
||||
@ -72,7 +71,7 @@ type VagrantClient interface {
|
||||
//
|
||||
// This RPC always returns immediately. You must use GetJob or GetJobStream
|
||||
// to wait on the status of the cancellation.
|
||||
CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
// GetJob queries a job by ID.
|
||||
GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
|
||||
// INTERNAL: ListJobs lists all the jobs the server has processed. This
|
||||
@ -89,11 +88,11 @@ type VagrantClient interface {
|
||||
// GetRunner gets information about a single runner.
|
||||
GetRunner(ctx context.Context, in *GetRunnerRequest, opts ...grpc.CallOption) (*Runner, error)
|
||||
// GetServerConfig sets configuration for the Vagrant server.
|
||||
GetServerConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error)
|
||||
GetServerConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error)
|
||||
// SetServerConfig sets configuration for the Vagrant server.
|
||||
SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
// CreateSnapshot creates a new database snapshot.
|
||||
CreateSnapshot(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error)
|
||||
CreateSnapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error)
|
||||
// RestoreSnapshot performs a database restore with the given snapshot.
|
||||
// This API doesn't do a full online restore, it only stages the restore
|
||||
// for the next server start to finalize the restore. See the arguments for
|
||||
@ -102,11 +101,11 @@ type VagrantClient interface {
|
||||
// BootstrapToken returns the initial token for the server. This can only
|
||||
// be requested once on first startup. After initial request this will
|
||||
// always return a PermissionDenied error.
|
||||
BootstrapToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error)
|
||||
BootstrapToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error)
|
||||
// Generate a new invite token that users can exchange for a login token.
|
||||
GenerateInviteToken(ctx context.Context, in *InviteTokenRequest, opts ...grpc.CallOption) (*NewTokenResponse, error)
|
||||
// Generate a new login token that users can use to login directly.
|
||||
GenerateLoginToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error)
|
||||
GenerateLoginToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error)
|
||||
// Exchange a invite token for a login token.
|
||||
ConvertInviteToken(ctx context.Context, in *ConvertInviteTokenRequest, opts ...grpc.CallOption) (*NewTokenResponse, error)
|
||||
// RunnerConfig is called to register a runner and receive the configuration
|
||||
@ -126,7 +125,7 @@ func NewVagrantClient(cc grpc.ClientConnInterface) VagrantClient {
|
||||
return &vagrantClient{cc}
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetVersionInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error) {
|
||||
func (c *vagrantClient) GetVersionInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error) {
|
||||
out := new(GetVersionInfoResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetVersionInfo", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -162,7 +161,7 @@ func (c *vagrantClient) FindBasis(ctx context.Context, in *FindBasisRequest, opt
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) ListBasis(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error) {
|
||||
func (c *vagrantClient) ListBasis(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error) {
|
||||
out := new(ListBasisResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListBasis", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -234,7 +233,7 @@ func (c *vagrantClient) FindProject(ctx context.Context, in *FindProjectRequest,
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) ListProjects(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error) {
|
||||
func (c *vagrantClient) ListProjects(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error) {
|
||||
out := new(ListProjectsResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListProjects", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -270,7 +269,7 @@ func (c *vagrantClient) FindTarget(ctx context.Context, in *FindTargetRequest, o
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) ListTargets(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error) {
|
||||
func (c *vagrantClient) ListTargets(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error) {
|
||||
out := new(ListTargetsResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListTargets", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -280,7 +279,7 @@ func (c *vagrantClient) ListTargets(ctx context.Context, in *emptypb.Empty, opts
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetLogStream(ctx context.Context, in *GetLogStreamRequest, opts ...grpc.CallOption) (Vagrant_GetLogStreamClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[0], "/hashicorp.vagrant.Vagrant/GetLogStream", opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &_Vagrant_serviceDesc.Streams[0], "/hashicorp.vagrant.Vagrant/GetLogStream", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -338,8 +337,8 @@ func (c *vagrantClient) QueueJob(ctx context.Context, in *QueueJobRequest, opts
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
func (c *vagrantClient) CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/CancelJob", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -375,7 +374,7 @@ func (c *vagrantClient) ValidateJob(ctx context.Context, in *ValidateJobRequest,
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetJobStream(ctx context.Context, in *GetJobStreamRequest, opts ...grpc.CallOption) (Vagrant_GetJobStreamClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[1], "/hashicorp.vagrant.Vagrant/GetJobStream", opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &_Vagrant_serviceDesc.Streams[1], "/hashicorp.vagrant.Vagrant/GetJobStream", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -415,7 +414,7 @@ func (c *vagrantClient) GetRunner(ctx context.Context, in *GetRunnerRequest, opt
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetServerConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error) {
|
||||
func (c *vagrantClient) GetServerConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error) {
|
||||
out := new(GetServerConfigResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetServerConfig", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -424,8 +423,8 @@ func (c *vagrantClient) GetServerConfig(ctx context.Context, in *emptypb.Empty,
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/SetServerConfig", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -433,8 +432,8 @@ func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfig
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) CreateSnapshot(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[2], "/hashicorp.vagrant.Vagrant/CreateSnapshot", opts...)
|
||||
func (c *vagrantClient) CreateSnapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &_Vagrant_serviceDesc.Streams[2], "/hashicorp.vagrant.Vagrant/CreateSnapshot", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -466,7 +465,7 @@ func (x *vagrantCreateSnapshotClient) Recv() (*CreateSnapshotResponse, error) {
|
||||
}
|
||||
|
||||
func (c *vagrantClient) RestoreSnapshot(ctx context.Context, opts ...grpc.CallOption) (Vagrant_RestoreSnapshotClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[3], "/hashicorp.vagrant.Vagrant/RestoreSnapshot", opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &_Vagrant_serviceDesc.Streams[3], "/hashicorp.vagrant.Vagrant/RestoreSnapshot", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -476,7 +475,7 @@ func (c *vagrantClient) RestoreSnapshot(ctx context.Context, opts ...grpc.CallOp
|
||||
|
||||
type Vagrant_RestoreSnapshotClient interface {
|
||||
Send(*RestoreSnapshotRequest) error
|
||||
CloseAndRecv() (*emptypb.Empty, error)
|
||||
CloseAndRecv() (*empty.Empty, error)
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
@ -488,18 +487,18 @@ func (x *vagrantRestoreSnapshotClient) Send(m *RestoreSnapshotRequest) error {
|
||||
return x.ClientStream.SendMsg(m)
|
||||
}
|
||||
|
||||
func (x *vagrantRestoreSnapshotClient) CloseAndRecv() (*emptypb.Empty, error) {
|
||||
func (x *vagrantRestoreSnapshotClient) CloseAndRecv() (*empty.Empty, error) {
|
||||
if err := x.ClientStream.CloseSend(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
m := new(emptypb.Empty)
|
||||
m := new(empty.Empty)
|
||||
if err := x.ClientStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return m, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) BootstrapToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) {
|
||||
func (c *vagrantClient) BootstrapToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) {
|
||||
out := new(NewTokenResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/BootstrapToken", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -517,7 +516,7 @@ func (c *vagrantClient) GenerateInviteToken(ctx context.Context, in *InviteToken
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GenerateLoginToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) {
|
||||
func (c *vagrantClient) GenerateLoginToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) {
|
||||
out := new(NewTokenResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GenerateLoginToken", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -536,7 +535,7 @@ func (c *vagrantClient) ConvertInviteToken(ctx context.Context, in *ConvertInvit
|
||||
}
|
||||
|
||||
func (c *vagrantClient) RunnerConfig(ctx context.Context, opts ...grpc.CallOption) (Vagrant_RunnerConfigClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[4], "/hashicorp.vagrant.Vagrant/RunnerConfig", opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &_Vagrant_serviceDesc.Streams[4], "/hashicorp.vagrant.Vagrant/RunnerConfig", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -567,7 +566,7 @@ func (x *vagrantRunnerConfigClient) Recv() (*RunnerConfigResponse, error) {
|
||||
}
|
||||
|
||||
func (c *vagrantClient) RunnerJobStream(ctx context.Context, opts ...grpc.CallOption) (Vagrant_RunnerJobStreamClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[5], "/hashicorp.vagrant.Vagrant/RunnerJobStream", opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &_Vagrant_serviceDesc.Streams[5], "/hashicorp.vagrant.Vagrant/RunnerJobStream", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -604,11 +603,11 @@ type VagrantServer interface {
|
||||
// GetVersionInfo returns information about the server. This RPC call does
|
||||
// NOT require authentication. It can be used by clients to determine if they
|
||||
// are capable of talking to this server.
|
||||
GetVersionInfo(context.Context, *emptypb.Empty) (*GetVersionInfoResponse, error)
|
||||
GetVersionInfo(context.Context, *empty.Empty) (*GetVersionInfoResponse, error)
|
||||
UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error)
|
||||
GetBasis(context.Context, *GetBasisRequest) (*GetBasisResponse, error)
|
||||
FindBasis(context.Context, *FindBasisRequest) (*FindBasisResponse, error)
|
||||
ListBasis(context.Context, *emptypb.Empty) (*ListBasisResponse, error)
|
||||
ListBasis(context.Context, *empty.Empty) (*ListBasisResponse, error)
|
||||
// ListTasks returns the tasks.
|
||||
ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
|
||||
// GetTask returns a task
|
||||
@ -626,13 +625,13 @@ type VagrantServer interface {
|
||||
// ListProjects returns a list of all the projects. There is no equivalent
|
||||
// ListApplications because applications are a part of projects and you
|
||||
// can use GetProject to get more information about the project.
|
||||
ListProjects(context.Context, *emptypb.Empty) (*ListProjectsResponse, error)
|
||||
ListProjects(context.Context, *empty.Empty) (*ListProjectsResponse, error)
|
||||
// UpsertTarget upserts a target with a project. If the target
|
||||
// is already registered this does nothing.
|
||||
UpsertTarget(context.Context, *UpsertTargetRequest) (*UpsertTargetResponse, error)
|
||||
GetTarget(context.Context, *GetTargetRequest) (*GetTargetResponse, error)
|
||||
FindTarget(context.Context, *FindTargetRequest) (*FindTargetResponse, error)
|
||||
ListTargets(context.Context, *emptypb.Empty) (*ListTargetsResponse, error)
|
||||
ListTargets(context.Context, *empty.Empty) (*ListTargetsResponse, error)
|
||||
// GetLogStream reads the log stream for a deployment. This will immediately
|
||||
// send a single LogEntry with the lines we have so far. If there are no
|
||||
// available lines this will NOT block and instead will return an error.
|
||||
@ -654,7 +653,7 @@ type VagrantServer interface {
|
||||
//
|
||||
// This RPC always returns immediately. You must use GetJob or GetJobStream
|
||||
// to wait on the status of the cancellation.
|
||||
CancelJob(context.Context, *CancelJobRequest) (*emptypb.Empty, error)
|
||||
CancelJob(context.Context, *CancelJobRequest) (*empty.Empty, error)
|
||||
// GetJob queries a job by ID.
|
||||
GetJob(context.Context, *GetJobRequest) (*Job, error)
|
||||
// INTERNAL: ListJobs lists all the jobs the server has processed. This
|
||||
@ -671,11 +670,11 @@ type VagrantServer interface {
|
||||
// GetRunner gets information about a single runner.
|
||||
GetRunner(context.Context, *GetRunnerRequest) (*Runner, error)
|
||||
// GetServerConfig sets configuration for the Vagrant server.
|
||||
GetServerConfig(context.Context, *emptypb.Empty) (*GetServerConfigResponse, error)
|
||||
GetServerConfig(context.Context, *empty.Empty) (*GetServerConfigResponse, error)
|
||||
// SetServerConfig sets configuration for the Vagrant server.
|
||||
SetServerConfig(context.Context, *SetServerConfigRequest) (*emptypb.Empty, error)
|
||||
SetServerConfig(context.Context, *SetServerConfigRequest) (*empty.Empty, error)
|
||||
// CreateSnapshot creates a new database snapshot.
|
||||
CreateSnapshot(*emptypb.Empty, Vagrant_CreateSnapshotServer) error
|
||||
CreateSnapshot(*empty.Empty, Vagrant_CreateSnapshotServer) error
|
||||
// RestoreSnapshot performs a database restore with the given snapshot.
|
||||
// This API doesn't do a full online restore, it only stages the restore
|
||||
// for the next server start to finalize the restore. See the arguments for
|
||||
@ -684,11 +683,11 @@ type VagrantServer interface {
|
||||
// BootstrapToken returns the initial token for the server. This can only
|
||||
// be requested once on first startup. After initial request this will
|
||||
// always return a PermissionDenied error.
|
||||
BootstrapToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error)
|
||||
BootstrapToken(context.Context, *empty.Empty) (*NewTokenResponse, error)
|
||||
// Generate a new invite token that users can exchange for a login token.
|
||||
GenerateInviteToken(context.Context, *InviteTokenRequest) (*NewTokenResponse, error)
|
||||
// Generate a new login token that users can use to login directly.
|
||||
GenerateLoginToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error)
|
||||
GenerateLoginToken(context.Context, *empty.Empty) (*NewTokenResponse, error)
|
||||
// Exchange a invite token for a login token.
|
||||
ConvertInviteToken(context.Context, *ConvertInviteTokenRequest) (*NewTokenResponse, error)
|
||||
// RunnerConfig is called to register a runner and receive the configuration
|
||||
@ -704,7 +703,7 @@ type VagrantServer interface {
|
||||
type UnimplementedVagrantServer struct {
|
||||
}
|
||||
|
||||
func (UnimplementedVagrantServer) GetVersionInfo(context.Context, *emptypb.Empty) (*GetVersionInfoResponse, error) {
|
||||
func (UnimplementedVagrantServer) GetVersionInfo(context.Context, *empty.Empty) (*GetVersionInfoResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetVersionInfo not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error) {
|
||||
@ -716,7 +715,7 @@ func (UnimplementedVagrantServer) GetBasis(context.Context, *GetBasisRequest) (*
|
||||
func (UnimplementedVagrantServer) FindBasis(context.Context, *FindBasisRequest) (*FindBasisResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method FindBasis not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ListBasis(context.Context, *emptypb.Empty) (*ListBasisResponse, error) {
|
||||
func (UnimplementedVagrantServer) ListBasis(context.Context, *empty.Empty) (*ListBasisResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListBasis not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) {
|
||||
@ -740,7 +739,7 @@ func (UnimplementedVagrantServer) GetProject(context.Context, *GetProjectRequest
|
||||
func (UnimplementedVagrantServer) FindProject(context.Context, *FindProjectRequest) (*FindProjectResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method FindProject not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ListProjects(context.Context, *emptypb.Empty) (*ListProjectsResponse, error) {
|
||||
func (UnimplementedVagrantServer) ListProjects(context.Context, *empty.Empty) (*ListProjectsResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListProjects not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) UpsertTarget(context.Context, *UpsertTargetRequest) (*UpsertTargetResponse, error) {
|
||||
@ -752,7 +751,7 @@ func (UnimplementedVagrantServer) GetTarget(context.Context, *GetTargetRequest)
|
||||
func (UnimplementedVagrantServer) FindTarget(context.Context, *FindTargetRequest) (*FindTargetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method FindTarget not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ListTargets(context.Context, *emptypb.Empty) (*ListTargetsResponse, error) {
|
||||
func (UnimplementedVagrantServer) ListTargets(context.Context, *empty.Empty) (*ListTargetsResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListTargets not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetLogStream(*GetLogStreamRequest, Vagrant_GetLogStreamServer) error {
|
||||
@ -767,7 +766,7 @@ func (UnimplementedVagrantServer) GetConfig(context.Context, *ConfigGetRequest)
|
||||
func (UnimplementedVagrantServer) QueueJob(context.Context, *QueueJobRequest) (*QueueJobResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method QueueJob not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) CancelJob(context.Context, *CancelJobRequest) (*emptypb.Empty, error) {
|
||||
func (UnimplementedVagrantServer) CancelJob(context.Context, *CancelJobRequest) (*empty.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method CancelJob not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetJob(context.Context, *GetJobRequest) (*Job, error) {
|
||||
@ -785,25 +784,25 @@ func (UnimplementedVagrantServer) GetJobStream(*GetJobStreamRequest, Vagrant_Get
|
||||
func (UnimplementedVagrantServer) GetRunner(context.Context, *GetRunnerRequest) (*Runner, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetRunner not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetServerConfig(context.Context, *emptypb.Empty) (*GetServerConfigResponse, error) {
|
||||
func (UnimplementedVagrantServer) GetServerConfig(context.Context, *empty.Empty) (*GetServerConfigResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetServerConfig not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) SetServerConfig(context.Context, *SetServerConfigRequest) (*emptypb.Empty, error) {
|
||||
func (UnimplementedVagrantServer) SetServerConfig(context.Context, *SetServerConfigRequest) (*empty.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method SetServerConfig not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) CreateSnapshot(*emptypb.Empty, Vagrant_CreateSnapshotServer) error {
|
||||
func (UnimplementedVagrantServer) CreateSnapshot(*empty.Empty, Vagrant_CreateSnapshotServer) error {
|
||||
return status.Errorf(codes.Unimplemented, "method CreateSnapshot not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) RestoreSnapshot(Vagrant_RestoreSnapshotServer) error {
|
||||
return status.Errorf(codes.Unimplemented, "method RestoreSnapshot not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) BootstrapToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error) {
|
||||
func (UnimplementedVagrantServer) BootstrapToken(context.Context, *empty.Empty) (*NewTokenResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method BootstrapToken not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GenerateInviteToken(context.Context, *InviteTokenRequest) (*NewTokenResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GenerateInviteToken not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GenerateLoginToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error) {
|
||||
func (UnimplementedVagrantServer) GenerateLoginToken(context.Context, *empty.Empty) (*NewTokenResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GenerateLoginToken not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ConvertInviteToken(context.Context, *ConvertInviteTokenRequest) (*NewTokenResponse, error) {
|
||||
@ -824,11 +823,11 @@ type UnsafeVagrantServer interface {
|
||||
}
|
||||
|
||||
func RegisterVagrantServer(s grpc.ServiceRegistrar, srv VagrantServer) {
|
||||
s.RegisterService(&Vagrant_ServiceDesc, srv)
|
||||
s.RegisterService(&_Vagrant_serviceDesc, srv)
|
||||
}
|
||||
|
||||
func _Vagrant_GetVersionInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -840,7 +839,7 @@ func _Vagrant_GetVersionInfo_Handler(srv interface{}, ctx context.Context, dec f
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/GetVersionInfo",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).GetVersionInfo(ctx, req.(*emptypb.Empty))
|
||||
return srv.(VagrantServer).GetVersionInfo(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -900,7 +899,7 @@ func _Vagrant_FindBasis_Handler(srv interface{}, ctx context.Context, dec func(i
|
||||
}
|
||||
|
||||
func _Vagrant_ListBasis_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -912,7 +911,7 @@ func _Vagrant_ListBasis_Handler(srv interface{}, ctx context.Context, dec func(i
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/ListBasis",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).ListBasis(ctx, req.(*emptypb.Empty))
|
||||
return srv.(VagrantServer).ListBasis(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1044,7 +1043,7 @@ func _Vagrant_FindProject_Handler(srv interface{}, ctx context.Context, dec func
|
||||
}
|
||||
|
||||
func _Vagrant_ListProjects_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1056,7 +1055,7 @@ func _Vagrant_ListProjects_Handler(srv interface{}, ctx context.Context, dec fun
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/ListProjects",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).ListProjects(ctx, req.(*emptypb.Empty))
|
||||
return srv.(VagrantServer).ListProjects(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1116,7 +1115,7 @@ func _Vagrant_FindTarget_Handler(srv interface{}, ctx context.Context, dec func(
|
||||
}
|
||||
|
||||
func _Vagrant_ListTargets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1128,7 +1127,7 @@ func _Vagrant_ListTargets_Handler(srv interface{}, ctx context.Context, dec func
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/ListTargets",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).ListTargets(ctx, req.(*emptypb.Empty))
|
||||
return srv.(VagrantServer).ListTargets(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1320,7 +1319,7 @@ func _Vagrant_GetRunner_Handler(srv interface{}, ctx context.Context, dec func(i
|
||||
}
|
||||
|
||||
func _Vagrant_GetServerConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1332,7 +1331,7 @@ func _Vagrant_GetServerConfig_Handler(srv interface{}, ctx context.Context, dec
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/GetServerConfig",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).GetServerConfig(ctx, req.(*emptypb.Empty))
|
||||
return srv.(VagrantServer).GetServerConfig(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1356,7 +1355,7 @@ func _Vagrant_SetServerConfig_Handler(srv interface{}, ctx context.Context, dec
|
||||
}
|
||||
|
||||
func _Vagrant_CreateSnapshot_Handler(srv interface{}, stream grpc.ServerStream) error {
|
||||
m := new(emptypb.Empty)
|
||||
m := new(empty.Empty)
|
||||
if err := stream.RecvMsg(m); err != nil {
|
||||
return err
|
||||
}
|
||||
@ -1381,7 +1380,7 @@ func _Vagrant_RestoreSnapshot_Handler(srv interface{}, stream grpc.ServerStream)
|
||||
}
|
||||
|
||||
type Vagrant_RestoreSnapshotServer interface {
|
||||
SendAndClose(*emptypb.Empty) error
|
||||
SendAndClose(*empty.Empty) error
|
||||
Recv() (*RestoreSnapshotRequest, error)
|
||||
grpc.ServerStream
|
||||
}
|
||||
@ -1390,7 +1389,7 @@ type vagrantRestoreSnapshotServer struct {
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
func (x *vagrantRestoreSnapshotServer) SendAndClose(m *emptypb.Empty) error {
|
||||
func (x *vagrantRestoreSnapshotServer) SendAndClose(m *empty.Empty) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
|
||||
@ -1403,7 +1402,7 @@ func (x *vagrantRestoreSnapshotServer) Recv() (*RestoreSnapshotRequest, error) {
|
||||
}
|
||||
|
||||
func _Vagrant_BootstrapToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1415,7 +1414,7 @@ func _Vagrant_BootstrapToken_Handler(srv interface{}, ctx context.Context, dec f
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/BootstrapToken",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).BootstrapToken(ctx, req.(*emptypb.Empty))
|
||||
return srv.(VagrantServer).BootstrapToken(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1439,7 +1438,7 @@ func _Vagrant_GenerateInviteToken_Handler(srv interface{}, ctx context.Context,
|
||||
}
|
||||
|
||||
func _Vagrant_GenerateLoginToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
in := new(empty.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1451,7 +1450,7 @@ func _Vagrant_GenerateLoginToken_Handler(srv interface{}, ctx context.Context, d
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/GenerateLoginToken",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).GenerateLoginToken(ctx, req.(*emptypb.Empty))
|
||||
return srv.(VagrantServer).GenerateLoginToken(ctx, req.(*empty.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1526,10 +1525,7 @@ func (x *vagrantRunnerJobStreamServer) Recv() (*RunnerJobStreamRequest, error) {
|
||||
return m, nil
|
||||
}
|
||||
|
||||
// Vagrant_ServiceDesc is the grpc.ServiceDesc for Vagrant service.
|
||||
// It's only intended for direct use with grpc.RegisterService,
|
||||
// and not to be introspected or modified (even as a copy)
|
||||
var Vagrant_ServiceDesc = grpc.ServiceDesc{
|
||||
var _Vagrant_serviceDesc = grpc.ServiceDesc{
|
||||
ServiceName: "hashicorp.vagrant.Vagrant",
|
||||
HandlerType: (*VagrantServer)(nil),
|
||||
Methods: []grpc.MethodDesc{
|
||||
|
||||
@ -8,7 +8,7 @@ module Plugin
|
||||
module GRPCBroker
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
|
||||
@ -10,7 +10,7 @@ module Hashicorp
|
||||
# The service that is implemented for the server backend.
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
|
||||
@ -96,9 +96,6 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
optional :short_description, :string, 2
|
||||
optional :long_description, :string, 3
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.Args.Host" do
|
||||
optional :server_addr, :string, 1
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.Args.StateBag" do
|
||||
optional :stream_id, :uint32, 1
|
||||
end
|
||||
|
||||
@ -17,7 +17,7 @@ module Hashicorp
|
||||
# interact with it indirectly via a terminal.UI implementation.
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -35,7 +35,7 @@ module Hashicorp
|
||||
# to convert to/from various types.
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -57,7 +57,7 @@ module Hashicorp
|
||||
#
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -84,7 +84,7 @@ module Hashicorp
|
||||
# the state of a machine
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -138,7 +138,7 @@ module Hashicorp
|
||||
# A Provisioner runs actions against a VM
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -154,7 +154,7 @@ module Hashicorp
|
||||
module CommandService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -174,7 +174,7 @@ module Hashicorp
|
||||
module CommunicatorService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -210,7 +210,7 @@ module Hashicorp
|
||||
module ConfigService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -226,7 +226,7 @@ module Hashicorp
|
||||
module GuestService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -248,7 +248,7 @@ module Hashicorp
|
||||
module HostService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -270,7 +270,7 @@ module Hashicorp
|
||||
module SyncedFolderService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -286,7 +286,7 @@ module Hashicorp
|
||||
module BasisService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -304,7 +304,7 @@ module Hashicorp
|
||||
# ******************************************************************
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -331,7 +331,7 @@ module Hashicorp
|
||||
module TargetMachineService
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
@ -370,7 +370,7 @@ module Hashicorp
|
||||
# ******************************************************************
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
|
||||
@ -10,7 +10,7 @@ module Hashicorp
|
||||
# The service that is implemented for the server backend.
|
||||
class Service
|
||||
|
||||
include ::GRPC::GenericService
|
||||
include GRPC::GenericService
|
||||
|
||||
self.marshal_class_method = :encode
|
||||
self.unmarshal_class_method = :decode
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user