Generated proto updates
This commit is contained in:
Chris Roberts
parent
be969c3386
commit
f42269c584
@ -1,4 +1,8 @@
|
||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-grpc v1.2.0
|
||||
// - protoc v3.19.4
|
||||
// source: proto/vagrant_server/server.proto
|
||||
|
||||
package vagrant_server
|
||||
|
||||
@ -27,15 +31,6 @@ type VagrantClient interface {
|
||||
GetBasis(ctx context.Context, in *GetBasisRequest, opts ...grpc.CallOption) (*GetBasisResponse, error)
|
||||
FindBasis(ctx context.Context, in *FindBasisRequest, opts ...grpc.CallOption) (*FindBasisResponse, error)
|
||||
ListBasis(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListBasisResponse, error)
|
||||
// ListTasks returns the tasks.
|
||||
ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
|
||||
// GetTask returns a task
|
||||
GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
|
||||
// GetLatestRelease returns the most recent successfully completed
|
||||
// task within the given scope.
|
||||
GetLatestTask(ctx context.Context, in *GetLatestTaskRequest, opts ...grpc.CallOption) (*Task, error)
|
||||
// UpsertRelease updates or inserts a task.
|
||||
UpsertTask(ctx context.Context, in *UpsertTaskRequest, opts ...grpc.CallOption) (*UpsertTaskResponse, error)
|
||||
// UpsertProject upserts the project.
|
||||
UpsertProject(ctx context.Context, in *UpsertProjectRequest, opts ...grpc.CallOption) (*UpsertProjectResponse, error)
|
||||
// GetProject returns the project.
|
||||
@ -63,12 +58,6 @@ type VagrantClient interface {
|
||||
// available lines this will NOT block and instead will return an error.
|
||||
// The client can choose to retry or not.
|
||||
GetLogStream(ctx context.Context, in *GetLogStreamRequest, opts ...grpc.CallOption) (Vagrant_GetLogStreamClient, error)
|
||||
// Set a single configuration item for the application.
|
||||
SetConfig(ctx context.Context, in *ConfigSetRequest, opts ...grpc.CallOption) (*ConfigSetResponse, error)
|
||||
// Retrieve merged configuration values for a specific scope. You can determine
|
||||
// where a configuration variable was set by looking at the scope field on
|
||||
// each variable.
|
||||
GetConfig(ctx context.Context, in *ConfigGetRequest, opts ...grpc.CallOption) (*ConfigGetResponse, error)
|
||||
// QueueJob queues a job for execution by a runner. This will return as
|
||||
// soon as the job is queued, it will not wait for execution.
|
||||
QueueJob(ctx context.Context, in *QueueJobRequest, opts ...grpc.CallOption) (*QueueJobResponse, error)
|
||||
@ -97,17 +86,6 @@ type VagrantClient interface {
|
||||
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 *emptypb.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error)
|
||||
// SetServerConfig sets configuration for the Vagrant server.
|
||||
SetServerConfig(ctx context.Context, in *SetServerConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
|
||||
// CreateSnapshot creates a new database snapshot.
|
||||
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
|
||||
// more information.
|
||||
RestoreSnapshot(ctx context.Context, opts ...grpc.CallOption) (Vagrant_RestoreSnapshotClient, error)
|
||||
// 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.
|
||||
@ -180,42 +158,6 @@ func (c *vagrantClient) ListBasis(ctx context.Context, in *emptypb.Empty, opts .
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) {
|
||||
out := new(ListTasksResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/ListTasks", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) {
|
||||
out := new(Task)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetTask", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetLatestTask(ctx context.Context, in *GetLatestTaskRequest, opts ...grpc.CallOption) (*Task, error) {
|
||||
out := new(Task)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetLatestTask", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) UpsertTask(ctx context.Context, in *UpsertTaskRequest, opts ...grpc.CallOption) (*UpsertTaskResponse, error) {
|
||||
out := new(UpsertTaskResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/UpsertTask", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) UpsertProject(ctx context.Context, in *UpsertProjectRequest, opts ...grpc.CallOption) (*UpsertProjectResponse, error) {
|
||||
out := new(UpsertProjectResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/UpsertProject", in, out, opts...)
|
||||
@ -374,24 +316,6 @@ func (x *vagrantGetLogStreamClient) Recv() (*LogBatch, error) {
|
||||
return m, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) SetConfig(ctx context.Context, in *ConfigSetRequest, opts ...grpc.CallOption) (*ConfigSetResponse, error) {
|
||||
out := new(ConfigSetResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/SetConfig", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetConfig(ctx context.Context, in *ConfigGetRequest, opts ...grpc.CallOption) (*ConfigGetResponse, error) {
|
||||
out := new(ConfigGetResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetConfig", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) QueueJob(ctx context.Context, in *QueueJobRequest, opts ...grpc.CallOption) (*QueueJobResponse, error) {
|
||||
out := new(QueueJobResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/QueueJob", in, out, opts...)
|
||||
@ -487,90 +411,6 @@ func (c *vagrantClient) GetRunner(ctx context.Context, in *GetRunnerRequest, opt
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) GetServerConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetServerConfigResponse, error) {
|
||||
out := new(GetServerConfigResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/GetServerConfig", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
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
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) CreateSnapshot(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Vagrant_CreateSnapshotClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[2], "/hashicorp.vagrant.Vagrant/CreateSnapshot", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
x := &vagrantCreateSnapshotClient{stream}
|
||||
if err := x.ClientStream.SendMsg(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := x.ClientStream.CloseSend(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return x, nil
|
||||
}
|
||||
|
||||
type Vagrant_CreateSnapshotClient interface {
|
||||
Recv() (*CreateSnapshotResponse, error)
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
type vagrantCreateSnapshotClient struct {
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
func (x *vagrantCreateSnapshotClient) Recv() (*CreateSnapshotResponse, error) {
|
||||
m := new(CreateSnapshotResponse)
|
||||
if err := x.ClientStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return m, nil
|
||||
}
|
||||
|
||||
func (c *vagrantClient) RestoreSnapshot(ctx context.Context, opts ...grpc.CallOption) (Vagrant_RestoreSnapshotClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[3], "/hashicorp.vagrant.Vagrant/RestoreSnapshot", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
x := &vagrantRestoreSnapshotClient{stream}
|
||||
return x, nil
|
||||
}
|
||||
|
||||
type Vagrant_RestoreSnapshotClient interface {
|
||||
Send(*RestoreSnapshotRequest) error
|
||||
CloseAndRecv() (*emptypb.Empty, error)
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
type vagrantRestoreSnapshotClient struct {
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
func (x *vagrantRestoreSnapshotClient) Send(m *RestoreSnapshotRequest) error {
|
||||
return x.ClientStream.SendMsg(m)
|
||||
}
|
||||
|
||||
func (x *vagrantRestoreSnapshotClient) CloseAndRecv() (*emptypb.Empty, error) {
|
||||
if err := x.ClientStream.CloseSend(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
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 *emptypb.Empty, opts ...grpc.CallOption) (*NewTokenResponse, error) {
|
||||
out := new(NewTokenResponse)
|
||||
err := c.cc.Invoke(ctx, "/hashicorp.vagrant.Vagrant/BootstrapToken", in, out, opts...)
|
||||
@ -608,7 +448,7 @@ func (c *vagrantClient) ConvertInviteToken(ctx context.Context, in *ConvertInvit
|
||||
}
|
||||
|
||||
func (c *vagrantClient) RunnerConfig(ctx context.Context, opts ...grpc.CallOption) (Vagrant_RunnerConfigClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[4], "/hashicorp.vagrant.Vagrant/RunnerConfig", opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[2], "/hashicorp.vagrant.Vagrant/RunnerConfig", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -639,7 +479,7 @@ func (x *vagrantRunnerConfigClient) Recv() (*RunnerConfigResponse, error) {
|
||||
}
|
||||
|
||||
func (c *vagrantClient) RunnerJobStream(ctx context.Context, opts ...grpc.CallOption) (Vagrant_RunnerJobStreamClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[5], "/hashicorp.vagrant.Vagrant/RunnerJobStream", opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &Vagrant_ServiceDesc.Streams[3], "/hashicorp.vagrant.Vagrant/RunnerJobStream", opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -681,15 +521,6 @@ type VagrantServer interface {
|
||||
GetBasis(context.Context, *GetBasisRequest) (*GetBasisResponse, error)
|
||||
FindBasis(context.Context, *FindBasisRequest) (*FindBasisResponse, error)
|
||||
ListBasis(context.Context, *emptypb.Empty) (*ListBasisResponse, error)
|
||||
// ListTasks returns the tasks.
|
||||
ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
|
||||
// GetTask returns a task
|
||||
GetTask(context.Context, *GetTaskRequest) (*Task, error)
|
||||
// GetLatestRelease returns the most recent successfully completed
|
||||
// task within the given scope.
|
||||
GetLatestTask(context.Context, *GetLatestTaskRequest) (*Task, error)
|
||||
// UpsertRelease updates or inserts a task.
|
||||
UpsertTask(context.Context, *UpsertTaskRequest) (*UpsertTaskResponse, error)
|
||||
// UpsertProject upserts the project.
|
||||
UpsertProject(context.Context, *UpsertProjectRequest) (*UpsertProjectResponse, error)
|
||||
// GetProject returns the project.
|
||||
@ -717,12 +548,6 @@ type VagrantServer interface {
|
||||
// available lines this will NOT block and instead will return an error.
|
||||
// The client can choose to retry or not.
|
||||
GetLogStream(*GetLogStreamRequest, Vagrant_GetLogStreamServer) error
|
||||
// Set a single configuration item for the application.
|
||||
SetConfig(context.Context, *ConfigSetRequest) (*ConfigSetResponse, error)
|
||||
// Retrieve merged configuration values for a specific scope. You can determine
|
||||
// where a configuration variable was set by looking at the scope field on
|
||||
// each variable.
|
||||
GetConfig(context.Context, *ConfigGetRequest) (*ConfigGetResponse, error)
|
||||
// QueueJob queues a job for execution by a runner. This will return as
|
||||
// soon as the job is queued, it will not wait for execution.
|
||||
QueueJob(context.Context, *QueueJobRequest) (*QueueJobResponse, error)
|
||||
@ -751,17 +576,6 @@ type VagrantServer interface {
|
||||
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, *emptypb.Empty) (*GetServerConfigResponse, error)
|
||||
// SetServerConfig sets configuration for the Vagrant server.
|
||||
SetServerConfig(context.Context, *SetServerConfigRequest) (*emptypb.Empty, error)
|
||||
// CreateSnapshot creates a new database snapshot.
|
||||
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
|
||||
// more information.
|
||||
RestoreSnapshot(Vagrant_RestoreSnapshotServer) error
|
||||
// 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.
|
||||
@ -800,18 +614,6 @@ func (UnimplementedVagrantServer) FindBasis(context.Context, *FindBasisRequest)
|
||||
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) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ListTasks not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetTask(context.Context, *GetTaskRequest) (*Task, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetTask not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetLatestTask(context.Context, *GetLatestTaskRequest) (*Task, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetLatestTask not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) UpsertTask(context.Context, *UpsertTaskRequest) (*UpsertTaskResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method UpsertTask not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) UpsertProject(context.Context, *UpsertProjectRequest) (*UpsertProjectResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method UpsertProject not implemented")
|
||||
}
|
||||
@ -857,12 +659,6 @@ func (UnimplementedVagrantServer) FindBox(context.Context, *FindBoxRequest) (*Fi
|
||||
func (UnimplementedVagrantServer) GetLogStream(*GetLogStreamRequest, Vagrant_GetLogStreamServer) error {
|
||||
return status.Errorf(codes.Unimplemented, "method GetLogStream not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) SetConfig(context.Context, *ConfigSetRequest) (*ConfigSetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method SetConfig not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetConfig(context.Context, *ConfigGetRequest) (*ConfigGetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetConfig not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) QueueJob(context.Context, *QueueJobRequest) (*QueueJobResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method QueueJob not implemented")
|
||||
}
|
||||
@ -887,18 +683,6 @@ func (UnimplementedVagrantServer) PruneOldJobs(context.Context, *emptypb.Empty)
|
||||
func (UnimplementedVagrantServer) GetRunner(context.Context, *GetRunnerRequest) (*Runner, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetRunner not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) GetServerConfig(context.Context, *emptypb.Empty) (*GetServerConfigResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetServerConfig not implemented")
|
||||
}
|
||||
func (UnimplementedVagrantServer) SetServerConfig(context.Context, *SetServerConfigRequest) (*emptypb.Empty, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method SetServerConfig not implemented")
|
||||
}
|
||||
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, *emptypb.Empty) (*NewTokenResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method BootstrapToken not implemented")
|
||||
}
|
||||
@ -1019,78 +803,6 @@ func _Vagrant_ListBasis_Handler(srv interface{}, ctx context.Context, dec func(i
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_ListTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(ListTasksRequest)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).ListTasks(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/ListTasks",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).ListTasks(ctx, req.(*ListTasksRequest))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_GetTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(GetTaskRequest)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).GetTask(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/GetTask",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).GetTask(ctx, req.(*GetTaskRequest))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_GetLatestTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(GetLatestTaskRequest)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).GetLatestTask(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/GetLatestTask",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).GetLatestTask(ctx, req.(*GetLatestTaskRequest))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_UpsertTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(UpsertTaskRequest)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).UpsertTask(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/UpsertTask",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).UpsertTask(ctx, req.(*UpsertTaskRequest))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_UpsertProject_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(UpsertProjectRequest)
|
||||
if err := dec(in); err != nil {
|
||||
@ -1364,42 +1076,6 @@ func (x *vagrantGetLogStreamServer) Send(m *LogBatch) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
|
||||
func _Vagrant_SetConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(ConfigSetRequest)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).SetConfig(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/SetConfig",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).SetConfig(ctx, req.(*ConfigSetRequest))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_GetConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(ConfigGetRequest)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).GetConfig(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/GetConfig",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).GetConfig(ctx, req.(*ConfigGetRequest))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_QueueJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(QueueJobRequest)
|
||||
if err := dec(in); err != nil {
|
||||
@ -1547,89 +1223,6 @@ func _Vagrant_GetRunner_Handler(srv interface{}, ctx context.Context, dec func(i
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_GetServerConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).GetServerConfig(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/GetServerConfig",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).GetServerConfig(ctx, req.(*emptypb.Empty))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_SetServerConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(SetServerConfigRequest)
|
||||
if err := dec(in); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if interceptor == nil {
|
||||
return srv.(VagrantServer).SetServerConfig(ctx, in)
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/hashicorp.vagrant.Vagrant/SetServerConfig",
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(VagrantServer).SetServerConfig(ctx, req.(*SetServerConfigRequest))
|
||||
}
|
||||
return interceptor(ctx, in, info, handler)
|
||||
}
|
||||
|
||||
func _Vagrant_CreateSnapshot_Handler(srv interface{}, stream grpc.ServerStream) error {
|
||||
m := new(emptypb.Empty)
|
||||
if err := stream.RecvMsg(m); err != nil {
|
||||
return err
|
||||
}
|
||||
return srv.(VagrantServer).CreateSnapshot(m, &vagrantCreateSnapshotServer{stream})
|
||||
}
|
||||
|
||||
type Vagrant_CreateSnapshotServer interface {
|
||||
Send(*CreateSnapshotResponse) error
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
type vagrantCreateSnapshotServer struct {
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
func (x *vagrantCreateSnapshotServer) Send(m *CreateSnapshotResponse) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
|
||||
func _Vagrant_RestoreSnapshot_Handler(srv interface{}, stream grpc.ServerStream) error {
|
||||
return srv.(VagrantServer).RestoreSnapshot(&vagrantRestoreSnapshotServer{stream})
|
||||
}
|
||||
|
||||
type Vagrant_RestoreSnapshotServer interface {
|
||||
SendAndClose(*emptypb.Empty) error
|
||||
Recv() (*RestoreSnapshotRequest, error)
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
type vagrantRestoreSnapshotServer struct {
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
func (x *vagrantRestoreSnapshotServer) SendAndClose(m *emptypb.Empty) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
|
||||
func (x *vagrantRestoreSnapshotServer) Recv() (*RestoreSnapshotRequest, error) {
|
||||
m := new(RestoreSnapshotRequest)
|
||||
if err := x.ServerStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return m, nil
|
||||
}
|
||||
|
||||
func _Vagrant_BootstrapToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(emptypb.Empty)
|
||||
if err := dec(in); err != nil {
|
||||
@ -1781,22 +1374,6 @@ var Vagrant_ServiceDesc = grpc.ServiceDesc{
|
||||
MethodName: "ListBasis",
|
||||
Handler: _Vagrant_ListBasis_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "ListTasks",
|
||||
Handler: _Vagrant_ListTasks_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "GetTask",
|
||||
Handler: _Vagrant_GetTask_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "GetLatestTask",
|
||||
Handler: _Vagrant_GetLatestTask_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "UpsertTask",
|
||||
Handler: _Vagrant_UpsertTask_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "UpsertProject",
|
||||
Handler: _Vagrant_UpsertProject_Handler,
|
||||
@ -1853,14 +1430,6 @@ var Vagrant_ServiceDesc = grpc.ServiceDesc{
|
||||
MethodName: "FindBox",
|
||||
Handler: _Vagrant_FindBox_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "SetConfig",
|
||||
Handler: _Vagrant_SetConfig_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "GetConfig",
|
||||
Handler: _Vagrant_GetConfig_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "QueueJob",
|
||||
Handler: _Vagrant_QueueJob_Handler,
|
||||
@ -1889,14 +1458,6 @@ var Vagrant_ServiceDesc = grpc.ServiceDesc{
|
||||
MethodName: "GetRunner",
|
||||
Handler: _Vagrant_GetRunner_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "GetServerConfig",
|
||||
Handler: _Vagrant_GetServerConfig_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "SetServerConfig",
|
||||
Handler: _Vagrant_SetServerConfig_Handler,
|
||||
},
|
||||
{
|
||||
MethodName: "BootstrapToken",
|
||||
Handler: _Vagrant_BootstrapToken_Handler,
|
||||
@ -1925,16 +1486,6 @@ var Vagrant_ServiceDesc = grpc.ServiceDesc{
|
||||
Handler: _Vagrant_GetJobStream_Handler,
|
||||
ServerStreams: true,
|
||||
},
|
||||
{
|
||||
StreamName: "CreateSnapshot",
|
||||
Handler: _Vagrant_CreateSnapshot_Handler,
|
||||
ServerStreams: true,
|
||||
},
|
||||
{
|
||||
StreamName: "RestoreSnapshot",
|
||||
Handler: _Vagrant_RestoreSnapshot_Handler,
|
||||
ClientStreams: true,
|
||||
},
|
||||
{
|
||||
StreamName: "RunnerConfig",
|
||||
Handler: _Vagrant_RunnerConfig_Handler,
|
||||
|
||||
@ -58,7 +58,7 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
optional :data_source, :message, 101, "hashicorp.vagrant.Job.DataSource"
|
||||
end
|
||||
add_message "hashicorp.vagrant.Box" do
|
||||
optional :id, :string, 1
|
||||
optional :resource_id, :string, 1
|
||||
optional :provider, :string, 2
|
||||
optional :version, :string, 3
|
||||
optional :directory, :string, 4
|
||||
@ -73,15 +73,13 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
optional :name, :string, 3
|
||||
optional :project, :message, 4, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :state, :enum, 5, "hashicorp.vagrant.Operation.PhysicalState"
|
||||
repeated :subtargets, :message, 6, "hashicorp.vagrant.Target"
|
||||
optional :parent, :message, 7, "hashicorp.vagrant.Target"
|
||||
repeated :subtargets, :message, 6, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :parent, :message, 7, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :uuid, :string, 8
|
||||
optional :metadata, :message, 9, "hashicorp.vagrant.sdk.Args.MetadataSet"
|
||||
optional :configuration, :message, 10, "hashicorp.vagrant.sdk.Args.ConfigData"
|
||||
optional :record, :message, 11, "google.protobuf.Any"
|
||||
optional :provider, :string, 12
|
||||
optional :remote_enabled, :bool, 100
|
||||
optional :data_source, :message, 101, "hashicorp.vagrant.Job.DataSource"
|
||||
end
|
||||
add_message "hashicorp.vagrant.Target.Machine" do
|
||||
optional :id, :string, 1
|
||||
@ -150,6 +148,7 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
value :CONFIG, 12
|
||||
value :PLUGININFO, 13
|
||||
value :PUSH, 14
|
||||
value :DOWNLOADER, 15
|
||||
end
|
||||
add_message "hashicorp.vagrant.Status" do
|
||||
optional :state, :enum, 1, "hashicorp.vagrant.Status.State"
|
||||
@ -213,9 +212,6 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
end
|
||||
add_message "hashicorp.vagrant.Job" do
|
||||
optional :id, :string, 1
|
||||
optional :basis, :message, 2, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
optional :project, :message, 3, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :target, :message, 4, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :target_runner, :message, 5, "hashicorp.vagrant.Ref.Runner"
|
||||
map :labels, :string, :string, 6
|
||||
optional :data_source, :message, 7, "hashicorp.vagrant.Job.DataSource"
|
||||
@ -230,12 +226,17 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
optional :result, :message, 107, "hashicorp.vagrant.Job.Result"
|
||||
optional :cancel_time, :message, 108, "google.protobuf.Timestamp"
|
||||
optional :expire_time, :message, 109, "google.protobuf.Timestamp"
|
||||
oneof :scope do
|
||||
optional :basis, :message, 2, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
optional :project, :message, 3, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :target, :message, 4, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
end
|
||||
oneof :operation do
|
||||
optional :noop, :message, 50, "hashicorp.vagrant.Job.Noop"
|
||||
optional :auth, :message, 51, "hashicorp.vagrant.Job.AuthOp"
|
||||
optional :docs, :message, 52, "hashicorp.vagrant.Job.DocsOp"
|
||||
optional :validate, :message, 53, "hashicorp.vagrant.Job.ValidateOp"
|
||||
optional :run, :message, 54, "hashicorp.vagrant.Job.RunOp"
|
||||
optional :command, :message, 54, "hashicorp.vagrant.Job.CommandOp"
|
||||
optional :init, :message, 55, "hashicorp.vagrant.Job.InitOp"
|
||||
end
|
||||
end
|
||||
@ -244,7 +245,7 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
optional :docs, :message, 2, "hashicorp.vagrant.Job.DocsResult"
|
||||
optional :validate, :message, 3, "hashicorp.vagrant.Job.ValidateResult"
|
||||
optional :init, :message, 4, "hashicorp.vagrant.Job.InitResult"
|
||||
optional :run, :message, 5, "hashicorp.vagrant.Job.RunResult"
|
||||
optional :run, :message, 5, "hashicorp.vagrant.Job.CommandResult"
|
||||
end
|
||||
add_message "hashicorp.vagrant.Job.DataSource" do
|
||||
oneof :source do
|
||||
@ -286,11 +287,24 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
value :BEFORE, 0
|
||||
value :AFTER, 1
|
||||
end
|
||||
add_message "hashicorp.vagrant.Job.RunOp" do
|
||||
optional :task, :message, 1, "hashicorp.vagrant.Task"
|
||||
add_message "hashicorp.vagrant.Job.CommandOp" do
|
||||
optional :command, :string, 4
|
||||
optional :id, :string, 5
|
||||
optional :status, :message, 6, "hashicorp.vagrant.Status"
|
||||
optional :state, :enum, 7, "hashicorp.vagrant.Operation.PhysicalState"
|
||||
optional :component, :message, 8, "hashicorp.vagrant.Component"
|
||||
map :labels, :string, :string, 9
|
||||
optional :job_id, :string, 10
|
||||
optional :cli_args, :message, 11, "hashicorp.vagrant.sdk.Command.Arguments"
|
||||
optional :vagrantfile, :message, 12, "hashicorp.vagrant.Vagrantfile"
|
||||
oneof :scope do
|
||||
optional :target, :message, 1, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :project, :message, 2, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :basis, :message, 3, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
end
|
||||
end
|
||||
add_message "hashicorp.vagrant.Job.RunResult" do
|
||||
optional :task, :message, 1, "hashicorp.vagrant.Task"
|
||||
add_message "hashicorp.vagrant.Job.CommandResult" do
|
||||
optional :task, :message, 1, "hashicorp.vagrant.Operation"
|
||||
optional :run_result, :bool, 2
|
||||
optional :run_error, :message, 3, "google.rpc.Status"
|
||||
optional :exit_code, :sint32, 4
|
||||
@ -497,30 +511,9 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
add_message "hashicorp.vagrant.RunnerJobStreamResponse.JobCancel" do
|
||||
optional :force, :bool, 1
|
||||
end
|
||||
add_message "hashicorp.vagrant.RunnerGetDeploymentConfigRequest" do
|
||||
end
|
||||
add_message "hashicorp.vagrant.RunnerGetDeploymentConfigResponse" do
|
||||
optional :server_addr, :string, 1
|
||||
optional :server_tls, :bool, 2
|
||||
optional :server_tls_skip_verify, :bool, 3
|
||||
end
|
||||
add_message "hashicorp.vagrant.GetRunnerRequest" do
|
||||
optional :runner_id, :string, 1
|
||||
end
|
||||
add_message "hashicorp.vagrant.SetServerConfigRequest" do
|
||||
optional :config, :message, 1, "hashicorp.vagrant.ServerConfig"
|
||||
end
|
||||
add_message "hashicorp.vagrant.GetServerConfigResponse" do
|
||||
optional :config, :message, 1, "hashicorp.vagrant.ServerConfig"
|
||||
end
|
||||
add_message "hashicorp.vagrant.ServerConfig" do
|
||||
repeated :advertise_addrs, :message, 1, "hashicorp.vagrant.ServerConfig.AdvertiseAddr"
|
||||
end
|
||||
add_message "hashicorp.vagrant.ServerConfig.AdvertiseAddr" do
|
||||
optional :addr, :string, 1
|
||||
optional :tls, :bool, 2
|
||||
optional :tls_skip_verify, :bool, 3
|
||||
end
|
||||
add_message "hashicorp.vagrant.UpsertBasisRequest" do
|
||||
optional :basis, :message, 1, "hashicorp.vagrant.Basis"
|
||||
end
|
||||
@ -635,9 +628,10 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
optional :name, :string, 1
|
||||
optional :value, :string, 2
|
||||
oneof :scope do
|
||||
optional :target, :message, 3, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :basis, :message, 3, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
optional :project, :message, 4, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :runner, :message, 5, "hashicorp.vagrant.Ref.Runner"
|
||||
optional :target, :message, 5, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :runner, :message, 6, "hashicorp.vagrant.Ref.Runner"
|
||||
end
|
||||
end
|
||||
add_message "hashicorp.vagrant.ConfigSetRequest" do
|
||||
@ -650,7 +644,8 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
oneof :scope do
|
||||
optional :target, :message, 2, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :project, :message, 3, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :runner, :message, 4, "hashicorp.vagrant.Ref.RunnerId"
|
||||
optional :basis, :message, 4, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
optional :runner, :message, 5, "hashicorp.vagrant.Ref.RunnerId"
|
||||
end
|
||||
end
|
||||
add_message "hashicorp.vagrant.ConfigGetResponse" do
|
||||
@ -831,53 +826,6 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
|
||||
map :items, :string, :bytes, 2
|
||||
optional :final, :bool, 3
|
||||
end
|
||||
add_message "hashicorp.vagrant.UpsertTaskRequest" do
|
||||
optional :task, :message, 1, "hashicorp.vagrant.Task"
|
||||
end
|
||||
add_message "hashicorp.vagrant.UpsertTaskResponse" do
|
||||
optional :task, :message, 1, "hashicorp.vagrant.Task"
|
||||
end
|
||||
add_message "hashicorp.vagrant.GetLatestTaskRequest" do
|
||||
oneof :scope do
|
||||
optional :target, :message, 1, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :project, :message, 2, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :basis, :message, 3, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
end
|
||||
end
|
||||
add_message "hashicorp.vagrant.ListTasksRequest" do
|
||||
repeated :status, :message, 4, "hashicorp.vagrant.StatusFilter"
|
||||
optional :physical_state, :enum, 5, "hashicorp.vagrant.Operation.PhysicalState"
|
||||
optional :order, :message, 6, "hashicorp.vagrant.OperationOrder"
|
||||
oneof :scope do
|
||||
optional :target, :message, 1, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :project, :message, 2, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :basis, :message, 3, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
end
|
||||
end
|
||||
add_message "hashicorp.vagrant.ListTasksResponse" do
|
||||
repeated :tasks, :message, 1, "hashicorp.vagrant.Task"
|
||||
end
|
||||
add_message "hashicorp.vagrant.GetTaskRequest" do
|
||||
optional :ref, :message, 1, "hashicorp.vagrant.Ref.Operation"
|
||||
end
|
||||
add_message "hashicorp.vagrant.Task" do
|
||||
optional :task, :string, 4
|
||||
optional :sequence, :uint64, 5
|
||||
optional :id, :string, 6
|
||||
optional :status, :message, 7, "hashicorp.vagrant.Status"
|
||||
optional :state, :enum, 8, "hashicorp.vagrant.Operation.PhysicalState"
|
||||
optional :component, :message, 9, "hashicorp.vagrant.Component"
|
||||
map :labels, :string, :string, 10
|
||||
optional :job_id, :string, 11
|
||||
optional :cli_args, :message, 12, "hashicorp.vagrant.sdk.Command.Arguments"
|
||||
optional :command_name, :string, 13
|
||||
optional :vagrantfile, :message, 14, "hashicorp.vagrant.Vagrantfile"
|
||||
oneof :scope do
|
||||
optional :target, :message, 1, "hashicorp.vagrant.sdk.Ref.Target"
|
||||
optional :project, :message, 2, "hashicorp.vagrant.sdk.Ref.Project"
|
||||
optional :basis, :message, 3, "hashicorp.vagrant.sdk.Ref.Basis"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@ -931,8 +879,8 @@ module Hashicorp
|
||||
Job::Action = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.Action").msgclass
|
||||
Job::Hook = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.Hook").msgclass
|
||||
Job::Hook::Location = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.Hook.Location").enummodule
|
||||
Job::RunOp = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.RunOp").msgclass
|
||||
Job::RunResult = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.RunResult").msgclass
|
||||
Job::CommandOp = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.CommandOp").msgclass
|
||||
Job::CommandResult = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.CommandResult").msgclass
|
||||
Job::AuthOp = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.AuthOp").msgclass
|
||||
Job::AuthResult = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.AuthResult").msgclass
|
||||
Job::AuthResult::Result = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Job.AuthResult.Result").msgclass
|
||||
@ -978,13 +926,7 @@ module Hashicorp
|
||||
RunnerJobStreamResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.RunnerJobStreamResponse").msgclass
|
||||
RunnerJobStreamResponse::JobAssignment = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.RunnerJobStreamResponse.JobAssignment").msgclass
|
||||
RunnerJobStreamResponse::JobCancel = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.RunnerJobStreamResponse.JobCancel").msgclass
|
||||
RunnerGetDeploymentConfigRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.RunnerGetDeploymentConfigRequest").msgclass
|
||||
RunnerGetDeploymentConfigResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.RunnerGetDeploymentConfigResponse").msgclass
|
||||
GetRunnerRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.GetRunnerRequest").msgclass
|
||||
SetServerConfigRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.SetServerConfigRequest").msgclass
|
||||
GetServerConfigResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.GetServerConfigResponse").msgclass
|
||||
ServerConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.ServerConfig").msgclass
|
||||
ServerConfig::AdvertiseAddr = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.ServerConfig.AdvertiseAddr").msgclass
|
||||
UpsertBasisRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.UpsertBasisRequest").msgclass
|
||||
UpsertBasisResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.UpsertBasisResponse").msgclass
|
||||
GetBasisRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.GetBasisRequest").msgclass
|
||||
@ -1062,12 +1004,5 @@ module Hashicorp
|
||||
Snapshot::Header::Format = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Snapshot.Header.Format").enummodule
|
||||
Snapshot::Trailer = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Snapshot.Trailer").msgclass
|
||||
Snapshot::BoltChunk = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Snapshot.BoltChunk").msgclass
|
||||
UpsertTaskRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.UpsertTaskRequest").msgclass
|
||||
UpsertTaskResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.UpsertTaskResponse").msgclass
|
||||
GetLatestTaskRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.GetLatestTaskRequest").msgclass
|
||||
ListTasksRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.ListTasksRequest").msgclass
|
||||
ListTasksResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.ListTasksResponse").msgclass
|
||||
GetTaskRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.GetTaskRequest").msgclass
|
||||
Task = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("hashicorp.vagrant.Task").msgclass
|
||||
end
|
||||
end
|
||||
|
||||
@ -24,15 +24,6 @@ module Hashicorp
|
||||
rpc :GetBasis, ::Hashicorp::Vagrant::GetBasisRequest, ::Hashicorp::Vagrant::GetBasisResponse
|
||||
rpc :FindBasis, ::Hashicorp::Vagrant::FindBasisRequest, ::Hashicorp::Vagrant::FindBasisResponse
|
||||
rpc :ListBasis, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::ListBasisResponse
|
||||
# ListTasks returns the tasks.
|
||||
rpc :ListTasks, ::Hashicorp::Vagrant::ListTasksRequest, ::Hashicorp::Vagrant::ListTasksResponse
|
||||
# GetTask returns a task
|
||||
rpc :GetTask, ::Hashicorp::Vagrant::GetTaskRequest, ::Hashicorp::Vagrant::Task
|
||||
# GetLatestRelease returns the most recent successfully completed
|
||||
# task within the given scope.
|
||||
rpc :GetLatestTask, ::Hashicorp::Vagrant::GetLatestTaskRequest, ::Hashicorp::Vagrant::Task
|
||||
# UpsertRelease updates or inserts a task.
|
||||
rpc :UpsertTask, ::Hashicorp::Vagrant::UpsertTaskRequest, ::Hashicorp::Vagrant::UpsertTaskResponse
|
||||
# UpsertProject upserts the project.
|
||||
rpc :UpsertProject, ::Hashicorp::Vagrant::UpsertProjectRequest, ::Hashicorp::Vagrant::UpsertProjectResponse
|
||||
# GetProject returns the project.
|
||||
@ -60,12 +51,6 @@ module Hashicorp
|
||||
# available lines this will NOT block and instead will return an error.
|
||||
# The client can choose to retry or not.
|
||||
rpc :GetLogStream, ::Hashicorp::Vagrant::GetLogStreamRequest, stream(::Hashicorp::Vagrant::LogBatch)
|
||||
# Set a single configuration item for the application.
|
||||
rpc :SetConfig, ::Hashicorp::Vagrant::ConfigSetRequest, ::Hashicorp::Vagrant::ConfigSetResponse
|
||||
# Retrieve merged configuration values for a specific scope. You can determine
|
||||
# where a configuration variable was set by looking at the scope field on
|
||||
# each variable.
|
||||
rpc :GetConfig, ::Hashicorp::Vagrant::ConfigGetRequest, ::Hashicorp::Vagrant::ConfigGetResponse
|
||||
# QueueJob queues a job for execution by a runner. This will return as
|
||||
# soon as the job is queued, it will not wait for execution.
|
||||
rpc :QueueJob, ::Hashicorp::Vagrant::QueueJobRequest, ::Hashicorp::Vagrant::QueueJobResponse
|
||||
@ -94,17 +79,6 @@ module Hashicorp
|
||||
rpc :PruneOldJobs, ::Google::Protobuf::Empty, ::Google::Protobuf::Empty
|
||||
# GetRunner gets information about a single runner.
|
||||
rpc :GetRunner, ::Hashicorp::Vagrant::GetRunnerRequest, ::Hashicorp::Vagrant::Runner
|
||||
# GetServerConfig sets configuration for the Vagrant server.
|
||||
rpc :GetServerConfig, ::Google::Protobuf::Empty, ::Hashicorp::Vagrant::GetServerConfigResponse
|
||||
# SetServerConfig sets configuration for the Vagrant server.
|
||||
rpc :SetServerConfig, ::Hashicorp::Vagrant::SetServerConfigRequest, ::Google::Protobuf::Empty
|
||||
# CreateSnapshot creates a new database snapshot.
|
||||
rpc :CreateSnapshot, ::Google::Protobuf::Empty, stream(::Hashicorp::Vagrant::CreateSnapshotResponse)
|
||||
# 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
|
||||
# more information.
|
||||
rpc :RestoreSnapshot, stream(::Hashicorp::Vagrant::RestoreSnapshotRequest), ::Google::Protobuf::Empty
|
||||
# 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.
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user