beckermj/vaguerent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Generated proto updates

Browse Source
This commit is contained in:
Chris Roberts 2021-10-13 15:52:11 -07:00 committed by Paul Hinze
parent 5052e1b9bf
commit be4bbe902f
No known key found for this signature in database
GPG Key ID: B69DEDF2D55501C0
6 changed files with 132 additions and 123 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/server/proto/ruby_vagrant/ruby-server.pb.go
View File

@ -1,18 +1,18 @@
// Code generated by protoc-gen-go. DO NOT EDIT. // Code generated by protoc-gen-go. DO NOT EDIT.
// versions: // versions:
// protoc-gen-go v1.23.0 // protoc-gen-go v1.25.0
// protoc v3.13.0 // protoc v3.17.3
// source: proto/ruby_vagrant/ruby-server.proto // source: proto/ruby_vagrant/ruby-server.proto
package ruby_vagrant package ruby_vagrant
import ( import (
proto "github.com/golang/protobuf/proto" proto "github.com/golang/protobuf/proto"
_ "github.com/golang/protobuf/ptypes/any"
empty "github.com/golang/protobuf/ptypes/empty"
vagrant_plugin_sdk "github.com/hashicorp/vagrant-plugin-sdk/proto/vagrant_plugin_sdk" vagrant_plugin_sdk "github.com/hashicorp/vagrant-plugin-sdk/proto/vagrant_plugin_sdk"
protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl" protoimpl "google.golang.org/protobuf/runtime/protoimpl"
_ "google.golang.org/protobuf/types/known/anypb"
emptypb "google.golang.org/protobuf/types/known/emptypb"
reflect "reflect" reflect "reflect"
sync "sync" sync "sync"
) )
@ -398,7 +398,7 @@ var file_proto_ruby_vagrant_ruby_server_proto_goTypes = []interface{}{
(*ParseVagrantfileRequest)(nil), // 3: hashicorp.vagrant.ParseVagrantfileRequest (*ParseVagrantfileRequest)(nil), // 3: hashicorp.vagrant.ParseVagrantfileRequest
(*ParseVagrantfileResponse)(nil), // 4: hashicorp.vagrant.ParseVagrantfileResponse (*ParseVagrantfileResponse)(nil), // 4: hashicorp.vagrant.ParseVagrantfileResponse
(*vagrant_plugin_sdk.Vagrantfile_Vagrantfile)(nil), // 5: hashicorp.vagrant.sdk.Vagrantfile.Vagrantfile (*vagrant_plugin_sdk.Vagrantfile_Vagrantfile)(nil), // 5: hashicorp.vagrant.sdk.Vagrantfile.Vagrantfile
(*empty.Empty)(nil), // 6: google.protobuf.Empty (*emptypb.Empty)(nil), // 6: google.protobuf.Empty
} }
var file_proto_ruby_vagrant_ruby_server_proto_depIdxs = []int32{ var file_proto_ruby_vagrant_ruby_server_proto_depIdxs = []int32{
2, // 0: hashicorp.vagrant.GetPluginsResponse.plugins:type_name -> hashicorp.vagrant.Plugin 2, // 0: hashicorp.vagrant.GetPluginsResponse.plugins:type_name -> hashicorp.vagrant.Plugin

14
internal/server/proto/ruby_vagrant/ruby-server_grpc.pb.go
View File

@ -4,10 +4,10 @@ package ruby_vagrant
import ( import (
context "context" context "context"
empty "github.com/golang/protobuf/ptypes/empty"
grpc "google.golang.org/grpc" grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes" codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status" 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 // This is a compile-time assertion to ensure that this generated file
@ -20,7 +20,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. // 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 { type RubyVagrantClient interface {
// Gets available ruby plugins // Gets available ruby plugins
GetPlugins(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error) GetPlugins(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error)
ParseVagrantfile(ctx context.Context, in *ParseVagrantfileRequest, opts ...grpc.CallOption) (*ParseVagrantfileResponse, error) ParseVagrantfile(ctx context.Context, in *ParseVagrantfileRequest, opts ...grpc.CallOption) (*ParseVagrantfileResponse, error)
} }
@ -32,7 +32,7 @@ func NewRubyVagrantClient(cc grpc.ClientConnInterface) RubyVagrantClient {
return &rubyVagrantClient{cc} return &rubyVagrantClient{cc}
} }
func (c *rubyVagrantClient) GetPlugins(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error) { func (c *rubyVagrantClient) GetPlugins(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetPluginsResponse, error) {
out := new(GetPluginsResponse) out := new(GetPluginsResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.RubyVagrant/GetPlugins", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.RubyVagrant/GetPlugins", in, out, opts...)
if err != nil { if err != nil {
@ -55,7 +55,7 @@ func (c *rubyVagrantClient) ParseVagrantfile(ctx context.Context, in *ParseVagra
// for forward compatibility // for forward compatibility
type RubyVagrantServer interface { type RubyVagrantServer interface {
// Gets available ruby plugins // Gets available ruby plugins
GetPlugins(context.Context, *empty.Empty) (*GetPluginsResponse, error) GetPlugins(context.Context, *emptypb.Empty) (*GetPluginsResponse, error)
ParseVagrantfile(context.Context, *ParseVagrantfileRequest) (*ParseVagrantfileResponse, error) ParseVagrantfile(context.Context, *ParseVagrantfileRequest) (*ParseVagrantfileResponse, error)
mustEmbedUnimplementedRubyVagrantServer() mustEmbedUnimplementedRubyVagrantServer()
} }
@ -64,7 +64,7 @@ type RubyVagrantServer interface {
type UnimplementedRubyVagrantServer struct { type UnimplementedRubyVagrantServer struct {
} }
func (UnimplementedRubyVagrantServer) GetPlugins(context.Context, *empty.Empty) (*GetPluginsResponse, error) { func (UnimplementedRubyVagrantServer) GetPlugins(context.Context, *emptypb.Empty) (*GetPluginsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetPlugins not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetPlugins not implemented")
} }
func (UnimplementedRubyVagrantServer) ParseVagrantfile(context.Context, *ParseVagrantfileRequest) (*ParseVagrantfileResponse, error) { func (UnimplementedRubyVagrantServer) ParseVagrantfile(context.Context, *ParseVagrantfileRequest) (*ParseVagrantfileResponse, error) {
@ -84,7 +84,7 @@ func RegisterRubyVagrantServer(s grpc.ServiceRegistrar, srv RubyVagrantServer) {
} }
func _RubyVagrant_GetPlugins_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _RubyVagrant_GetPlugins_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -96,7 +96,7 @@ func _RubyVagrant_GetPlugins_Handler(srv interface{}, ctx context.Context, dec f
FullMethod: "/hashicorp.vagrant.RubyVagrant/GetPlugins", FullMethod: "/hashicorp.vagrant.RubyVagrant/GetPlugins",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RubyVagrantServer).GetPlugins(ctx, req.(*empty.Empty)) return srv.(RubyVagrantServer).GetPlugins(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }

71
internal/server/proto/vagrant_server/server.pb.go
View File

@ -1,21 +1,21 @@
// Code generated by protoc-gen-go. DO NOT EDIT. // Code generated by protoc-gen-go. DO NOT EDIT.
// versions: // versions:
// protoc-gen-go v1.23.0 // protoc-gen-go v1.25.0
// protoc v3.13.0 // protoc v3.17.3
// source: proto/vagrant_server/server.proto // source: proto/vagrant_server/server.proto
package vagrant_server package vagrant_server
import ( import (
proto "github.com/golang/protobuf/proto" proto "github.com/golang/protobuf/proto"
any "github.com/golang/protobuf/ptypes/any"
empty "github.com/golang/protobuf/ptypes/empty"
_ "github.com/golang/protobuf/ptypes/struct"
timestamp "github.com/golang/protobuf/ptypes/timestamp"
vagrant_plugin_sdk "github.com/hashicorp/vagrant-plugin-sdk/proto/vagrant_plugin_sdk" vagrant_plugin_sdk "github.com/hashicorp/vagrant-plugin-sdk/proto/vagrant_plugin_sdk"
status "google.golang.org/genproto/googleapis/rpc/status" status "google.golang.org/genproto/googleapis/rpc/status"
protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl" protoimpl "google.golang.org/protobuf/runtime/protoimpl"
anypb "google.golang.org/protobuf/types/known/anypb"
emptypb "google.golang.org/protobuf/types/known/emptypb"
_ "google.golang.org/protobuf/types/known/structpb"
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
reflect "reflect" reflect "reflect"
sync "sync" sync "sync"
) )
@ -951,7 +951,7 @@ type Target struct {
// Serialized configuration of the target (Vagrantfile) // Serialized configuration of the target (Vagrantfile)
Configuration *vagrant_plugin_sdk.Vagrantfile_MachineConfig `protobuf:"bytes,10,opt,name=configuration,proto3" json:"configuration,omitempty"` Configuration *vagrant_plugin_sdk.Vagrantfile_MachineConfig `protobuf:"bytes,10,opt,name=configuration,proto3" json:"configuration,omitempty"`
// Specialized target information (from provider) // Specialized target information (from provider)
Record *any.Any `protobuf:"bytes,11,opt,name=record,proto3" json:"record,omitempty"` Record *anypb.Any `protobuf:"bytes,11,opt,name=record,proto3" json:"record,omitempty"`
// Provider name backing machine // Provider name backing machine
Provider string `protobuf:"bytes,12,opt,name=provider,proto3" json:"provider,omitempty"` Provider string `protobuf:"bytes,12,opt,name=provider,proto3" json:"provider,omitempty"`
// If true, then the `-remote` flag or the `vagrant build project/app` // If true, then the `-remote` flag or the `vagrant build project/app`
@ -1068,7 +1068,7 @@ func (x *Target) GetConfiguration() *vagrant_plugin_sdk.Vagrantfile_MachineConfi
return nil return nil
} }
func (x *Target) GetRecord() *any.Any { func (x *Target) GetRecord() *anypb.Any {
if x != nil { if x != nil {
return x.Record return x.Record
} }
@ -1285,9 +1285,9 @@ type Status struct {
// error is set if the state == ERROR with the error that occurred. // error is set if the state == ERROR with the error that occurred.
Error *status.Status `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` Error *status.Status `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// start_time is the time the operation was started. // start_time is the time the operation was started.
StartTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// complete_time is the time the operation completed (success or fail). // complete_time is the time the operation completed (success or fail).
CompleteTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"` CompleteTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
} }
func (x *Status) Reset() { func (x *Status) Reset() {
@ -1343,14 +1343,14 @@ func (x *Status) GetError() *status.Status {
return nil return nil
} }
func (x *Status) GetStartTime() *timestamp.Timestamp { func (x *Status) GetStartTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.StartTime return x.StartTime
} }
return nil return nil
} }
func (x *Status) GetCompleteTime() *timestamp.Timestamp { func (x *Status) GetCompleteTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.CompleteTime return x.CompleteTime
} }
@ -1848,10 +1848,10 @@ type Job struct {
// runner may have been ephemeral and may no longer exist. // runner may have been ephemeral and may no longer exist.
AssignedRunner *Ref_RunnerId `protobuf:"bytes,101,opt,name=assigned_runner,json=assignedRunner,proto3" json:"assigned_runner,omitempty"` AssignedRunner *Ref_RunnerId `protobuf:"bytes,101,opt,name=assigned_runner,json=assignedRunner,proto3" json:"assigned_runner,omitempty"`
// The time when the job was queued. // The time when the job was queued.
QueueTime *timestamp.Timestamp `protobuf:"bytes,102,opt,name=queue_time,json=queueTime,proto3" json:"queue_time,omitempty"` QueueTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=queue_time,json=queueTime,proto3" json:"queue_time,omitempty"`
AssignTime *timestamp.Timestamp `protobuf:"bytes,103,opt,name=assign_time,json=assignTime,proto3" json:"assign_time,omitempty"` AssignTime *timestamppb.Timestamp `protobuf:"bytes,103,opt,name=assign_time,json=assignTime,proto3" json:"assign_time,omitempty"`
AckTime *timestamp.Timestamp `protobuf:"bytes,104,opt,name=ack_time,json=ackTime,proto3" json:"ack_time,omitempty"` AckTime *timestamppb.Timestamp `protobuf:"bytes,104,opt,name=ack_time,json=ackTime,proto3" json:"ack_time,omitempty"`
CompleteTime *timestamp.Timestamp `protobuf:"bytes,105,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"` CompleteTime *timestamppb.Timestamp `protobuf:"bytes,105,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
// error is set if state == ERROR // error is set if state == ERROR
Error *status.Status `protobuf:"bytes,106,opt,name=error,proto3" json:"error,omitempty"` Error *status.Status `protobuf:"bytes,106,opt,name=error,proto3" json:"error,omitempty"`
// result is set based on the operation specified. A nil result is possible // result is set based on the operation specified. A nil result is possible
@ -1861,12 +1861,12 @@ type Job struct {
// If this is zero then this job was not cancelled. Note that this is the // If this is zero then this job was not cancelled. Note that this is the
// cancellation _request_ time. The actual time a job ended is noted by // cancellation _request_ time. The actual time a job ended is noted by
// the complete_time field. // the complete_time field.
CancelTime *timestamp.Timestamp `protobuf:"bytes,108,opt,name=cancel_time,json=cancelTime,proto3" json:"cancel_time,omitempty"` CancelTime *timestamppb.Timestamp `protobuf:"bytes,108,opt,name=cancel_time,json=cancelTime,proto3" json:"cancel_time,omitempty"`
// expire time is the time when this job would expire. If this isn't set // expire time is the time when this job would expire. If this isn't set
// then this is a non-expiring job. This will remain set even if the job // then this is a non-expiring job. This will remain set even if the job
// never expired because it was accepted and run. This field can be used // never expired because it was accepted and run. This field can be used
// to detect that it was configured to expire. // to detect that it was configured to expire.
ExpireTime *timestamp.Timestamp `protobuf:"bytes,109,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"` ExpireTime *timestamppb.Timestamp `protobuf:"bytes,109,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
} }
func (x *Job) Reset() { func (x *Job) Reset() {
@ -2020,28 +2020,28 @@ func (x *Job) GetAssignedRunner() *Ref_RunnerId {
return nil return nil
} }
func (x *Job) GetQueueTime() *timestamp.Timestamp { func (x *Job) GetQueueTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.QueueTime return x.QueueTime
} }
return nil return nil
} }
func (x *Job) GetAssignTime() *timestamp.Timestamp { func (x *Job) GetAssignTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.AssignTime return x.AssignTime
} }
return nil return nil
} }
func (x *Job) GetAckTime() *timestamp.Timestamp { func (x *Job) GetAckTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.AckTime return x.AckTime
} }
return nil return nil
} }
func (x *Job) GetCompleteTime() *timestamp.Timestamp { func (x *Job) GetCompleteTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.CompleteTime return x.CompleteTime
} }
@ -2062,14 +2062,14 @@ func (x *Job) GetResult() *Job_Result {
return nil return nil
} }
func (x *Job) GetCancelTime() *timestamp.Timestamp { func (x *Job) GetCancelTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.CancelTime return x.CancelTime
} }
return nil return nil
} }
func (x *Job) GetExpireTime() *timestamp.Timestamp { func (x *Job) GetExpireTime() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.ExpireTime return x.ExpireTime
} }
@ -5605,7 +5605,7 @@ type Token struct {
TokenId []byte `protobuf:"bytes,2,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty"` TokenId []byte `protobuf:"bytes,2,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty"`
// When the token is valid until. After the given date, the token will be rejected. // When the token is valid until. After the given date, the token will be rejected.
// When this is not set, the token is valid forever. // When this is not set, the token is valid forever.
ValidUntil *timestamp.Timestamp `protobuf:"bytes,3,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` ValidUntil *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"`
// Indicates whether or not this token can be used for to authenticate RPCs. // Indicates whether or not this token can be used for to authenticate RPCs.
Login bool `protobuf:"varint,4,opt,name=login,proto3" json:"login,omitempty"` Login bool `protobuf:"varint,4,opt,name=login,proto3" json:"login,omitempty"`
// Inidicates whether or not this token can be used as an invite. // Inidicates whether or not this token can be used as an invite.
@ -5661,7 +5661,7 @@ func (x *Token) GetTokenId() []byte {
return nil return nil
} }
func (x *Token) GetValidUntil() *timestamp.Timestamp { func (x *Token) GetValidUntil() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.ValidUntil return x.ValidUntil
} }
@ -9176,7 +9176,7 @@ type GetJobStreamResponse_Terminal_Event struct {
// timestamp of the event as seen by the runner. This might be // timestamp of the event as seen by the runner. This might be
// skewed from the server or the client but relative to all other // skewed from the server or the client but relative to all other
// line output, it will be accurate. // line output, it will be accurate.
Timestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// Types that are assignable to Event: // Types that are assignable to Event:
// *GetJobStreamResponse_Terminal_Event_Line_ // *GetJobStreamResponse_Terminal_Event_Line_
// *GetJobStreamResponse_Terminal_Event_Status_ // *GetJobStreamResponse_Terminal_Event_Status_
@ -9220,7 +9220,7 @@ func (*GetJobStreamResponse_Terminal_Event) Descriptor() ([]byte, []int) {
return file_proto_vagrant_server_server_proto_rawDescGZIP(), []int{23, 2, 0} return file_proto_vagrant_server_server_proto_rawDescGZIP(), []int{23, 2, 0}
} }
func (x *GetJobStreamResponse_Terminal_Event) GetTimestamp() *timestamp.Timestamp { func (x *GetJobStreamResponse_Terminal_Event) GetTimestamp() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.Timestamp return x.Timestamp
} }
@ -9326,7 +9326,8 @@ func (*GetJobStreamResponse_Terminal_Event_Raw_) isGetJobStreamResponse_Terminal
func (*GetJobStreamResponse_Terminal_Event_Table_) isGetJobStreamResponse_Terminal_Event_Event() {} func (*GetJobStreamResponse_Terminal_Event_Table_) isGetJobStreamResponse_Terminal_Event_Event() {}
func (*GetJobStreamResponse_Terminal_Event_StepGroup_) isGetJobStreamResponse_Terminal_Event_Event() {} func (*GetJobStreamResponse_Terminal_Event_StepGroup_) isGetJobStreamResponse_Terminal_Event_Event() {
}
func (*GetJobStreamResponse_Terminal_Event_Step_) isGetJobStreamResponse_Terminal_Event_Event() {} func (*GetJobStreamResponse_Terminal_Event_Step_) isGetJobStreamResponse_Terminal_Event_Event() {}
@ -10323,8 +10324,8 @@ type LogBatch_Entry struct {
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields unknownFields protoimpl.UnknownFields
Timestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"` Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"`
} }
func (x *LogBatch_Entry) Reset() { func (x *LogBatch_Entry) Reset() {
@ -10359,7 +10360,7 @@ func (*LogBatch_Entry) Descriptor() ([]byte, []int) {
return file_proto_vagrant_server_server_proto_rawDescGZIP(), []int{59, 0} return file_proto_vagrant_server_server_proto_rawDescGZIP(), []int{59, 0}
} }
func (x *LogBatch_Entry) GetTimestamp() *timestamp.Timestamp { func (x *LogBatch_Entry) GetTimestamp() *timestamppb.Timestamp {
if x != nil { if x != nil {
return x.Timestamp return x.Timestamp
} }
@ -13294,13 +13295,13 @@ var file_proto_vagrant_server_server_proto_goTypes = []interface{}{
(*vagrant_plugin_sdk.Ref_Basis)(nil), // 189: hashicorp.vagrant.sdk.Ref.Basis (*vagrant_plugin_sdk.Ref_Basis)(nil), // 189: hashicorp.vagrant.sdk.Ref.Basis
(*vagrant_plugin_sdk.Args_DataDir_Target)(nil), // 190: hashicorp.vagrant.sdk.Args.DataDir.Target (*vagrant_plugin_sdk.Args_DataDir_Target)(nil), // 190: hashicorp.vagrant.sdk.Args.DataDir.Target
(*vagrant_plugin_sdk.Vagrantfile_MachineConfig)(nil), // 191: hashicorp.vagrant.sdk.Vagrantfile.MachineConfig (*vagrant_plugin_sdk.Vagrantfile_MachineConfig)(nil), // 191: hashicorp.vagrant.sdk.Vagrantfile.MachineConfig
(*any.Any)(nil), // 192: google.protobuf.Any (*anypb.Any)(nil), // 192: google.protobuf.Any
(*status.Status)(nil), // 193: google.rpc.Status (*status.Status)(nil), // 193: google.rpc.Status
(*timestamp.Timestamp)(nil), // 194: google.protobuf.Timestamp (*timestamppb.Timestamp)(nil), // 194: google.protobuf.Timestamp
(*vagrant_plugin_sdk.Command_Arguments)(nil), // 195: hashicorp.vagrant.sdk.Command.Arguments (*vagrant_plugin_sdk.Command_Arguments)(nil), // 195: hashicorp.vagrant.sdk.Command.Arguments
(*vagrant_plugin_sdk.Args_Target_Machine_Box)(nil), // 196: hashicorp.vagrant.sdk.Args.Target.Machine.Box (*vagrant_plugin_sdk.Args_Target_Machine_Box)(nil), // 196: hashicorp.vagrant.sdk.Args.Target.Machine.Box
(*vagrant_plugin_sdk.Args_Target_Machine_State)(nil), // 197: hashicorp.vagrant.sdk.Args.Target.Machine.State (*vagrant_plugin_sdk.Args_Target_Machine_State)(nil), // 197: hashicorp.vagrant.sdk.Args.Target.Machine.State
(*empty.Empty)(nil), // 198: google.protobuf.Empty (*emptypb.Empty)(nil), // 198: google.protobuf.Empty
} }
var file_proto_vagrant_server_server_proto_depIdxs = []int32{ var file_proto_vagrant_server_server_proto_depIdxs = []int32{
11, // 0: hashicorp.vagrant.GetVersionInfoResponse.info:type_name -> hashicorp.vagrant.VersionInfo 11, // 0: hashicorp.vagrant.GetVersionInfoResponse.info:type_name -> hashicorp.vagrant.VersionInfo

150
internal/server/proto/vagrant_server/server_grpc.pb.go
View File

@ -4,10 +4,10 @@ package vagrant_server
import ( import (
context "context" context "context"
empty "github.com/golang/protobuf/ptypes/empty"
grpc "google.golang.org/grpc" grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes" codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status" 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 // This is a compile-time assertion to ensure that this generated file
@ -22,11 +22,11 @@ type VagrantClient interface {
// GetVersionInfo returns information about the server. This RPC call does // GetVersionInfo returns information about the server. This RPC call does
// NOT require authentication. It can be used by clients to determine if they // NOT require authentication. It can be used by clients to determine if they
// are capable of talking to this server. // are capable of talking to this server.
GetVersionInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error) GetVersionInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error)
UpsertBasis(ctx context.Context, in *UpsertBasisRequest, opts ...grpc.CallOption) (*UpsertBasisResponse, error) UpsertBasis(ctx context.Context, in *UpsertBasisRequest, opts ...grpc.CallOption) (*UpsertBasisResponse, error)
GetBasis(ctx context.Context, in *GetBasisRequest, opts ...grpc.CallOption) (*GetBasisResponse, error) GetBasis(ctx context.Context, in *GetBasisRequest, opts ...grpc.CallOption) (*GetBasisResponse, error)
FindBasis(ctx context.Context, in *FindBasisRequest, opts ...grpc.CallOption) (*FindBasisResponse, error) FindBasis(ctx context.Context, in *FindBasisRequest, opts ...grpc.CallOption) (*FindBasisResponse, error)
ListBasis(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error) ListBasis(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error)
// ListTasks returns the tasks. // ListTasks returns the tasks.
ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
// GetTask returns a task // GetTask returns a task
@ -44,14 +44,14 @@ type VagrantClient interface {
// ListProjects returns a list of all the projects. There is no equivalent // ListProjects returns a list of all the projects. There is no equivalent
// ListApplications because applications are a part of projects and you // ListApplications because applications are a part of projects and you
// can use GetProject to get more information about the project. // can use GetProject to get more information about the project.
ListProjects(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error) ListProjects(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error)
// UpsertTarget upserts a target with a project. If the target // UpsertTarget upserts a target with a project. If the target
// is already registered this does nothing. // is already registered this does nothing.
UpsertTarget(ctx context.Context, in *UpsertTargetRequest, opts ...grpc.CallOption) (*UpsertTargetResponse, error) UpsertTarget(ctx context.Context, in *UpsertTargetRequest, opts ...grpc.CallOption) (*UpsertTargetResponse, error)
DeleteTarget(ctx context.Context, in *DeleteTargetRequest, opts ...grpc.CallOption) (*empty.Empty, error) DeleteTarget(ctx context.Context, in *DeleteTargetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
GetTarget(ctx context.Context, in *GetTargetRequest, opts ...grpc.CallOption) (*GetTargetResponse, error) GetTarget(ctx context.Context, in *GetTargetRequest, opts ...grpc.CallOption) (*GetTargetResponse, error)
FindTarget(ctx context.Context, in *FindTargetRequest, opts ...grpc.CallOption) (*FindTargetResponse, error) FindTarget(ctx context.Context, in *FindTargetRequest, opts ...grpc.CallOption) (*FindTargetResponse, error)
ListTargets(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error) ListTargets(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error)
// GetLogStream reads the log stream for a deployment. This will immediately // 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 // 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. // available lines this will NOT block and instead will return an error.
@ -73,7 +73,7 @@ type VagrantClient interface {
// //
// This RPC always returns immediately. You must use GetJob or GetJobStream // This RPC always returns immediately. You must use GetJob or GetJobStream
// to wait on the status of the cancellation. // to wait on the status of the cancellation.
CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// GetJob queries a job by ID. // GetJob queries a job by ID.
GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
// INTERNAL: ListJobs lists all the jobs the server has processed. This // INTERNAL: ListJobs lists all the jobs the server has processed. This
@ -88,15 +88,15 @@ type VagrantClient interface {
// Multiple listeners can open a job stream. // Multiple listeners can open a job stream.
GetJobStream(ctx context.Context, in *GetJobStreamRequest, opts ...grpc.CallOption) (Vagrant_GetJobStreamClient, error) GetJobStream(ctx context.Context, in *GetJobStreamRequest, opts ...grpc.CallOption) (Vagrant_GetJobStreamClient, error)
// Clean out old jobs from the job database // Clean out old jobs from the job database
PruneOldJobs(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) PruneOldJobs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
// GetRunner gets information about a single runner. // GetRunner gets information about a single runner.
GetRunner(ctx context.Context, in *GetRunnerRequest, opts ...grpc.CallOption) (*Runner, error) GetRunner(ctx context.Context, in *GetRunnerRequest, opts ...grpc.CallOption) (*Runner, error)
// GetServerConfig sets configuration for the Vagrant server. // GetServerConfig sets configuration for the Vagrant server.
GetServerConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error) GetServerConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error)
// SetServerConfig sets configuration for the Vagrant server. // SetServerConfig sets configuration for the Vagrant server.
SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// CreateSnapshot creates a new database snapshot. // CreateSnapshot creates a new database snapshot.
CreateSnapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error) CreateSnapshot(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error)
// RestoreSnapshot performs a database restore with the given snapshot. // RestoreSnapshot performs a database restore with the given snapshot.
// This API doesn't do a full online restore, it only stages the restore // 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 // for the next server start to finalize the restore. See the arguments for
@ -105,11 +105,11 @@ type VagrantClient interface {
// BootstrapToken returns the initial token for the server. This can only // BootstrapToken returns the initial token for the server. This can only
// be requested once on first startup. After initial request this will // be requested once on first startup. After initial request this will
// always return a PermissionDenied error. // always return a PermissionDenied error.
BootstrapToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) BootstrapToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error)
// Generate a new invite token that users can exchange for a login token. // Generate a new invite token that users can exchange for a login token.
GenerateInviteToken(ctx context.Context, in *InviteTokenRequest, opts ...grpc.CallOption) (*NewTokenResponse, error) GenerateInviteToken(ctx context.Context, in *InviteTokenRequest, opts ...grpc.CallOption) (*NewTokenResponse, error)
// Generate a new login token that users can use to login directly. // Generate a new login token that users can use to login directly.
GenerateLoginToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) GenerateLoginToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error)
// Exchange a invite token for a login token. // Exchange a invite token for a login token.
ConvertInviteToken(ctx context.Context, in *ConvertInviteTokenRequest, opts ...grpc.CallOption) (*NewTokenResponse, error) ConvertInviteToken(ctx context.Context, in *ConvertInviteTokenRequest, opts ...grpc.CallOption) (*NewTokenResponse, error)
// RunnerConfig is called to register a runner and receive the configuration // RunnerConfig is called to register a runner and receive the configuration
@ -129,7 +129,7 @@ func NewVagrantClient(cc grpc.ClientConnInterface) VagrantClient {
return &vagrantClient{cc} return &vagrantClient{cc}
} }
func (c *vagrantClient) GetVersionInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error) { func (c *vagrantClient) GetVersionInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetVersionInfoResponse, error) {
out := new(GetVersionInfoResponse) out := new(GetVersionInfoResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetVersionInfo", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetVersionInfo", in, out, opts...)
if err != nil { if err != nil {
@ -165,7 +165,7 @@ func (c *vagrantClient) FindBasis(ctx context.Context, in *FindBasisRequest, opt
return out, nil return out, nil
} }
func (c *vagrantClient) ListBasis(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error) { func (c *vagrantClient) ListBasis(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error) {
out := new(ListBasisResponse) out := new(ListBasisResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListBasis", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListBasis", in, out, opts...)
if err != nil { if err != nil {
@ -237,7 +237,7 @@ func (c *vagrantClient) FindProject(ctx context.Context, in *FindProjectRequest,
return out, nil return out, nil
} }
func (c *vagrantClient) ListProjects(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error) { func (c *vagrantClient) ListProjects(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListProjectsResponse, error) {
out := new(ListProjectsResponse) out := new(ListProjectsResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListProjects", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListProjects", in, out, opts...)
if err != nil { if err != nil {
@ -255,8 +255,8 @@ func (c *vagrantClient) UpsertTarget(ctx context.Context, in *UpsertTargetReques
return out, nil return out, nil
} }
func (c *vagrantClient) DeleteTarget(ctx context.Context, in *DeleteTargetRequest, opts ...grpc.CallOption) (*empty.Empty, error) { func (c *vagrantClient) DeleteTarget(ctx context.Context, in *DeleteTargetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(empty.Empty) out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/DeleteTarget", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/DeleteTarget", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -282,7 +282,7 @@ func (c *vagrantClient) FindTarget(ctx context.Context, in *FindTargetRequest, o
return out, nil return out, nil
} }
func (c *vagrantClient) ListTargets(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error) { func (c *vagrantClient) ListTargets(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTargetsResponse, error) {
out := new(ListTargetsResponse) out := new(ListTargetsResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListTargets", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListTargets", in, out, opts...)
if err != nil { if err != nil {
@ -350,8 +350,8 @@ func (c *vagrantClient) QueueJob(ctx context.Context, in *QueueJobRequest, opts
return out, nil return out, nil
} }
func (c *vagrantClient) CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*empty.Empty, error) { func (c *vagrantClient) CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(empty.Empty) out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/CancelJob", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/CancelJob", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -418,8 +418,8 @@ func (x *vagrantGetJobStreamClient) Recv() (*GetJobStreamResponse, error) {
return m, nil return m, nil
} }
func (c *vagrantClient) PruneOldJobs(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) { func (c *vagrantClient) PruneOldJobs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(empty.Empty) out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/PruneOldJobs", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/PruneOldJobs", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -436,7 +436,7 @@ func (c *vagrantClient) GetRunner(ctx context.Context, in *GetRunnerRequest, opt
return out, nil return out, nil
} }
func (c *vagrantClient) GetServerConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error) { func (c *vagrantClient) GetServerConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error) {
out := new(GetServerConfigResponse) out := new(GetServerConfigResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetServerConfig", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetServerConfig", in, out, opts...)
if err != nil { if err != nil {
@ -445,8 +445,8 @@ func (c *vagrantClient) GetServerConfig(ctx context.Context, in *empty.Empty, op
return out, nil return out, nil
} }
func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) { func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(empty.Empty) out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/SetServerConfig", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/SetServerConfig", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -454,7 +454,7 @@ func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfig
return out, nil return out, nil
} }
func (c *vagrantClient) CreateSnapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error) { 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...) stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[2], "/hashicorp.vagrant.Vagrant/CreateSnapshot", opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -497,7 +497,7 @@ func (c *vagrantClient) RestoreSnapshot(ctx context.Context, opts ...grpc.CallOp
type Vagrant_RestoreSnapshotClient interface { type Vagrant_RestoreSnapshotClient interface {
Send(*RestoreSnapshotRequest) error Send(*RestoreSnapshotRequest) error
CloseAndRecv() (*empty.Empty, error) CloseAndRecv() (*emptypb.Empty, error)
grpc.ClientStream grpc.ClientStream
} }
@ -509,18 +509,18 @@ func (x *vagrantRestoreSnapshotClient) Send(m *RestoreSnapshotRequest) error {
return x.ClientStream.SendMsg(m) return x.ClientStream.SendMsg(m)
} }
func (x *vagrantRestoreSnapshotClient) CloseAndRecv() (*empty.Empty, error) { func (x *vagrantRestoreSnapshotClient) CloseAndRecv() (*emptypb.Empty, error) {
if err := x.ClientStream.CloseSend(); err != nil { if err := x.ClientStream.CloseSend(); err != nil {
return nil, err return nil, err
} }
m := new(empty.Empty) m := new(emptypb.Empty)
if err := x.ClientStream.RecvMsg(m); err != nil { if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err return nil, err
} }
return m, nil return m, nil
} }
func (c *vagrantClient) BootstrapToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) { func (c *vagrantClient) BootstrapToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) {
out := new(NewTokenResponse) out := new(NewTokenResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/BootstrapToken", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/BootstrapToken", in, out, opts...)
if err != nil { if err != nil {
@ -538,7 +538,7 @@ func (c *vagrantClient) GenerateInviteToken(ctx context.Context, in *InviteToken
return out, nil return out, nil
} }
func (c *vagrantClient) GenerateLoginToken(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) { func (c *vagrantClient) GenerateLoginToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) {
out := new(NewTokenResponse) out := new(NewTokenResponse)
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GenerateLoginToken", in, out, opts...) err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GenerateLoginToken", in, out, opts...)
if err != nil { if err != nil {
@ -625,11 +625,11 @@ type VagrantServer interface {
// GetVersionInfo returns information about the server. This RPC call does // GetVersionInfo returns information about the server. This RPC call does
// NOT require authentication. It can be used by clients to determine if they // NOT require authentication. It can be used by clients to determine if they
// are capable of talking to this server. // are capable of talking to this server.
GetVersionInfo(context.Context, *empty.Empty) (*GetVersionInfoResponse, error) GetVersionInfo(context.Context, *emptypb.Empty) (*GetVersionInfoResponse, error)
UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error) UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error)
GetBasis(context.Context, *GetBasisRequest) (*GetBasisResponse, error) GetBasis(context.Context, *GetBasisRequest) (*GetBasisResponse, error)
FindBasis(context.Context, *FindBasisRequest) (*FindBasisResponse, error) FindBasis(context.Context, *FindBasisRequest) (*FindBasisResponse, error)
ListBasis(context.Context, *empty.Empty) (*ListBasisResponse, error) ListBasis(context.Context, *emptypb.Empty) (*ListBasisResponse, error)
// ListTasks returns the tasks. // ListTasks returns the tasks.
ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
// GetTask returns a task // GetTask returns a task
@ -647,14 +647,14 @@ type VagrantServer interface {
// ListProjects returns a list of all the projects. There is no equivalent // ListProjects returns a list of all the projects. There is no equivalent
// ListApplications because applications are a part of projects and you // ListApplications because applications are a part of projects and you
// can use GetProject to get more information about the project. // can use GetProject to get more information about the project.
ListProjects(context.Context, *empty.Empty) (*ListProjectsResponse, error) ListProjects(context.Context, *emptypb.Empty) (*ListProjectsResponse, error)
// UpsertTarget upserts a target with a project. If the target // UpsertTarget upserts a target with a project. If the target
// is already registered this does nothing. // is already registered this does nothing.
UpsertTarget(context.Context, *UpsertTargetRequest) (*UpsertTargetResponse, error) UpsertTarget(context.Context, *UpsertTargetRequest) (*UpsertTargetResponse, error)
DeleteTarget(context.Context, *DeleteTargetRequest) (*empty.Empty, error) DeleteTarget(context.Context, *DeleteTargetRequest) (*emptypb.Empty, error)
GetTarget(context.Context, *GetTargetRequest) (*GetTargetResponse, error) GetTarget(context.Context, *GetTargetRequest) (*GetTargetResponse, error)
FindTarget(context.Context, *FindTargetRequest) (*FindTargetResponse, error) FindTarget(context.Context, *FindTargetRequest) (*FindTargetResponse, error)
ListTargets(context.Context, *empty.Empty) (*ListTargetsResponse, error) ListTargets(context.Context, *emptypb.Empty) (*ListTargetsResponse, error)
// GetLogStream reads the log stream for a deployment. This will immediately // 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 // 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. // available lines this will NOT block and instead will return an error.
@ -676,7 +676,7 @@ type VagrantServer interface {
// //
// This RPC always returns immediately. You must use GetJob or GetJobStream // This RPC always returns immediately. You must use GetJob or GetJobStream
// to wait on the status of the cancellation. // to wait on the status of the cancellation.
CancelJob(context.Context, *CancelJobRequest) (*empty.Empty, error) CancelJob(context.Context, *CancelJobRequest) (*emptypb.Empty, error)
// GetJob queries a job by ID. // GetJob queries a job by ID.
GetJob(context.Context, *GetJobRequest) (*Job, error) GetJob(context.Context, *GetJobRequest) (*Job, error)
// INTERNAL: ListJobs lists all the jobs the server has processed. This // INTERNAL: ListJobs lists all the jobs the server has processed. This
@ -691,15 +691,15 @@ type VagrantServer interface {
// Multiple listeners can open a job stream. // Multiple listeners can open a job stream.
GetJobStream(*GetJobStreamRequest, Vagrant_GetJobStreamServer) error GetJobStream(*GetJobStreamRequest, Vagrant_GetJobStreamServer) error
// Clean out old jobs from the job database // Clean out old jobs from the job database
PruneOldJobs(context.Context, *empty.Empty) (*empty.Empty, error) PruneOldJobs(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
// GetRunner gets information about a single runner. // GetRunner gets information about a single runner.
GetRunner(context.Context, *GetRunnerRequest) (*Runner, error) GetRunner(context.Context, *GetRunnerRequest) (*Runner, error)
// GetServerConfig sets configuration for the Vagrant server. // GetServerConfig sets configuration for the Vagrant server.
GetServerConfig(context.Context, *empty.Empty) (*GetServerConfigResponse, error) GetServerConfig(context.Context, *emptypb.Empty) (*GetServerConfigResponse, error)
// SetServerConfig sets configuration for the Vagrant server. // SetServerConfig sets configuration for the Vagrant server.
SetServerConfig(context.Context, *SetServerConfigRequest) (*empty.Empty, error) SetServerConfig(context.Context, *SetServerConfigRequest) (*emptypb.Empty, error)
// CreateSnapshot creates a new database snapshot. // CreateSnapshot creates a new database snapshot.
CreateSnapshot(*empty.Empty, Vagrant_CreateSnapshotServer) error CreateSnapshot(*emptypb.Empty, Vagrant_CreateSnapshotServer) error
// RestoreSnapshot performs a database restore with the given snapshot. // RestoreSnapshot performs a database restore with the given snapshot.
// This API doesn't do a full online restore, it only stages the restore // 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 // for the next server start to finalize the restore. See the arguments for
@ -708,11 +708,11 @@ type VagrantServer interface {
// BootstrapToken returns the initial token for the server. This can only // BootstrapToken returns the initial token for the server. This can only
// be requested once on first startup. After initial request this will // be requested once on first startup. After initial request this will
// always return a PermissionDenied error. // always return a PermissionDenied error.
BootstrapToken(context.Context, *empty.Empty) (*NewTokenResponse, error) BootstrapToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error)
// Generate a new invite token that users can exchange for a login token. // Generate a new invite token that users can exchange for a login token.
GenerateInviteToken(context.Context, *InviteTokenRequest) (*NewTokenResponse, error) GenerateInviteToken(context.Context, *InviteTokenRequest) (*NewTokenResponse, error)
// Generate a new login token that users can use to login directly. // Generate a new login token that users can use to login directly.
GenerateLoginToken(context.Context, *empty.Empty) (*NewTokenResponse, error) GenerateLoginToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error)
// Exchange a invite token for a login token. // Exchange a invite token for a login token.
ConvertInviteToken(context.Context, *ConvertInviteTokenRequest) (*NewTokenResponse, error) ConvertInviteToken(context.Context, *ConvertInviteTokenRequest) (*NewTokenResponse, error)
// RunnerConfig is called to register a runner and receive the configuration // RunnerConfig is called to register a runner and receive the configuration
@ -728,7 +728,7 @@ type VagrantServer interface {
type UnimplementedVagrantServer struct { type UnimplementedVagrantServer struct {
} }
func (UnimplementedVagrantServer) GetVersionInfo(context.Context, *empty.Empty) (*GetVersionInfoResponse, error) { func (UnimplementedVagrantServer) GetVersionInfo(context.Context, *emptypb.Empty) (*GetVersionInfoResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetVersionInfo not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetVersionInfo not implemented")
} }
func (UnimplementedVagrantServer) UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error) { func (UnimplementedVagrantServer) UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error) {
@ -740,7 +740,7 @@ func (UnimplementedVagrantServer) GetBasis(context.Context, *GetBasisRequest) (*
func (UnimplementedVagrantServer) FindBasis(context.Context, *FindBasisRequest) (*FindBasisResponse, error) { func (UnimplementedVagrantServer) FindBasis(context.Context, *FindBasisRequest) (*FindBasisResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method FindBasis not implemented") return nil, status.Errorf(codes.Unimplemented, "method FindBasis not implemented")
} }
func (UnimplementedVagrantServer) ListBasis(context.Context, *empty.Empty) (*ListBasisResponse, error) { func (UnimplementedVagrantServer) ListBasis(context.Context, *emptypb.Empty) (*ListBasisResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListBasis not implemented") return nil, status.Errorf(codes.Unimplemented, "method ListBasis not implemented")
} }
func (UnimplementedVagrantServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) { func (UnimplementedVagrantServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) {
@ -764,13 +764,13 @@ func (UnimplementedVagrantServer) GetProject(context.Context, *GetProjectRequest
func (UnimplementedVagrantServer) FindProject(context.Context, *FindProjectRequest) (*FindProjectResponse, error) { func (UnimplementedVagrantServer) FindProject(context.Context, *FindProjectRequest) (*FindProjectResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method FindProject not implemented") return nil, status.Errorf(codes.Unimplemented, "method FindProject not implemented")
} }
func (UnimplementedVagrantServer) ListProjects(context.Context, *empty.Empty) (*ListProjectsResponse, error) { func (UnimplementedVagrantServer) ListProjects(context.Context, *emptypb.Empty) (*ListProjectsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListProjects not implemented") return nil, status.Errorf(codes.Unimplemented, "method ListProjects not implemented")
} }
func (UnimplementedVagrantServer) UpsertTarget(context.Context, *UpsertTargetRequest) (*UpsertTargetResponse, error) { func (UnimplementedVagrantServer) UpsertTarget(context.Context, *UpsertTargetRequest) (*UpsertTargetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpsertTarget not implemented") return nil, status.Errorf(codes.Unimplemented, "method UpsertTarget not implemented")
} }
func (UnimplementedVagrantServer) DeleteTarget(context.Context, *DeleteTargetRequest) (*empty.Empty, error) { func (UnimplementedVagrantServer) DeleteTarget(context.Context, *DeleteTargetRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteTarget not implemented") return nil, status.Errorf(codes.Unimplemented, "method DeleteTarget not implemented")
} }
func (UnimplementedVagrantServer) GetTarget(context.Context, *GetTargetRequest) (*GetTargetResponse, error) { func (UnimplementedVagrantServer) GetTarget(context.Context, *GetTargetRequest) (*GetTargetResponse, error) {
@ -779,7 +779,7 @@ func (UnimplementedVagrantServer) GetTarget(context.Context, *GetTargetRequest)
func (UnimplementedVagrantServer) FindTarget(context.Context, *FindTargetRequest) (*FindTargetResponse, error) { func (UnimplementedVagrantServer) FindTarget(context.Context, *FindTargetRequest) (*FindTargetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method FindTarget not implemented") return nil, status.Errorf(codes.Unimplemented, "method FindTarget not implemented")
} }
func (UnimplementedVagrantServer) ListTargets(context.Context, *empty.Empty) (*ListTargetsResponse, error) { func (UnimplementedVagrantServer) ListTargets(context.Context, *emptypb.Empty) (*ListTargetsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListTargets not implemented") return nil, status.Errorf(codes.Unimplemented, "method ListTargets not implemented")
} }
func (UnimplementedVagrantServer) GetLogStream(*GetLogStreamRequest, Vagrant_GetLogStreamServer) error { func (UnimplementedVagrantServer) GetLogStream(*GetLogStreamRequest, Vagrant_GetLogStreamServer) error {
@ -794,7 +794,7 @@ func (UnimplementedVagrantServer) GetConfig(context.Context, *ConfigGetRequest)
func (UnimplementedVagrantServer) QueueJob(context.Context, *QueueJobRequest) (*QueueJobResponse, error) { func (UnimplementedVagrantServer) QueueJob(context.Context, *QueueJobRequest) (*QueueJobResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method QueueJob not implemented") return nil, status.Errorf(codes.Unimplemented, "method QueueJob not implemented")
} }
func (UnimplementedVagrantServer) CancelJob(context.Context, *CancelJobRequest) (*empty.Empty, error) { func (UnimplementedVagrantServer) CancelJob(context.Context, *CancelJobRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CancelJob not implemented") return nil, status.Errorf(codes.Unimplemented, "method CancelJob not implemented")
} }
func (UnimplementedVagrantServer) GetJob(context.Context, *GetJobRequest) (*Job, error) { func (UnimplementedVagrantServer) GetJob(context.Context, *GetJobRequest) (*Job, error) {
@ -809,31 +809,31 @@ func (UnimplementedVagrantServer) ValidateJob(context.Context, *ValidateJobReque
func (UnimplementedVagrantServer) GetJobStream(*GetJobStreamRequest, Vagrant_GetJobStreamServer) error { func (UnimplementedVagrantServer) GetJobStream(*GetJobStreamRequest, Vagrant_GetJobStreamServer) error {
return status.Errorf(codes.Unimplemented, "method GetJobStream not implemented") return status.Errorf(codes.Unimplemented, "method GetJobStream not implemented")
} }
func (UnimplementedVagrantServer) PruneOldJobs(context.Context, *empty.Empty) (*empty.Empty, error) { func (UnimplementedVagrantServer) PruneOldJobs(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method PruneOldJobs not implemented") return nil, status.Errorf(codes.Unimplemented, "method PruneOldJobs not implemented")
} }
func (UnimplementedVagrantServer) GetRunner(context.Context, *GetRunnerRequest) (*Runner, error) { func (UnimplementedVagrantServer) GetRunner(context.Context, *GetRunnerRequest) (*Runner, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetRunner not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetRunner not implemented")
} }
func (UnimplementedVagrantServer) GetServerConfig(context.Context, *empty.Empty) (*GetServerConfigResponse, error) { func (UnimplementedVagrantServer) GetServerConfig(context.Context, *emptypb.Empty) (*GetServerConfigResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetServerConfig not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetServerConfig not implemented")
} }
func (UnimplementedVagrantServer) SetServerConfig(context.Context, *SetServerConfigRequest) (*empty.Empty, error) { func (UnimplementedVagrantServer) SetServerConfig(context.Context, *SetServerConfigRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method SetServerConfig not implemented") return nil, status.Errorf(codes.Unimplemented, "method SetServerConfig not implemented")
} }
func (UnimplementedVagrantServer) CreateSnapshot(*empty.Empty, Vagrant_CreateSnapshotServer) error { func (UnimplementedVagrantServer) CreateSnapshot(*emptypb.Empty, Vagrant_CreateSnapshotServer) error {
return status.Errorf(codes.Unimplemented, "method CreateSnapshot not implemented") return status.Errorf(codes.Unimplemented, "method CreateSnapshot not implemented")
} }
func (UnimplementedVagrantServer) RestoreSnapshot(Vagrant_RestoreSnapshotServer) error { func (UnimplementedVagrantServer) RestoreSnapshot(Vagrant_RestoreSnapshotServer) error {
return status.Errorf(codes.Unimplemented, "method RestoreSnapshot not implemented") return status.Errorf(codes.Unimplemented, "method RestoreSnapshot not implemented")
} }
func (UnimplementedVagrantServer) BootstrapToken(context.Context, *empty.Empty) (*NewTokenResponse, error) { func (UnimplementedVagrantServer) BootstrapToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method BootstrapToken not implemented") return nil, status.Errorf(codes.Unimplemented, "method BootstrapToken not implemented")
} }
func (UnimplementedVagrantServer) GenerateInviteToken(context.Context, *InviteTokenRequest) (*NewTokenResponse, error) { func (UnimplementedVagrantServer) GenerateInviteToken(context.Context, *InviteTokenRequest) (*NewTokenResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GenerateInviteToken not implemented") return nil, status.Errorf(codes.Unimplemented, "method GenerateInviteToken not implemented")
} }
func (UnimplementedVagrantServer) GenerateLoginToken(context.Context, *empty.Empty) (*NewTokenResponse, error) { func (UnimplementedVagrantServer) GenerateLoginToken(context.Context, *emptypb.Empty) (*NewTokenResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GenerateLoginToken not implemented") return nil, status.Errorf(codes.Unimplemented, "method GenerateLoginToken not implemented")
} }
func (UnimplementedVagrantServer) ConvertInviteToken(context.Context, *ConvertInviteTokenRequest) (*NewTokenResponse, error) { func (UnimplementedVagrantServer) ConvertInviteToken(context.Context, *ConvertInviteTokenRequest) (*NewTokenResponse, error) {
@ -858,7 +858,7 @@ func RegisterVagrantServer(s grpc.ServiceRegistrar, srv VagrantServer) {
} }
func _Vagrant_GetVersionInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _Vagrant_GetVersionInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -870,7 +870,7 @@ func _Vagrant_GetVersionInfo_Handler(srv interface{}, ctx context.Context, dec f
FullMethod: "/hashicorp.vagrant.Vagrant/GetVersionInfo", FullMethod: "/hashicorp.vagrant.Vagrant/GetVersionInfo",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).GetVersionInfo(ctx, req.(*empty.Empty)) return srv.(VagrantServer).GetVersionInfo(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -930,7 +930,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) { func _Vagrant_ListBasis_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -942,7 +942,7 @@ func _Vagrant_ListBasis_Handler(srv interface{}, ctx context.Context, dec func(i
FullMethod: "/hashicorp.vagrant.Vagrant/ListBasis", FullMethod: "/hashicorp.vagrant.Vagrant/ListBasis",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).ListBasis(ctx, req.(*empty.Empty)) return srv.(VagrantServer).ListBasis(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -1074,7 +1074,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) { func _Vagrant_ListProjects_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -1086,7 +1086,7 @@ func _Vagrant_ListProjects_Handler(srv interface{}, ctx context.Context, dec fun
FullMethod: "/hashicorp.vagrant.Vagrant/ListProjects", FullMethod: "/hashicorp.vagrant.Vagrant/ListProjects",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).ListProjects(ctx, req.(*empty.Empty)) return srv.(VagrantServer).ListProjects(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -1164,7 +1164,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) { func _Vagrant_ListTargets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -1176,7 +1176,7 @@ func _Vagrant_ListTargets_Handler(srv interface{}, ctx context.Context, dec func
FullMethod: "/hashicorp.vagrant.Vagrant/ListTargets", FullMethod: "/hashicorp.vagrant.Vagrant/ListTargets",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).ListTargets(ctx, req.(*empty.Empty)) return srv.(VagrantServer).ListTargets(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -1350,7 +1350,7 @@ func (x *vagrantGetJobStreamServer) Send(m *GetJobStreamResponse) error {
} }
func _Vagrant_PruneOldJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _Vagrant_PruneOldJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -1362,7 +1362,7 @@ func _Vagrant_PruneOldJobs_Handler(srv interface{}, ctx context.Context, dec fun
FullMethod: "/hashicorp.vagrant.Vagrant/PruneOldJobs", FullMethod: "/hashicorp.vagrant.Vagrant/PruneOldJobs",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).PruneOldJobs(ctx, req.(*empty.Empty)) return srv.(VagrantServer).PruneOldJobs(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -1386,7 +1386,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) { func _Vagrant_GetServerConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -1398,7 +1398,7 @@ func _Vagrant_GetServerConfig_Handler(srv interface{}, ctx context.Context, dec
FullMethod: "/hashicorp.vagrant.Vagrant/GetServerConfig", FullMethod: "/hashicorp.vagrant.Vagrant/GetServerConfig",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).GetServerConfig(ctx, req.(*empty.Empty)) return srv.(VagrantServer).GetServerConfig(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -1422,7 +1422,7 @@ func _Vagrant_SetServerConfig_Handler(srv interface{}, ctx context.Context, dec
} }
func _Vagrant_CreateSnapshot_Handler(srv interface{}, stream grpc.ServerStream) error { func _Vagrant_CreateSnapshot_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(empty.Empty) m := new(emptypb.Empty)
if err := stream.RecvMsg(m); err != nil { if err := stream.RecvMsg(m); err != nil {
return err return err
} }
@ -1447,7 +1447,7 @@ func _Vagrant_RestoreSnapshot_Handler(srv interface{}, stream grpc.ServerStream)
} }
type Vagrant_RestoreSnapshotServer interface { type Vagrant_RestoreSnapshotServer interface {
SendAndClose(*empty.Empty) error SendAndClose(*emptypb.Empty) error
Recv() (*RestoreSnapshotRequest, error) Recv() (*RestoreSnapshotRequest, error)
grpc.ServerStream grpc.ServerStream
} }
@ -1456,7 +1456,7 @@ type vagrantRestoreSnapshotServer struct {
grpc.ServerStream grpc.ServerStream
} }
func (x *vagrantRestoreSnapshotServer) SendAndClose(m *empty.Empty) error { func (x *vagrantRestoreSnapshotServer) SendAndClose(m *emptypb.Empty) error {
return x.ServerStream.SendMsg(m) return x.ServerStream.SendMsg(m)
} }
@ -1469,7 +1469,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) { func _Vagrant_BootstrapToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -1481,7 +1481,7 @@ func _Vagrant_BootstrapToken_Handler(srv interface{}, ctx context.Context, dec f
FullMethod: "/hashicorp.vagrant.Vagrant/BootstrapToken", FullMethod: "/hashicorp.vagrant.Vagrant/BootstrapToken",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).BootstrapToken(ctx, req.(*empty.Empty)) return srv.(VagrantServer).BootstrapToken(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -1505,7 +1505,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) { func _Vagrant_GenerateLoginToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty) in := new(emptypb.Empty)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -1517,7 +1517,7 @@ func _Vagrant_GenerateLoginToken_Handler(srv interface{}, ctx context.Context, d
FullMethod: "/hashicorp.vagrant.Vagrant/GenerateLoginToken", FullMethod: "/hashicorp.vagrant.Vagrant/GenerateLoginToken",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(VagrantServer).GenerateLoginToken(ctx, req.(*empty.Empty)) return srv.(VagrantServer).GenerateLoginToken(ctx, req.(*emptypb.Empty))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }

6
lib/vagrant/protobufs/proto/vagrant_plugin_sdk/plugin_pb.rb
View File

@ -139,7 +139,10 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
optional :target, :string, 3 optional :target, :string, 3
end end
add_message "hashicorp.vagrant.sdk.Args.NamedCapability" do add_message "hashicorp.vagrant.sdk.Args.NamedCapability" do
optional :Capability, :string, 1 optional :capability, :string, 1
end
add_message "hashicorp.vagrant.sdk.Args.Direct" do
repeated :list, :message, 1, "google.protobuf.Any"
end end
add_message "hashicorp.vagrant.sdk.BoxCollection" do add_message "hashicorp.vagrant.sdk.BoxCollection" do
optional :directory, :string, 1 optional :directory, :string, 1
@ -756,6 +759,7 @@ module Hashicorp
Args::SyncedFolder = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.SyncedFolder").msgclass Args::SyncedFolder = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.SyncedFolder").msgclass
Args::TargetIndex = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.TargetIndex").msgclass Args::TargetIndex = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.TargetIndex").msgclass
Args::NamedCapability = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.NamedCapability").msgclass Args::NamedCapability = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.NamedCapability").msgclass
Args::Direct = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Direct").msgclass
BoxCollection = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.BoxCollection").msgclass BoxCollection = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.BoxCollection").msgclass
SSHInfo = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.SSHInfo").msgclass SSHInfo = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.SSHInfo").msgclass
WinrmInfo = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.WinrmInfo").msgclass WinrmInfo = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.WinrmInfo").msgclass

4
lib/vagrant/protobufs/proto/vagrant_plugin_sdk/plugin_services_pb.rb
View File

@ -254,6 +254,8 @@ module Hashicorp
rpc :HasCapabilitySpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec rpc :HasCapabilitySpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec
rpc :Parents, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Hashicorp::Vagrant::Sdk::Platform::ParentsResp rpc :Parents, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Hashicorp::Vagrant::Sdk::Platform::ParentsResp
rpc :ParentsSpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec rpc :ParentsSpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec
rpc :Seed, ::Hashicorp::Vagrant::Sdk::Args::Direct, ::Google::Protobuf::Empty
rpc :Seeds, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::Args::Direct
end end
Stub = Service.rpc_stub_class Stub = Service.rpc_stub_class
@ -278,6 +280,8 @@ module Hashicorp
rpc :HasCapabilitySpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec rpc :HasCapabilitySpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec
rpc :Parents, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Hashicorp::Vagrant::Sdk::Platform::ParentsResp rpc :Parents, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Hashicorp::Vagrant::Sdk::Platform::ParentsResp
rpc :ParentsSpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec rpc :ParentsSpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec
rpc :Seed, ::Hashicorp::Vagrant::Sdk::Args::Direct, ::Google::Protobuf::Empty
rpc :Seeds, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::Args::Direct
end end
Stub = Service.rpc_stub_class Stub = Service.rpc_stub_class