Generated proto updates
This commit is contained in:
Chris Roberts
Paul Hinze
parent
9e58090d09
commit
2acd0fa3b8
@ -1,18 +1,18 @@
|
||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.23.0
|
||||
// protoc v3.13.0
|
||||
// protoc-gen-go v1.25.0
|
||||
// protoc v3.18.1
|
||||
// source: proto/ruby_vagrant/ruby-server.proto
|
||||
|
||||
package ruby_vagrant
|
||||
|
||||
import (
|
||||
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"
|
||||
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
||||
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
||||
_ "google.golang.org/protobuf/types/known/anypb"
|
||||
emptypb "google.golang.org/protobuf/types/known/emptypb"
|
||||
reflect "reflect"
|
||||
sync "sync"
|
||||
)
|
||||
@ -401,7 +401,7 @@ var file_proto_ruby_vagrant_ruby_server_proto_goTypes = []interface{}{
|
||||
(*ParseVagrantfileRequest)(nil), // 3: hashicorp.vagrant.ParseVagrantfileRequest
|
||||
(*ParseVagrantfileResponse)(nil), // 4: hashicorp.vagrant.ParseVagrantfileResponse
|
||||
(*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{
|
||||
2, // 0: hashicorp.vagrant.GetPluginsResponse.plugins:type_name -> hashicorp.vagrant.Plugin
|
||||
|
||||
@ -4,10 +4,10 @@ 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
|
||||
@ -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.
|
||||
type RubyVagrantClient interface {
|
||||
// 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)
|
||||
}
|
||||
|
||||
@ -32,7 +32,7 @@ func NewRubyVagrantClient(cc grpc.ClientConnInterface) RubyVagrantClient {
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.RubyVagrant/GetPlugins", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -55,7 +55,7 @@ func (c *rubyVagrantClient) ParseVagrantfile(ctx context.Context, in *ParseVagra
|
||||
// for forward compatibility
|
||||
type RubyVagrantServer interface {
|
||||
// Gets available ruby plugins
|
||||
GetPlugins(context.Context, *empty.Empty) (*GetPluginsResponse, error)
|
||||
GetPlugins(context.Context, *emptypb.Empty) (*GetPluginsResponse, error)
|
||||
ParseVagrantfile(context.Context, *ParseVagrantfileRequest) (*ParseVagrantfileResponse, error)
|
||||
mustEmbedUnimplementedRubyVagrantServer()
|
||||
}
|
||||
@ -64,7 +64,7 @@ type RubyVagrantServer interface {
|
||||
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")
|
||||
}
|
||||
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) {
|
||||
in := new(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -96,7 +96,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.(*empty.Empty))
|
||||
return srv.(RubyVagrantServer).GetPlugins(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
@ -1,21 +1,21 @@
|
||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// versions:
|
||||
// protoc-gen-go v1.23.0
|
||||
// protoc v3.13.0
|
||||
// protoc-gen-go v1.25.0
|
||||
// protoc v3.18.1
|
||||
// source: proto/vagrant_server/server.proto
|
||||
|
||||
package vagrant_server
|
||||
|
||||
import (
|
||||
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"
|
||||
status "google.golang.org/genproto/googleapis/rpc/status"
|
||||
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"
|
||||
_ "google.golang.org/protobuf/types/known/structpb"
|
||||
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
||||
reflect "reflect"
|
||||
sync "sync"
|
||||
)
|
||||
@ -951,7 +951,7 @@ type Box struct {
|
||||
// The box name. This is the logical name used when adding the box.
|
||||
Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
|
||||
// Tracks the last automatic update for the box
|
||||
LastUpdate *timestamp.Timestamp `protobuf:"bytes,8,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
|
||||
LastUpdate *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
|
||||
}
|
||||
|
||||
func (x *Box) Reset() {
|
||||
@ -1035,7 +1035,7 @@ func (x *Box) GetName() string {
|
||||
return ""
|
||||
}
|
||||
|
||||
func (x *Box) GetLastUpdate() *timestamp.Timestamp {
|
||||
func (x *Box) GetLastUpdate() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.LastUpdate
|
||||
}
|
||||
@ -1068,7 +1068,7 @@ type Target struct {
|
||||
// Serialized configuration of the target (Vagrantfile)
|
||||
Configuration *vagrant_plugin_sdk.Vagrantfile_MachineConfig `protobuf:"bytes,10,opt,name=configuration,proto3" json:"configuration,omitempty"`
|
||||
// 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 string `protobuf:"bytes,12,opt,name=provider,proto3" json:"provider,omitempty"`
|
||||
// If true, then the `-remote` flag or the `vagrant build project/app`
|
||||
@ -1185,7 +1185,7 @@ func (x *Target) GetConfiguration() *vagrant_plugin_sdk.Vagrantfile_MachineConfi
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Target) GetRecord() *any.Any {
|
||||
func (x *Target) GetRecord() *anypb.Any {
|
||||
if x != nil {
|
||||
return x.Record
|
||||
}
|
||||
@ -1402,9 +1402,9 @@ type Status struct {
|
||||
// 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"`
|
||||
// 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).
|
||||
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() {
|
||||
@ -1460,14 +1460,14 @@ func (x *Status) GetError() *status.Status {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Status) GetStartTime() *timestamp.Timestamp {
|
||||
func (x *Status) GetStartTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.StartTime
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Status) GetCompleteTime() *timestamp.Timestamp {
|
||||
func (x *Status) GetCompleteTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.CompleteTime
|
||||
}
|
||||
@ -1965,10 +1965,10 @@ type Job struct {
|
||||
// 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"`
|
||||
// The time when the job was queued.
|
||||
QueueTime *timestamp.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"`
|
||||
AckTime *timestamp.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"`
|
||||
QueueTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=queue_time,json=queueTime,proto3" json:"queue_time,omitempty"`
|
||||
AssignTime *timestamppb.Timestamp `protobuf:"bytes,103,opt,name=assign_time,json=assignTime,proto3" json:"assign_time,omitempty"`
|
||||
AckTime *timestamppb.Timestamp `protobuf:"bytes,104,opt,name=ack_time,json=ackTime,proto3" json:"ack_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 *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
|
||||
@ -1978,12 +1978,12 @@ type Job struct {
|
||||
// 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
|
||||
// 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
|
||||
// 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
|
||||
// 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() {
|
||||
@ -2137,28 +2137,28 @@ func (x *Job) GetAssignedRunner() *Ref_RunnerId {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Job) GetQueueTime() *timestamp.Timestamp {
|
||||
func (x *Job) GetQueueTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.QueueTime
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Job) GetAssignTime() *timestamp.Timestamp {
|
||||
func (x *Job) GetAssignTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.AssignTime
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Job) GetAckTime() *timestamp.Timestamp {
|
||||
func (x *Job) GetAckTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.AckTime
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Job) GetCompleteTime() *timestamp.Timestamp {
|
||||
func (x *Job) GetCompleteTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.CompleteTime
|
||||
}
|
||||
@ -2179,14 +2179,14 @@ func (x *Job) GetResult() *Job_Result {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Job) GetCancelTime() *timestamp.Timestamp {
|
||||
func (x *Job) GetCancelTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.CancelTime
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Job) GetExpireTime() *timestamp.Timestamp {
|
||||
func (x *Job) GetExpireTime() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.ExpireTime
|
||||
}
|
||||
@ -6098,7 +6098,7 @@ type Token struct {
|
||||
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 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.
|
||||
Login bool `protobuf:"varint,4,opt,name=login,proto3" json:"login,omitempty"`
|
||||
// Inidicates whether or not this token can be used as an invite.
|
||||
@ -6154,7 +6154,7 @@ func (x *Token) GetTokenId() []byte {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *Token) GetValidUntil() *timestamp.Timestamp {
|
||||
func (x *Token) GetValidUntil() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.ValidUntil
|
||||
}
|
||||
@ -9669,7 +9669,7 @@ type GetJobStreamResponse_Terminal_Event struct {
|
||||
// timestamp of the event as seen by the runner. This might be
|
||||
// skewed from the server or the client but relative to all other
|
||||
// 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:
|
||||
// *GetJobStreamResponse_Terminal_Event_Line_
|
||||
// *GetJobStreamResponse_Terminal_Event_Status_
|
||||
@ -9713,7 +9713,7 @@ func (*GetJobStreamResponse_Terminal_Event) Descriptor() ([]byte, []int) {
|
||||
return file_proto_vagrant_server_server_proto_rawDescGZIP(), []int{24, 2, 0}
|
||||
}
|
||||
|
||||
func (x *GetJobStreamResponse_Terminal_Event) GetTimestamp() *timestamp.Timestamp {
|
||||
func (x *GetJobStreamResponse_Terminal_Event) GetTimestamp() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.Timestamp
|
||||
}
|
||||
@ -9819,7 +9819,8 @@ func (*GetJobStreamResponse_Terminal_Event_Raw_) isGetJobStreamResponse_Terminal
|
||||
|
||||
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() {}
|
||||
|
||||
@ -10816,7 +10817,7 @@ type LogBatch_Entry struct {
|
||||
sizeCache protoimpl.SizeCache
|
||||
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"`
|
||||
}
|
||||
|
||||
@ -10852,7 +10853,7 @@ func (*LogBatch_Entry) Descriptor() ([]byte, []int) {
|
||||
return file_proto_vagrant_server_server_proto_rawDescGZIP(), []int{68, 0}
|
||||
}
|
||||
|
||||
func (x *LogBatch_Entry) GetTimestamp() *timestamp.Timestamp {
|
||||
func (x *LogBatch_Entry) GetTimestamp() *timestamppb.Timestamp {
|
||||
if x != nil {
|
||||
return x.Timestamp
|
||||
}
|
||||
@ -13874,15 +13875,15 @@ var file_proto_vagrant_server_server_proto_goTypes = []interface{}{
|
||||
(*vagrant_plugin_sdk.Vagrantfile_Vagrantfile)(nil), // 197: hashicorp.vagrant.sdk.Vagrantfile.Vagrantfile
|
||||
(*vagrant_plugin_sdk.Ref_Target)(nil), // 198: hashicorp.vagrant.sdk.Ref.Target
|
||||
(*vagrant_plugin_sdk.Ref_Basis)(nil), // 199: hashicorp.vagrant.sdk.Ref.Basis
|
||||
(*timestamp.Timestamp)(nil), // 200: google.protobuf.Timestamp
|
||||
(*timestamppb.Timestamp)(nil), // 200: google.protobuf.Timestamp
|
||||
(*vagrant_plugin_sdk.Args_DataDir_Target)(nil), // 201: hashicorp.vagrant.sdk.Args.DataDir.Target
|
||||
(*vagrant_plugin_sdk.Vagrantfile_MachineConfig)(nil), // 202: hashicorp.vagrant.sdk.Vagrantfile.MachineConfig
|
||||
(*any.Any)(nil), // 203: google.protobuf.Any
|
||||
(*anypb.Any)(nil), // 203: google.protobuf.Any
|
||||
(*status.Status)(nil), // 204: google.rpc.Status
|
||||
(*vagrant_plugin_sdk.Ref_Box)(nil), // 205: hashicorp.vagrant.sdk.Ref.Box
|
||||
(*vagrant_plugin_sdk.Command_Arguments)(nil), // 206: hashicorp.vagrant.sdk.Command.Arguments
|
||||
(*vagrant_plugin_sdk.Args_Target_Machine_State)(nil), // 207: hashicorp.vagrant.sdk.Args.Target.Machine.State
|
||||
(*empty.Empty)(nil), // 208: google.protobuf.Empty
|
||||
(*emptypb.Empty)(nil), // 208: google.protobuf.Empty
|
||||
}
|
||||
var file_proto_vagrant_server_server_proto_depIdxs = []int32{
|
||||
11, // 0: hashicorp.vagrant.GetVersionInfoResponse.info:type_name -> hashicorp.vagrant.VersionInfo
|
||||
|
||||
@ -4,10 +4,10 @@ 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
|
||||
@ -22,11 +22,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 *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)
|
||||
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 *empty.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error)
|
||||
ListBasis(ctx context.Context, in *emptypb.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,19 +44,19 @@ 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 *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
|
||||
// is already registered this does nothing.
|
||||
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)
|
||||
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)
|
||||
// CRUD operations for box
|
||||
UpsertBox(ctx context.Context, in *UpsertBoxRequest, opts ...grpc.CallOption) (*UpsertBoxResponse, error)
|
||||
DeleteBox(ctx context.Context, in *DeleteBoxRequest, opts ...grpc.CallOption) (*empty.Empty, error)
|
||||
DeleteBox(ctx context.Context, in *DeleteBoxRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
GetBox(ctx context.Context, in *GetBoxRequest, opts ...grpc.CallOption) (*GetBoxResponse, error)
|
||||
ListBoxes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListBoxesResponse, error)
|
||||
ListBoxes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBoxesResponse, error)
|
||||
FindBox(ctx context.Context, in *FindBoxRequest, opts ...grpc.CallOption) (*FindBoxResponse, 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
|
||||
@ -79,7 +79,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) (*empty.Empty, error)
|
||||
CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*emptypb.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
|
||||
@ -94,15 +94,15 @@ type VagrantClient interface {
|
||||
// Multiple listeners can open a job stream.
|
||||
GetJobStream(ctx context.Context, in *GetJobStreamRequest, opts ...grpc.CallOption) (Vagrant_GetJobStreamClient, error)
|
||||
// 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(ctx context.Context, in *GetRunnerRequest, opts ...grpc.CallOption) (*Runner, error)
|
||||
// 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(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(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.
|
||||
// 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
|
||||
@ -111,11 +111,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 *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.
|
||||
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 *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.
|
||||
ConvertInviteToken(ctx context.Context, in *ConvertInviteTokenRequest, opts ...grpc.CallOption) (*NewTokenResponse, error)
|
||||
// RunnerConfig is called to register a runner and receive the configuration
|
||||
@ -135,7 +135,7 @@ func NewVagrantClient(cc grpc.ClientConnInterface) VagrantClient {
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetVersionInfo", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -171,7 +171,7 @@ func (c *vagrantClient) FindBasis(ctx context.Context, in *FindBasisRequest, opt
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListBasis", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -243,7 +243,7 @@ func (c *vagrantClient) FindProject(ctx context.Context, in *FindProjectRequest,
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListProjects", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -261,8 +261,8 @@ func (c *vagrantClient) UpsertTarget(ctx context.Context, in *UpsertTargetReques
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) DeleteTarget(ctx context.Context, in *DeleteTargetRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *vagrantClient) DeleteTarget(ctx context.Context, in *DeleteTargetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/DeleteTarget", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -288,7 +288,7 @@ func (c *vagrantClient) FindTarget(ctx context.Context, in *FindTargetRequest, o
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListTargets", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -306,8 +306,8 @@ func (c *vagrantClient) UpsertBox(ctx context.Context, in *UpsertBoxRequest, opt
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) DeleteBox(ctx context.Context, in *DeleteBoxRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *vagrantClient) DeleteBox(ctx context.Context, in *DeleteBoxRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/DeleteBox", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -324,7 +324,7 @@ func (c *vagrantClient) GetBox(ctx context.Context, in *GetBoxRequest, opts ...g
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) ListBoxes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListBoxesResponse, error) {
|
||||
func (c *vagrantClient) ListBoxes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBoxesResponse, error) {
|
||||
out := new(ListBoxesResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListBoxes", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -401,8 +401,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) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *vagrantClient) CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/CancelJob", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -469,8 +469,8 @@ func (x *vagrantGetJobStreamClient) Recv() (*GetJobStreamResponse, error) {
|
||||
return m, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) PruneOldJobs(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *vagrantClient) PruneOldJobs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/PruneOldJobs", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -487,7 +487,7 @@ func (c *vagrantClient) GetRunner(ctx context.Context, in *GetRunnerRequest, opt
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetServerConfig", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -496,8 +496,8 @@ func (c *vagrantClient) GetServerConfig(ctx context.Context, in *empty.Empty, op
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
|
||||
out := new(empty.Empty)
|
||||
func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
|
||||
out := new(emptypb.Empty)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/SetServerConfig", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -505,7 +505,7 @@ func (c *vagrantClient) SetServerConfig(ctx context.Context, in *SetServerConfig
|
||||
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...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -548,7 +548,7 @@ func (c *vagrantClient) RestoreSnapshot(ctx context.Context, opts ...grpc.CallOp
|
||||
|
||||
type Vagrant_RestoreSnapshotClient interface {
|
||||
Send(*RestoreSnapshotRequest) error
|
||||
CloseAndRecv() (*empty.Empty, error)
|
||||
CloseAndRecv() (*emptypb.Empty, error)
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
@ -560,18 +560,18 @@ func (x *vagrantRestoreSnapshotClient) Send(m *RestoreSnapshotRequest) error {
|
||||
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 {
|
||||
return nil, err
|
||||
}
|
||||
m := new(empty.Empty)
|
||||
m := new(emptypb.Empty)
|
||||
if err := x.ClientStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/BootstrapToken", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -589,7 +589,7 @@ func (c *vagrantClient) GenerateInviteToken(ctx context.Context, in *InviteToken
|
||||
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)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GenerateLoginToken", in, out, opts...)
|
||||
if err != nil {
|
||||
@ -676,11 +676,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, *empty.Empty) (*GetVersionInfoResponse, error)
|
||||
GetVersionInfo(context.Context, *emptypb.Empty) (*GetVersionInfoResponse, error)
|
||||
UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error)
|
||||
GetBasis(context.Context, *GetBasisRequest) (*GetBasisResponse, 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(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
|
||||
// GetTask returns a task
|
||||
@ -698,19 +698,19 @@ 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, *empty.Empty) (*ListProjectsResponse, error)
|
||||
ListProjects(context.Context, *emptypb.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)
|
||||
DeleteTarget(context.Context, *DeleteTargetRequest) (*empty.Empty, error)
|
||||
DeleteTarget(context.Context, *DeleteTargetRequest) (*emptypb.Empty, error)
|
||||
GetTarget(context.Context, *GetTargetRequest) (*GetTargetResponse, error)
|
||||
FindTarget(context.Context, *FindTargetRequest) (*FindTargetResponse, error)
|
||||
ListTargets(context.Context, *empty.Empty) (*ListTargetsResponse, error)
|
||||
ListTargets(context.Context, *emptypb.Empty) (*ListTargetsResponse, error)
|
||||
// CRUD operations for box
|
||||
UpsertBox(context.Context, *UpsertBoxRequest) (*UpsertBoxResponse, error)
|
||||
DeleteBox(context.Context, *DeleteBoxRequest) (*empty.Empty, error)
|
||||
DeleteBox(context.Context, *DeleteBoxRequest) (*emptypb.Empty, error)
|
||||
GetBox(context.Context, *GetBoxRequest) (*GetBoxResponse, error)
|
||||
ListBoxes(context.Context, *empty.Empty) (*ListBoxesResponse, error)
|
||||
ListBoxes(context.Context, *emptypb.Empty) (*ListBoxesResponse, error)
|
||||
FindBox(context.Context, *FindBoxRequest) (*FindBoxResponse, 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
|
||||
@ -733,7 +733,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) (*empty.Empty, error)
|
||||
CancelJob(context.Context, *CancelJobRequest) (*emptypb.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
|
||||
@ -748,15 +748,15 @@ type VagrantServer interface {
|
||||
// Multiple listeners can open a job stream.
|
||||
GetJobStream(*GetJobStreamRequest, Vagrant_GetJobStreamServer) error
|
||||
// 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(context.Context, *GetRunnerRequest) (*Runner, error)
|
||||
// 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(context.Context, *SetServerConfigRequest) (*empty.Empty, error)
|
||||
SetServerConfig(context.Context, *SetServerConfigRequest) (*emptypb.Empty, error)
|
||||
// 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.
|
||||
// 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
|
||||
@ -765,11 +765,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, *empty.Empty) (*NewTokenResponse, error)
|
||||
BootstrapToken(context.Context, *emptypb.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, *empty.Empty) (*NewTokenResponse, error)
|
||||
GenerateLoginToken(context.Context, *emptypb.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
|
||||
@ -785,7 +785,7 @@ type VagrantServer interface {
|
||||
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")
|
||||
}
|
||||
func (UnimplementedVagrantServer) UpsertBasis(context.Context, *UpsertBasisRequest) (*UpsertBasisResponse, error) {
|
||||
@ -797,7 +797,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, *empty.Empty) (*ListBasisResponse, error) {
|
||||
func (UnimplementedVagrantServer) ListBasis(context.Context, *emptypb.Empty) (*ListBasisResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListBasis not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) {
|
||||
@ -821,13 +821,13 @@ 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, *empty.Empty) (*ListProjectsResponse, error) {
|
||||
func (UnimplementedVagrantServer) ListProjects(context.Context, *emptypb.Empty) (*ListProjectsResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListProjects not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) UpsertTarget(context.Context, *UpsertTargetRequest) (*UpsertTargetResponse, error) {
|
||||
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")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetTarget(context.Context, *GetTargetRequest) (*GetTargetResponse, error) {
|
||||
@ -836,19 +836,19 @@ 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, *empty.Empty) (*ListTargetsResponse, error) {
|
||||
func (UnimplementedVagrantServer) ListTargets(context.Context, *emptypb.Empty) (*ListTargetsResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListTargets not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) UpsertBox(context.Context, *UpsertBoxRequest) (*UpsertBoxResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method UpsertBox not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) DeleteBox(context.Context, *DeleteBoxRequest) (*empty.Empty, error) {
|
||||
func (UnimplementedVagrantServer) DeleteBox(context.Context, *DeleteBoxRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method DeleteBox not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetBox(context.Context, *GetBoxRequest) (*GetBoxResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetBox not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ListBoxes(context.Context, *empty.Empty) (*ListBoxesResponse, error) {
|
||||
func (UnimplementedVagrantServer) ListBoxes(context.Context, *emptypb.Empty) (*ListBoxesResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListBoxes not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) FindBox(context.Context, *FindBoxRequest) (*FindBoxResponse, error) {
|
||||
@ -866,7 +866,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) (*empty.Empty, error) {
|
||||
func (UnimplementedVagrantServer) CancelJob(context.Context, *CancelJobRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method CancelJob not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetJob(context.Context, *GetJobRequest) (*Job, error) {
|
||||
@ -881,31 +881,31 @@ func (UnimplementedVagrantServer) ValidateJob(context.Context, *ValidateJobReque
|
||||
func (UnimplementedVagrantServer) GetJobStream(*GetJobStreamRequest, Vagrant_GetJobStreamServer) error {
|
||||
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")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetRunner(context.Context, *GetRunnerRequest) (*Runner, error) {
|
||||
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")
|
||||
}
|
||||
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")
|
||||
}
|
||||
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")
|
||||
}
|
||||
func (UnimplementedVagrantServer) RestoreSnapshot(Vagrant_RestoreSnapshotServer) error {
|
||||
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")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GenerateInviteToken(context.Context, *InviteTokenRequest) (*NewTokenResponse, error) {
|
||||
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")
|
||||
}
|
||||
func (UnimplementedVagrantServer) ConvertInviteToken(context.Context, *ConvertInviteTokenRequest) (*NewTokenResponse, error) {
|
||||
@ -930,7 +930,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) {
|
||||
in := new(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -942,7 +942,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.(*empty.Empty))
|
||||
return srv.(VagrantServer).GetVersionInfo(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1002,7 +1002,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(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1014,7 +1014,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.(*empty.Empty))
|
||||
return srv.(VagrantServer).ListBasis(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1146,7 +1146,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(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1158,7 +1158,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.(*empty.Empty))
|
||||
return srv.(VagrantServer).ListProjects(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1236,7 +1236,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(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1248,7 +1248,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.(*empty.Empty))
|
||||
return srv.(VagrantServer).ListTargets(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1308,7 +1308,7 @@ func _Vagrant_GetBox_Handler(srv interface{}, ctx context.Context, dec func(inte
|
||||
}
|
||||
|
||||
func _Vagrant_ListBoxes_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 {
|
||||
return nil, err
|
||||
}
|
||||
@ -1320,7 +1320,7 @@ func _Vagrant_ListBoxes_Handler(srv interface{}, ctx context.Context, dec func(i
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/ListBoxes",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).ListBoxes(ctx, req.(*empty.Empty))
|
||||
return srv.(VagrantServer).ListBoxes(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1512,7 +1512,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) {
|
||||
in := new(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1524,7 +1524,7 @@ func _Vagrant_PruneOldJobs_Handler(srv interface{}, ctx context.Context, dec fun
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/PruneOldJobs",
|
||||
}
|
||||
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)
|
||||
}
|
||||
@ -1548,7 +1548,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(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1560,7 +1560,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.(*empty.Empty))
|
||||
return srv.(VagrantServer).GetServerConfig(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1584,7 +1584,7 @@ func _Vagrant_SetServerConfig_Handler(srv interface{}, ctx context.Context, dec
|
||||
}
|
||||
|
||||
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 {
|
||||
return err
|
||||
}
|
||||
@ -1609,7 +1609,7 @@ func _Vagrant_RestoreSnapshot_Handler(srv interface{}, stream grpc.ServerStream)
|
||||
}
|
||||
|
||||
type Vagrant_RestoreSnapshotServer interface {
|
||||
SendAndClose(*empty.Empty) error
|
||||
SendAndClose(*emptypb.Empty) error
|
||||
Recv() (*RestoreSnapshotRequest, error)
|
||||
grpc.ServerStream
|
||||
}
|
||||
@ -1618,7 +1618,7 @@ type vagrantRestoreSnapshotServer struct {
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
func (x *vagrantRestoreSnapshotServer) SendAndClose(m *empty.Empty) error {
|
||||
func (x *vagrantRestoreSnapshotServer) SendAndClose(m *emptypb.Empty) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
|
||||
@ -1631,7 +1631,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(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1643,7 +1643,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.(*empty.Empty))
|
||||
return srv.(VagrantServer).BootstrapToken(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
@ -1667,7 +1667,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(empty.Empty)
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -1679,7 +1679,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.(*empty.Empty))
|
||||
return srv.(VagrantServer).GenerateLoginToken(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
@ -152,6 +152,47 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
optional :network, :string, 2
|
||||
optional :addr, :string, 3
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.Args.Connection" do
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.Args.Connection.SSHInfo" do
|
||||
optional :host, :string, 1
|
||||
optional :port, :string, 2
|
||||
optional :private_key_path, :string, 3
|
||||
optional :keys_only, :bool, 4
|
||||
optional :verify_host_key, :bool, 5
|
||||
optional :username, :string, 6
|
||||
optional :remote_user, :string, 7
|
||||
optional :compression, :bool, 8
|
||||
optional :dsa_authentication, :bool, 9
|
||||
optional :config, :string, 10
|
||||
repeated :extra_args, :string, 11
|
||||
optional :forward_agent, :bool, 12
|
||||
optional :forward_x11, :bool, 13
|
||||
repeated :forward_env, :string, 14
|
||||
optional :connect_timeout, :int64, 15
|
||||
optional :ssh_command, :string, 16
|
||||
optional :proxy_command, :string, 17
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.Args.Connection.WinrmInfo" do
|
||||
optional :username, :string, 1
|
||||
optional :password, :string, 2
|
||||
optional :host, :string, 3
|
||||
optional :port, :int64, 4
|
||||
optional :guest_port, :int64, 5
|
||||
optional :max_tries, :int64, 6
|
||||
optional :retry_delay, :int64, 7
|
||||
optional :timeout, :int64, 8
|
||||
optional :transport, :enum, 9, "hashicorp.vagrant.sdk.Args.Connection.WinrmInfo.Transport"
|
||||
optional :ssl_peer_verification, :bool, 10
|
||||
optional :execution_time_limit, :string, 11
|
||||
optional :basic_auth_only, :bool, 12
|
||||
optional :codepage, :string, 13
|
||||
end
|
||||
add_enum "hashicorp.vagrant.sdk.Args.Connection.WinrmInfo.Transport" do
|
||||
value :NEGOTIATE, 0
|
||||
value :SSL, 1
|
||||
value :PLAINTEXT, 2
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.Args.Push" do
|
||||
optional :stream_id, :uint32, 1
|
||||
optional :network, :string, 2
|
||||
@ -181,45 +222,6 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.Args.Null" do
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.SSHInfo" do
|
||||
optional :host, :string, 1
|
||||
optional :port, :string, 2
|
||||
optional :private_key_path, :string, 3
|
||||
optional :keys_only, :bool, 4
|
||||
optional :verify_host_key, :bool, 5
|
||||
optional :username, :string, 6
|
||||
optional :remote_user, :string, 7
|
||||
optional :compression, :bool, 8
|
||||
optional :dsa_authentication, :bool, 9
|
||||
optional :config, :string, 10
|
||||
repeated :extra_args, :string, 11
|
||||
optional :forward_agent, :bool, 12
|
||||
optional :forward_x11, :bool, 13
|
||||
repeated :forward_env, :string, 14
|
||||
optional :connect_timeout, :int64, 15
|
||||
optional :ssh_command, :string, 16
|
||||
optional :proxy_command, :string, 17
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.WinrmInfo" do
|
||||
optional :username, :string, 1
|
||||
optional :password, :string, 2
|
||||
optional :host, :string, 3
|
||||
optional :port, :int64, 4
|
||||
optional :guest_port, :int64, 5
|
||||
optional :max_tries, :int64, 6
|
||||
optional :retry_delay, :int64, 7
|
||||
optional :timeout, :int64, 8
|
||||
optional :transport, :enum, 9, "hashicorp.vagrant.sdk.WinrmInfo.Transport"
|
||||
optional :ssl_peer_verification, :bool, 10
|
||||
optional :execution_time_limit, :string, 11
|
||||
optional :basic_auth_only, :bool, 12
|
||||
optional :codepage, :string, 13
|
||||
end
|
||||
add_enum "hashicorp.vagrant.sdk.WinrmInfo.Transport" do
|
||||
value :NEGOTIATE, 0
|
||||
value :SSL, 1
|
||||
value :PLAINTEXT, 2
|
||||
end
|
||||
add_message "hashicorp.vagrant.sdk.FuncSpec" do
|
||||
optional :name, :string, 1
|
||||
repeated :args, :message, 2, "hashicorp.vagrant.sdk.FuncSpec.Value"
|
||||
@ -878,6 +880,10 @@ module Hashicorp
|
||||
Args::Host = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Host").msgclass
|
||||
Args::Guest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Guest").msgclass
|
||||
Args::Communicator = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Communicator").msgclass
|
||||
Args::Connection = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Connection").msgclass
|
||||
Args::Connection::SSHInfo = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Connection.SSHInfo").msgclass
|
||||
Args::Connection::WinrmInfo = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Connection.WinrmInfo").msgclass
|
||||
Args::Connection::WinrmInfo::Transport = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Connection.WinrmInfo.Transport").enummodule
|
||||
Args::Push = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Push").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
|
||||
@ -886,9 +892,6 @@ module Hashicorp
|
||||
Args::Array = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Array").msgclass
|
||||
Args::Hash = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Hash").msgclass
|
||||
Args::Null = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.Args.Null").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::Transport = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.WinrmInfo.Transport").enummodule
|
||||
FuncSpec = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.FuncSpec").msgclass
|
||||
FuncSpec::Value = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.FuncSpec.Value").msgclass
|
||||
FuncSpec::Args = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.sdk.FuncSpec.Args").msgclass
|
||||
|
||||
@ -124,7 +124,7 @@ module Hashicorp
|
||||
rpc :ActionSpec, ::Hashicorp::Vagrant::Sdk::Provider::ActionRequest, ::Hashicorp::Vagrant::Sdk::FuncSpec
|
||||
rpc :MachineIdChanged, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Google::Protobuf::Empty
|
||||
rpc :MachineIdChangedSpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec
|
||||
rpc :SshInfo, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Hashicorp::Vagrant::Sdk::SSHInfo
|
||||
rpc :SshInfo, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Hashicorp::Vagrant::Sdk::Args::Connection::SSHInfo
|
||||
rpc :SshInfoSpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec
|
||||
rpc :State, ::Hashicorp::Vagrant::Sdk::FuncSpec::Args, ::Hashicorp::Vagrant::Sdk::Args::Target::Machine::State
|
||||
rpc :StateSpec, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::Sdk::FuncSpec
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user