protos

package
v0.0.0-...-2a0314b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2025 License: BSD-3-Clause Imports: 8 Imported by: 0

README

Run "go generate" in the module top-level directory to update. You need a protoc binary (see https://github.com/golang/protobuf#installation).

Documentation

Index

Constants

View Source 
const (
	GomoteService_Authenticate_FullMethodName           = "/protos.GomoteService/Authenticate"
	GomoteService_AddBootstrap_FullMethodName           = "/protos.GomoteService/AddBootstrap"
	GomoteService_CreateInstance_FullMethodName         = "/protos.GomoteService/CreateInstance"
	GomoteService_DestroyInstance_FullMethodName        = "/protos.GomoteService/DestroyInstance"
	GomoteService_ExecuteCommand_FullMethodName         = "/protos.GomoteService/ExecuteCommand"
	GomoteService_InstanceAlive_FullMethodName          = "/protos.GomoteService/InstanceAlive"
	GomoteService_ListDirectory_FullMethodName          = "/protos.GomoteService/ListDirectory"
	GomoteService_ListDirectoryStreaming_FullMethodName = "/protos.GomoteService/ListDirectoryStreaming"
	GomoteService_ListInstances_FullMethodName          = "/protos.GomoteService/ListInstances"
	GomoteService_ListSwarmingBuilders_FullMethodName   = "/protos.GomoteService/ListSwarmingBuilders"
	GomoteService_ReadTGZToURL_FullMethodName           = "/protos.GomoteService/ReadTGZToURL"
	GomoteService_RemoveFiles_FullMethodName            = "/protos.GomoteService/RemoveFiles"
	GomoteService_SignSSHKey_FullMethodName             = "/protos.GomoteService/SignSSHKey"
	GomoteService_UploadFile_FullMethodName             = "/protos.GomoteService/UploadFile"
	GomoteService_WriteFileFromURL_FullMethodName       = "/protos.GomoteService/WriteFileFromURL"
	GomoteService_WriteTGZFromURL_FullMethodName        = "/protos.GomoteService/WriteTGZFromURL"
)

Variables

View Source 
var (
	CreateInstanceResponse_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "WAITING",
		2: "COMPLETE",
	}
	CreateInstanceResponse_Status_value = map[string]int32{
		"UNKNOWN":  0,
		"WAITING":  1,
		"COMPLETE": 2,
	}
)

Enum value maps for CreateInstanceResponse_Status.

View Source 
var File_internal_gomote_protos_gomote_proto protoreflect.FileDescriptor
View Source 
var GomoteService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protos.GomoteService",
	HandlerType: (*GomoteServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Authenticate",
			Handler:    _GomoteService_Authenticate_Handler,
		},
		{
			MethodName: "AddBootstrap",
			Handler:    _GomoteService_AddBootstrap_Handler,
		},
		{
			MethodName: "DestroyInstance",
			Handler:    _GomoteService_DestroyInstance_Handler,
		},
		{
			MethodName: "InstanceAlive",
			Handler:    _GomoteService_InstanceAlive_Handler,
		},
		{
			MethodName: "ListDirectory",
			Handler:    _GomoteService_ListDirectory_Handler,
		},
		{
			MethodName: "ListInstances",
			Handler:    _GomoteService_ListInstances_Handler,
		},
		{
			MethodName: "ListSwarmingBuilders",
			Handler:    _GomoteService_ListSwarmingBuilders_Handler,
		},
		{
			MethodName: "ReadTGZToURL",
			Handler:    _GomoteService_ReadTGZToURL_Handler,
		},
		{
			MethodName: "RemoveFiles",
			Handler:    _GomoteService_RemoveFiles_Handler,
		},
		{
			MethodName: "SignSSHKey",
			Handler:    _GomoteService_SignSSHKey_Handler,
		},
		{
			MethodName: "UploadFile",
			Handler:    _GomoteService_UploadFile_Handler,
		},
		{
			MethodName: "WriteFileFromURL",
			Handler:    _GomoteService_WriteFileFromURL_Handler,
		},
		{
			MethodName: "WriteTGZFromURL",
			Handler:    _GomoteService_WriteTGZFromURL_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateInstance",
			Handler:       _GomoteService_CreateInstance_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ExecuteCommand",
			Handler:       _GomoteService_ExecuteCommand_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListDirectoryStreaming",
			Handler:       _GomoteService_ListDirectoryStreaming_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/gomote/protos/gomote.proto",
}

GomoteService_ServiceDesc is the grpc.ServiceDesc for GomoteService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGomoteServiceServer 

func RegisterGomoteServiceServer(s grpc.ServiceRegistrar, srv GomoteServiceServer)

Types

type AddBootstrapRequest 

type AddBootstrapRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// contains filtered or unexported fields
}

AddBootstrapRequest specifies the data needed for a request to add the bootstrap version of Go to the instance.

func (*AddBootstrapRequest) Descriptor deprecated 

func (*AddBootstrapRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddBootstrapRequest.ProtoReflect.Descriptor instead.

func (*AddBootstrapRequest) GetGomoteId 

func (x *AddBootstrapRequest) GetGomoteId() string

func (*AddBootstrapRequest) ProtoMessage 

func (*AddBootstrapRequest) ProtoMessage()

func (*AddBootstrapRequest) ProtoReflect 

func (x *AddBootstrapRequest) ProtoReflect() protoreflect.Message

func (*AddBootstrapRequest) Reset 

func (x *AddBootstrapRequest) Reset()

func (*AddBootstrapRequest) String 

func (x *AddBootstrapRequest) String() string

type AddBootstrapResponse 

type AddBootstrapResponse struct {

	// The URL for the Go version added to the work directory.
	// If empty, the bootstrap version is undefined and has probably been included in
	// the instance image.
	BootstrapGoUrl string `protobuf:"bytes,1,opt,name=bootstrap_go_url,json=bootstrapGoUrl,proto3" json:"bootstrap_go_url,omitempty"`
	// contains filtered or unexported fields
}

AddBootstrapResponse contains the information about the add bootstrap request.

func (*AddBootstrapResponse) Descriptor deprecated 

func (*AddBootstrapResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddBootstrapResponse.ProtoReflect.Descriptor instead.

func (*AddBootstrapResponse) GetBootstrapGoUrl 

func (x *AddBootstrapResponse) GetBootstrapGoUrl() string

func (*AddBootstrapResponse) ProtoMessage 

func (*AddBootstrapResponse) ProtoMessage()

func (*AddBootstrapResponse) ProtoReflect 

func (x *AddBootstrapResponse) ProtoReflect() protoreflect.Message

func (*AddBootstrapResponse) Reset 

func (x *AddBootstrapResponse) Reset()

func (*AddBootstrapResponse) String 

func (x *AddBootstrapResponse) String() string

type AuthenticateRequest 

type AuthenticateRequest struct {
	// contains filtered or unexported fields
}

AuthenticateRequest specifies the data needed for an authentication request.

func (*AuthenticateRequest) Descriptor deprecated 

func (*AuthenticateRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuthenticateRequest.ProtoReflect.Descriptor instead.

func (*AuthenticateRequest) ProtoMessage 

func (*AuthenticateRequest) ProtoMessage()

func (*AuthenticateRequest) ProtoReflect 

func (x *AuthenticateRequest) ProtoReflect() protoreflect.Message

func (*AuthenticateRequest) Reset 

func (x *AuthenticateRequest) Reset()

func (*AuthenticateRequest) String 

func (x *AuthenticateRequest) String() string

type AuthenticateResponse 

type AuthenticateResponse struct {
	// contains filtered or unexported fields
}

AuthenticateResponse contains authenticated user data.

func (*AuthenticateResponse) Descriptor deprecated 

func (*AuthenticateResponse) Descriptor() ([]byte, []int)

Deprecated: Use AuthenticateResponse.ProtoReflect.Descriptor instead.

func (*AuthenticateResponse) ProtoMessage 

func (*AuthenticateResponse) ProtoMessage()

func (*AuthenticateResponse) ProtoReflect 

func (x *AuthenticateResponse) ProtoReflect() protoreflect.Message

func (*AuthenticateResponse) Reset 

func (x *AuthenticateResponse) Reset()

func (*AuthenticateResponse) String 

func (x *AuthenticateResponse) String() string

type CreateInstanceRequest 

type CreateInstanceRequest struct {
	BuilderType      string   `protobuf:"bytes,1,opt,name=builder_type,json=builderType,proto3" json:"builder_type,omitempty"`
	ExperimentOption []string `protobuf:"bytes,2,rep,name=experiment_option,json=experimentOption,proto3" json:"experiment_option,omitempty"`
	// contains filtered or unexported fields
}

CreateInstanceRequest specifies the data needed to create a gomote instance.

func (*CreateInstanceRequest) Descriptor deprecated 

func (*CreateInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetBuilderType 

func (x *CreateInstanceRequest) GetBuilderType() string

func (*CreateInstanceRequest) GetExperimentOption 

func (x *CreateInstanceRequest) GetExperimentOption() []string

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect 

func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message

func (*CreateInstanceRequest) Reset 

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse 

type CreateInstanceResponse struct {

	// Instance information for the requested instance.
	Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// The status for the requested create.
	Status CreateInstanceResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=protos.CreateInstanceResponse_Status" json:"status,omitempty"`
	// Waiters ahead is the count of how many instances are being scheduled for
	// creation before the current instance creation request.
	WaitersAhead int64 `protobuf:"varint,3,opt,name=waiters_ahead,json=waitersAhead,proto3" json:"waiters_ahead,omitempty"`
	// contains filtered or unexported fields
}

CreateInstanceResponse contains data about a created gomote instance.

func (*CreateInstanceResponse) Descriptor deprecated 

func (*CreateInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstance 

func (x *CreateInstanceResponse) GetInstance() *Instance

func (*CreateInstanceResponse) GetStatus 

func (x *CreateInstanceResponse) GetStatus() CreateInstanceResponse_Status

func (*CreateInstanceResponse) GetWaitersAhead 

func (x *CreateInstanceResponse) GetWaitersAhead() int64

func (*CreateInstanceResponse) ProtoMessage 

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect 

func (x *CreateInstanceResponse) ProtoReflect() protoreflect.Message

func (*CreateInstanceResponse) Reset 

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String 

func (x *CreateInstanceResponse) String() string

type CreateInstanceResponse_Status 

type CreateInstanceResponse_Status int32
const (
	CreateInstanceResponse_UNKNOWN  CreateInstanceResponse_Status = 0
	CreateInstanceResponse_WAITING  CreateInstanceResponse_Status = 1
	CreateInstanceResponse_COMPLETE CreateInstanceResponse_Status = 2
)

func (CreateInstanceResponse_Status) Descriptor 

func (CreateInstanceResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (CreateInstanceResponse_Status) Enum 

func (x CreateInstanceResponse_Status) Enum() *CreateInstanceResponse_Status

func (CreateInstanceResponse_Status) EnumDescriptor deprecated 

func (CreateInstanceResponse_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use CreateInstanceResponse_Status.Descriptor instead.

func (CreateInstanceResponse_Status) Number 

func (x CreateInstanceResponse_Status) Number() protoreflect.EnumNumber

func (CreateInstanceResponse_Status) String 

func (x CreateInstanceResponse_Status) String() string

func (CreateInstanceResponse_Status) Type 

func (CreateInstanceResponse_Status) Type() protoreflect.EnumType

type DestroyInstanceRequest 

type DestroyInstanceRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// contains filtered or unexported fields
}

DestroyInstanceRequest specifies the data needed to destroy a gomote instance.

func (*DestroyInstanceRequest) Descriptor deprecated 

func (*DestroyInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DestroyInstanceRequest.ProtoReflect.Descriptor instead.

func (*DestroyInstanceRequest) GetGomoteId 

func (x *DestroyInstanceRequest) GetGomoteId() string

func (*DestroyInstanceRequest) ProtoMessage 

func (*DestroyInstanceRequest) ProtoMessage()

func (*DestroyInstanceRequest) ProtoReflect 

func (x *DestroyInstanceRequest) ProtoReflect() protoreflect.Message

func (*DestroyInstanceRequest) Reset 

func (x *DestroyInstanceRequest) Reset()

func (*DestroyInstanceRequest) String 

func (x *DestroyInstanceRequest) String() string

type DestroyInstanceResponse 

type DestroyInstanceResponse struct {
	// contains filtered or unexported fields
}

DestroyInstanceResponse contains data about a destroyed gomote instance.

func (*DestroyInstanceResponse) Descriptor deprecated 

func (*DestroyInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use DestroyInstanceResponse.ProtoReflect.Descriptor instead.

func (*DestroyInstanceResponse) ProtoMessage 

func (*DestroyInstanceResponse) ProtoMessage()

func (*DestroyInstanceResponse) ProtoReflect 

func (x *DestroyInstanceResponse) ProtoReflect() protoreflect.Message

func (*DestroyInstanceResponse) Reset 

func (x *DestroyInstanceResponse) Reset()

func (*DestroyInstanceResponse) String 

func (x *DestroyInstanceResponse) String() string

type ExecuteCommandRequest 

type ExecuteCommandRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// The command to be executed on the buildlet.
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// Controls whether the command is run outside of the buildlet's environment.
	SystemLevel bool `protobuf:"varint,3,opt,name=system_level,json=systemLevel,proto3" json:"system_level,omitempty"`
	// Debug will instruct the buildlet to include extra debugging information in the output.
	Debug bool `protobuf:"varint,4,opt,name=debug,proto3" json:"debug,omitempty"`
	// These are additional environmental variables to include in the buildlet's process's
	// environment.
	AppendEnvironment []string `protobuf:"bytes,5,rep,name=append_environment,json=appendEnvironment,proto3" json:"append_environment,omitempty"`
	// Path specifies the PATH variable of the executed procesess's environment.
	// A non-nil entry will clear the existing PATH value.
	// The string "$PATH" expands to any existing PATH element(s).
	// The substring "$WORKDIR" expands to buildlet's temp workdir.
	Path []string `protobuf:"bytes,6,rep,name=path,proto3" json:"path,omitempty"`
	// The directory from which to execute the command.
	// If not specified, it defaults to the directory of the command or the
	// work directory if system level is set.
	Directory string `protobuf:"bytes,7,opt,name=directory,proto3" json:"directory,omitempty"`
	// The arguments to pass to the command.
	Args []string `protobuf:"bytes,8,rep,name=args,proto3" json:"args,omitempty"`
	// Optional alternate builder to act like. It must be a compatible builder.
	ImitateHostType string `protobuf:"bytes,9,opt,name=imitate_host_type,json=imitateHostType,proto3" json:"imitate_host_type,omitempty"`
	// contains filtered or unexported fields
}

ExecuteCommandRequest specifies the data needed to execute a command on a gomote instance.

func (*ExecuteCommandRequest) Descriptor deprecated 

func (*ExecuteCommandRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteCommandRequest.ProtoReflect.Descriptor instead.

func (*ExecuteCommandRequest) GetAppendEnvironment 

func (x *ExecuteCommandRequest) GetAppendEnvironment() []string

func (*ExecuteCommandRequest) GetArgs 

func (x *ExecuteCommandRequest) GetArgs() []string

func (*ExecuteCommandRequest) GetCommand 

func (x *ExecuteCommandRequest) GetCommand() string

func (*ExecuteCommandRequest) GetDebug 

func (x *ExecuteCommandRequest) GetDebug() bool

func (*ExecuteCommandRequest) GetDirectory 

func (x *ExecuteCommandRequest) GetDirectory() string

func (*ExecuteCommandRequest) GetGomoteId 

func (x *ExecuteCommandRequest) GetGomoteId() string

func (*ExecuteCommandRequest) GetImitateHostType 

func (x *ExecuteCommandRequest) GetImitateHostType() string

func (*ExecuteCommandRequest) GetPath 

func (x *ExecuteCommandRequest) GetPath() []string

func (*ExecuteCommandRequest) GetSystemLevel 

func (x *ExecuteCommandRequest) GetSystemLevel() bool

func (*ExecuteCommandRequest) ProtoMessage 

func (*ExecuteCommandRequest) ProtoMessage()

func (*ExecuteCommandRequest) ProtoReflect 

func (x *ExecuteCommandRequest) ProtoReflect() protoreflect.Message

func (*ExecuteCommandRequest) Reset 

func (x *ExecuteCommandRequest) Reset()

func (*ExecuteCommandRequest) String 

func (x *ExecuteCommandRequest) String() string

type ExecuteCommandResponse 

type ExecuteCommandResponse struct {

	// The output from the executed command.
	Output []byte `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

ExecuteCommandResponse contains data about the executed command.

func (*ExecuteCommandResponse) Descriptor deprecated 

func (*ExecuteCommandResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteCommandResponse.ProtoReflect.Descriptor instead.

func (*ExecuteCommandResponse) GetOutput 

func (x *ExecuteCommandResponse) GetOutput() []byte

func (*ExecuteCommandResponse) ProtoMessage 

func (*ExecuteCommandResponse) ProtoMessage()

func (*ExecuteCommandResponse) ProtoReflect 

func (x *ExecuteCommandResponse) ProtoReflect() protoreflect.Message

func (*ExecuteCommandResponse) Reset 

func (x *ExecuteCommandResponse) Reset()

func (*ExecuteCommandResponse) String 

func (x *ExecuteCommandResponse) String() string

type GomoteServiceClient 

type GomoteServiceClient interface {
	// Authenticate provides authentication information without any additional action.
	Authenticate(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption) (*AuthenticateResponse, error)
	// AddBootstrap adds the bootstrap version of Go to the work directory.
	AddBootstrap(ctx context.Context, in *AddBootstrapRequest, opts ...grpc.CallOption) (*AddBootstrapResponse, error)
	// CreateInstance creates a gomote instance.
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CreateInstanceResponse], error)
	// DestroyInstance destroys a gomote instance.
	DestroyInstance(ctx context.Context, in *DestroyInstanceRequest, opts ...grpc.CallOption) (*DestroyInstanceResponse, error)
	// ExecuteCommand executes a command on the gomote instance.
	ExecuteCommand(ctx context.Context, in *ExecuteCommandRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecuteCommandResponse], error)
	// InstanceAlive gives the liveness state of a gomote instance.
	InstanceAlive(ctx context.Context, in *InstanceAliveRequest, opts ...grpc.CallOption) (*InstanceAliveResponse, error)
	// ListDirectory lists the contents of a directory on an gomote instance.
	ListDirectory(ctx context.Context, in *ListDirectoryRequest, opts ...grpc.CallOption) (*ListDirectoryResponse, error)
	// ListDirectoryStreaming lists the contents of a directory on an gomote instance.
	ListDirectoryStreaming(ctx context.Context, in *ListDirectoryRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ListDirectoryResponse], error)
	// ListInstances lists all of the live gomote instances owned by the caller.
	ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
	// ListSwarmingBuilders lists all of the swarming builders for the project.
	ListSwarmingBuilders(ctx context.Context, in *ListSwarmingBuildersRequest, opts ...grpc.CallOption) (*ListSwarmingBuildersResponse, error)
	// ReadTGZToURL tars and zips a directory which exists on the gomote instance and returns a URL where it can be
	// downloaded from.
	ReadTGZToURL(ctx context.Context, in *ReadTGZToURLRequest, opts ...grpc.CallOption) (*ReadTGZToURLResponse, error)
	// RemoveFiles removes files or directories from the gomote instance.
	RemoveFiles(ctx context.Context, in *RemoveFilesRequest, opts ...grpc.CallOption) (*RemoveFilesResponse, error)
	// SignSSHKey signs an SSH public key which can be used to SSH into instances owned by the caller.
	SignSSHKey(ctx context.Context, in *SignSSHKeyRequest, opts ...grpc.CallOption) (*SignSSHKeyResponse, error)
	// UploadFile generates a signed URL and associated fields to be used when uploading the object to GCS. Once uploaded
	// the corresponding Write endpoint can be used to send the file to the gomote instance.
	UploadFile(ctx context.Context, in *UploadFileRequest, opts ...grpc.CallOption) (*UploadFileResponse, error)
	// WriteFileFromURL
	WriteFileFromURL(ctx context.Context, in *WriteFileFromURLRequest, opts ...grpc.CallOption) (*WriteFileFromURLResponse, error)
	// WriteTGZFromURL retrieves a tar and zipped file from a URL and expands it onto the file system of a gomote instance.
	WriteTGZFromURL(ctx context.Context, in *WriteTGZFromURLRequest, opts ...grpc.CallOption) (*WriteTGZFromURLResponse, error)
}

GomoteServiceClient is the client API for GomoteService service.

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.

GomoteService can manage the lifecycle of gomote instances and interact with them.

func NewGomoteServiceClient 

func NewGomoteServiceClient(cc grpc.ClientConnInterface) GomoteServiceClient

type GomoteServiceServer 

type GomoteServiceServer interface {
	// Authenticate provides authentication information without any additional action.
	Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error)
	// AddBootstrap adds the bootstrap version of Go to the work directory.
	AddBootstrap(context.Context, *AddBootstrapRequest) (*AddBootstrapResponse, error)
	// CreateInstance creates a gomote instance.
	CreateInstance(*CreateInstanceRequest, grpc.ServerStreamingServer[CreateInstanceResponse]) error
	// DestroyInstance destroys a gomote instance.
	DestroyInstance(context.Context, *DestroyInstanceRequest) (*DestroyInstanceResponse, error)
	// ExecuteCommand executes a command on the gomote instance.
	ExecuteCommand(*ExecuteCommandRequest, grpc.ServerStreamingServer[ExecuteCommandResponse]) error
	// InstanceAlive gives the liveness state of a gomote instance.
	InstanceAlive(context.Context, *InstanceAliveRequest) (*InstanceAliveResponse, error)
	// ListDirectory lists the contents of a directory on an gomote instance.
	ListDirectory(context.Context, *ListDirectoryRequest) (*ListDirectoryResponse, error)
	// ListDirectoryStreaming lists the contents of a directory on an gomote instance.
	ListDirectoryStreaming(*ListDirectoryRequest, grpc.ServerStreamingServer[ListDirectoryResponse]) error
	// ListInstances lists all of the live gomote instances owned by the caller.
	ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
	// ListSwarmingBuilders lists all of the swarming builders for the project.
	ListSwarmingBuilders(context.Context, *ListSwarmingBuildersRequest) (*ListSwarmingBuildersResponse, error)
	// ReadTGZToURL tars and zips a directory which exists on the gomote instance and returns a URL where it can be
	// downloaded from.
	ReadTGZToURL(context.Context, *ReadTGZToURLRequest) (*ReadTGZToURLResponse, error)
	// RemoveFiles removes files or directories from the gomote instance.
	RemoveFiles(context.Context, *RemoveFilesRequest) (*RemoveFilesResponse, error)
	// SignSSHKey signs an SSH public key which can be used to SSH into instances owned by the caller.
	SignSSHKey(context.Context, *SignSSHKeyRequest) (*SignSSHKeyResponse, error)
	// UploadFile generates a signed URL and associated fields to be used when uploading the object to GCS. Once uploaded
	// the corresponding Write endpoint can be used to send the file to the gomote instance.
	UploadFile(context.Context, *UploadFileRequest) (*UploadFileResponse, error)
	// WriteFileFromURL
	WriteFileFromURL(context.Context, *WriteFileFromURLRequest) (*WriteFileFromURLResponse, error)
	// WriteTGZFromURL retrieves a tar and zipped file from a URL and expands it onto the file system of a gomote instance.
	WriteTGZFromURL(context.Context, *WriteTGZFromURLRequest) (*WriteTGZFromURLResponse, error)
	// contains filtered or unexported methods
}

GomoteServiceServer is the server API for GomoteService service. All implementations must embed UnimplementedGomoteServiceServer for forward compatibility.

GomoteService can manage the lifecycle of gomote instances and interact with them.

type GomoteService_CreateInstanceClient 

type GomoteService_CreateInstanceClient = grpc.ServerStreamingClient[CreateInstanceResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GomoteService_CreateInstanceServer 

type GomoteService_CreateInstanceServer = grpc.ServerStreamingServer[CreateInstanceResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GomoteService_ExecuteCommandClient 

type GomoteService_ExecuteCommandClient = grpc.ServerStreamingClient[ExecuteCommandResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GomoteService_ExecuteCommandServer 

type GomoteService_ExecuteCommandServer = grpc.ServerStreamingServer[ExecuteCommandResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GomoteService_ListDirectoryStreamingClient 

type GomoteService_ListDirectoryStreamingClient = grpc.ServerStreamingClient[ListDirectoryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GomoteService_ListDirectoryStreamingServer 

type GomoteService_ListDirectoryStreamingServer = grpc.ServerStreamingServer[ListDirectoryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Instance 

type Instance struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// Builder type for the gomote instance.
	BuilderType string `protobuf:"bytes,2,opt,name=builder_type,json=builderType,proto3" json:"builder_type,omitempty"`
	// Host type for the gomote instance.
	HostType string `protobuf:"bytes,3,opt,name=host_type,json=hostType,proto3" json:"host_type,omitempty"`
	// The timestamp for when the builder instance will expire. It is
	// represented in Unix epoch time format.
	Expires int64 `protobuf:"varint,4,opt,name=expires,proto3" json:"expires,omitempty"`
	// The working directory of the instance.
	WorkingDir string `protobuf:"bytes,5,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	// contains filtered or unexported fields
}

Instance contains descriptive information about a gomote instance.

func (*Instance) Descriptor deprecated 

func (*Instance) Descriptor() ([]byte, []int)

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetBuilderType 

func (x *Instance) GetBuilderType() string

func (*Instance) GetExpires 

func (x *Instance) GetExpires() int64

func (*Instance) GetGomoteId 

func (x *Instance) GetGomoteId() string

func (*Instance) GetHostType 

func (x *Instance) GetHostType() string

func (*Instance) GetWorkingDir 

func (x *Instance) GetWorkingDir() string

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect 

func (x *Instance) ProtoReflect() protoreflect.Message

func (*Instance) Reset 

func (x *Instance) Reset()

func (*Instance) String 

func (x *Instance) String() string

type InstanceAliveRequest 

type InstanceAliveRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// contains filtered or unexported fields
}

InstanceAliveRequest specifies the data needed to check the liveness of a gomote instance.

func (*InstanceAliveRequest) Descriptor deprecated 

func (*InstanceAliveRequest) Descriptor() ([]byte, []int)

Deprecated: Use InstanceAliveRequest.ProtoReflect.Descriptor instead.

func (*InstanceAliveRequest) GetGomoteId 

func (x *InstanceAliveRequest) GetGomoteId() string

func (*InstanceAliveRequest) ProtoMessage 

func (*InstanceAliveRequest) ProtoMessage()

func (*InstanceAliveRequest) ProtoReflect 

func (x *InstanceAliveRequest) ProtoReflect() protoreflect.Message

func (*InstanceAliveRequest) Reset 

func (x *InstanceAliveRequest) Reset()

func (*InstanceAliveRequest) String 

func (x *InstanceAliveRequest) String() string

type InstanceAliveResponse 

type InstanceAliveResponse struct {
	// contains filtered or unexported fields
}

InstanceAliveResponse contains instance liveness state.

func (*InstanceAliveResponse) Descriptor deprecated 

func (*InstanceAliveResponse) Descriptor() ([]byte, []int)

Deprecated: Use InstanceAliveResponse.ProtoReflect.Descriptor instead.

func (*InstanceAliveResponse) ProtoMessage 

func (*InstanceAliveResponse) ProtoMessage()

func (*InstanceAliveResponse) ProtoReflect 

func (x *InstanceAliveResponse) ProtoReflect() protoreflect.Message

func (*InstanceAliveResponse) Reset 

func (x *InstanceAliveResponse) Reset()

func (*InstanceAliveResponse) String 

func (x *InstanceAliveResponse) String() string

type ListDirectoryRequest 

type ListDirectoryRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// The directory to list the contents of. The directory dir itself is not included.
	Directory string `protobuf:"bytes,2,opt,name=directory,proto3" json:"directory,omitempty"`
	// Controls whether the directory is listed recursively.
	Recursive bool `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// The directories to skip, relative to the main directory.
	// Each item should contain only forward slashes and not start or end in slashes.
	SkipFiles []string `protobuf:"bytes,4,rep,name=skip_files,json=skipFiles,proto3" json:"skip_files,omitempty"`
	// Controls whether the SHA-1 of regular files are returned.
	Digest bool `protobuf:"varint,5,opt,name=digest,proto3" json:"digest,omitempty"`
	// contains filtered or unexported fields
}

ListDirectoryRequest specifies the data needed to list contents of a directory from a gomote instance.

func (*ListDirectoryRequest) Descriptor deprecated 

func (*ListDirectoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListDirectoryRequest.ProtoReflect.Descriptor instead.

func (*ListDirectoryRequest) GetDigest 

func (x *ListDirectoryRequest) GetDigest() bool

func (*ListDirectoryRequest) GetDirectory 

func (x *ListDirectoryRequest) GetDirectory() string

func (*ListDirectoryRequest) GetGomoteId 

func (x *ListDirectoryRequest) GetGomoteId() string

func (*ListDirectoryRequest) GetRecursive 

func (x *ListDirectoryRequest) GetRecursive() bool

func (*ListDirectoryRequest) GetSkipFiles 

func (x *ListDirectoryRequest) GetSkipFiles() []string

func (*ListDirectoryRequest) ProtoMessage 

func (*ListDirectoryRequest) ProtoMessage()

func (*ListDirectoryRequest) ProtoReflect 

func (x *ListDirectoryRequest) ProtoReflect() protoreflect.Message

func (*ListDirectoryRequest) Reset 

func (x *ListDirectoryRequest) Reset()

func (*ListDirectoryRequest) String 

func (x *ListDirectoryRequest) String() string

type ListDirectoryResponse 

type ListDirectoryResponse struct {

	// The directory entries.
	Entries []string `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

ListDirectoryResponse contains the directory listing of a gomote instance.

func (*ListDirectoryResponse) Descriptor deprecated 

func (*ListDirectoryResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListDirectoryResponse.ProtoReflect.Descriptor instead.

func (*ListDirectoryResponse) GetEntries 

func (x *ListDirectoryResponse) GetEntries() []string

func (*ListDirectoryResponse) ProtoMessage 

func (*ListDirectoryResponse) ProtoMessage()

func (*ListDirectoryResponse) ProtoReflect 

func (x *ListDirectoryResponse) ProtoReflect() protoreflect.Message

func (*ListDirectoryResponse) Reset 

func (x *ListDirectoryResponse) Reset()

func (*ListDirectoryResponse) String 

func (x *ListDirectoryResponse) String() string

type ListInstancesRequest 

type ListInstancesRequest struct {
	// contains filtered or unexported fields
}

ListInstancesRequest specifies the data needed to list the live gomote instances owned by the caller.

func (*ListInstancesRequest) Descriptor deprecated 

func (*ListInstancesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListInstancesRequest.ProtoReflect.Descriptor instead.

func (*ListInstancesRequest) ProtoMessage 

func (*ListInstancesRequest) ProtoMessage()

func (*ListInstancesRequest) ProtoReflect 

func (x *ListInstancesRequest) ProtoReflect() protoreflect.Message

func (*ListInstancesRequest) Reset 

func (x *ListInstancesRequest) Reset()

func (*ListInstancesRequest) String 

func (x *ListInstancesRequest) String() string

type ListInstancesResponse 

type ListInstancesResponse struct {
	Instances []*Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

ListInstancesResponse contains the list of live gomote instances owned by the caller.

func (*ListInstancesResponse) Descriptor deprecated 

func (*ListInstancesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListInstancesResponse.ProtoReflect.Descriptor instead.

func (*ListInstancesResponse) GetInstances 

func (x *ListInstancesResponse) GetInstances() []*Instance

func (*ListInstancesResponse) ProtoMessage 

func (*ListInstancesResponse) ProtoMessage()

func (*ListInstancesResponse) ProtoReflect 

func (x *ListInstancesResponse) ProtoReflect() protoreflect.Message

func (*ListInstancesResponse) Reset 

func (x *ListInstancesResponse) Reset()

func (*ListInstancesResponse) String 

func (x *ListInstancesResponse) String() string

type ListSwarmingBuildersRequest 

type ListSwarmingBuildersRequest struct {
	// contains filtered or unexported fields
}

ListSwarmingBuildersRequest specifies the data needed to list all swarming builders.

func (*ListSwarmingBuildersRequest) Descriptor deprecated 

func (*ListSwarmingBuildersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSwarmingBuildersRequest.ProtoReflect.Descriptor instead.

func (*ListSwarmingBuildersRequest) ProtoMessage 

func (*ListSwarmingBuildersRequest) ProtoMessage()

func (*ListSwarmingBuildersRequest) ProtoReflect 

func (x *ListSwarmingBuildersRequest) ProtoReflect() protoreflect.Message

func (*ListSwarmingBuildersRequest) Reset 

func (x *ListSwarmingBuildersRequest) Reset()

func (*ListSwarmingBuildersRequest) String 

func (x *ListSwarmingBuildersRequest) String() string

type ListSwarmingBuildersResponse 

type ListSwarmingBuildersResponse struct {
	Builders []string `protobuf:"bytes,1,rep,name=builders,proto3" json:"builders,omitempty"`
	// contains filtered or unexported fields
}

ListSwarmingBuildersResponse contains a list of swarming builders.

func (*ListSwarmingBuildersResponse) Descriptor deprecated 

func (*ListSwarmingBuildersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListSwarmingBuildersResponse.ProtoReflect.Descriptor instead.

func (*ListSwarmingBuildersResponse) GetBuilders 

func (x *ListSwarmingBuildersResponse) GetBuilders() []string

func (*ListSwarmingBuildersResponse) ProtoMessage 

func (*ListSwarmingBuildersResponse) ProtoMessage()

func (*ListSwarmingBuildersResponse) ProtoReflect 

func (x *ListSwarmingBuildersResponse) ProtoReflect() protoreflect.Message

func (*ListSwarmingBuildersResponse) Reset 

func (x *ListSwarmingBuildersResponse) Reset()

func (*ListSwarmingBuildersResponse) String 

func (x *ListSwarmingBuildersResponse) String() string

type ReadTGZToURLRequest 

type ReadTGZToURLRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// The relative directory from the gomote's work directory to tar up.
	Directory string `protobuf:"bytes,2,opt,name=directory,proto3" json:"directory,omitempty"`
	// contains filtered or unexported fields
}

ReadTGZToURLRequest specifies the data needed to retrieve a tar and zipped directory from a gomote instance.

func (*ReadTGZToURLRequest) Descriptor deprecated 

func (*ReadTGZToURLRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadTGZToURLRequest.ProtoReflect.Descriptor instead.

func (*ReadTGZToURLRequest) GetDirectory 

func (x *ReadTGZToURLRequest) GetDirectory() string

func (*ReadTGZToURLRequest) GetGomoteId 

func (x *ReadTGZToURLRequest) GetGomoteId() string

func (*ReadTGZToURLRequest) ProtoMessage 

func (*ReadTGZToURLRequest) ProtoMessage()

func (*ReadTGZToURLRequest) ProtoReflect 

func (x *ReadTGZToURLRequest) ProtoReflect() protoreflect.Message

func (*ReadTGZToURLRequest) Reset 

func (x *ReadTGZToURLRequest) Reset()

func (*ReadTGZToURLRequest) String 

func (x *ReadTGZToURLRequest) String() string

type ReadTGZToURLResponse 

type ReadTGZToURLResponse struct {

	// URL to retrieve the tarball from.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

ReadTGZToURLResponse contains a URL where the tar and zipped directory from a gomote instance can be downloaded from.

func (*ReadTGZToURLResponse) Descriptor deprecated 

func (*ReadTGZToURLResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReadTGZToURLResponse.ProtoReflect.Descriptor instead.

func (*ReadTGZToURLResponse) GetUrl 

func (x *ReadTGZToURLResponse) GetUrl() string

func (*ReadTGZToURLResponse) ProtoMessage 

func (*ReadTGZToURLResponse) ProtoMessage()

func (*ReadTGZToURLResponse) ProtoReflect 

func (x *ReadTGZToURLResponse) ProtoReflect() protoreflect.Message

func (*ReadTGZToURLResponse) Reset 

func (x *ReadTGZToURLResponse) Reset()

func (*ReadTGZToURLResponse) String 

func (x *ReadTGZToURLResponse) String() string

type RemoveFilesRequest 

type RemoveFilesRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// The list of paths for files or directories to remove from the file system.
	// When everything should be deleted, "." should be used.
	// The paths are relative to the work directory.
	Paths []string `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

RemoveFilesRequest specifies the data needed to remove files or directories from a gomote instance.

func (*RemoveFilesRequest) Descriptor deprecated 

func (*RemoveFilesRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveFilesRequest.ProtoReflect.Descriptor instead.

func (*RemoveFilesRequest) GetGomoteId 

func (x *RemoveFilesRequest) GetGomoteId() string

func (*RemoveFilesRequest) GetPaths 

func (x *RemoveFilesRequest) GetPaths() []string

func (*RemoveFilesRequest) ProtoMessage 

func (*RemoveFilesRequest) ProtoMessage()

func (*RemoveFilesRequest) ProtoReflect 

func (x *RemoveFilesRequest) ProtoReflect() protoreflect.Message

func (*RemoveFilesRequest) Reset 

func (x *RemoveFilesRequest) Reset()

func (*RemoveFilesRequest) String 

func (x *RemoveFilesRequest) String() string

type RemoveFilesResponse 

type RemoveFilesResponse struct {
	// contains filtered or unexported fields
}

RemoveFilesResponse contains the results from removing files or directories from a gomote instance.

func (*RemoveFilesResponse) Descriptor deprecated 

func (*RemoveFilesResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveFilesResponse.ProtoReflect.Descriptor instead.

func (*RemoveFilesResponse) ProtoMessage 

func (*RemoveFilesResponse) ProtoMessage()

func (*RemoveFilesResponse) ProtoReflect 

func (x *RemoveFilesResponse) ProtoReflect() protoreflect.Message

func (*RemoveFilesResponse) Reset 

func (x *RemoveFilesResponse) Reset()

func (*RemoveFilesResponse) String 

func (x *RemoveFilesResponse) String() string

type SignSSHKeyRequest 

type SignSSHKeyRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// A user provided public SSH key which the user intends to initiate an SSH session with.
	PublicSshKey []byte `protobuf:"bytes,2,opt,name=public_ssh_key,json=publicSshKey,proto3" json:"public_ssh_key,omitempty"`
	// contains filtered or unexported fields
}

SignSSHKeyRequest specifies the data needed to sign a public SSH key which attaches a certificate to the key.

func (*SignSSHKeyRequest) Descriptor deprecated 

func (*SignSSHKeyRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignSSHKeyRequest.ProtoReflect.Descriptor instead.

func (*SignSSHKeyRequest) GetGomoteId 

func (x *SignSSHKeyRequest) GetGomoteId() string

func (*SignSSHKeyRequest) GetPublicSshKey 

func (x *SignSSHKeyRequest) GetPublicSshKey() []byte

func (*SignSSHKeyRequest) ProtoMessage 

func (*SignSSHKeyRequest) ProtoMessage()

func (*SignSSHKeyRequest) ProtoReflect 

func (x *SignSSHKeyRequest) ProtoReflect() protoreflect.Message

func (*SignSSHKeyRequest) Reset 

func (x *SignSSHKeyRequest) Reset()

func (*SignSSHKeyRequest) String 

func (x *SignSSHKeyRequest) String() string

type SignSSHKeyResponse 

type SignSSHKeyResponse struct {

	// A signed SSH key can be used in conjunction with the associated private key to initiate an SSH session to a gomote instance.
	// The certificate attached to the key will contain principles which restrict the instance that can be logged into.
	SignedPublicSshKey []byte `protobuf:"bytes,1,opt,name=signed_public_ssh_key,json=signedPublicSshKey,proto3" json:"signed_public_ssh_key,omitempty"`
	// contains filtered or unexported fields
}

SignSSHKeyResponse contains the results from a request to sign a public SSH key.

func (*SignSSHKeyResponse) Descriptor deprecated 

func (*SignSSHKeyResponse) Descriptor() ([]byte, []int)

Deprecated: Use SignSSHKeyResponse.ProtoReflect.Descriptor instead.

func (*SignSSHKeyResponse) GetSignedPublicSshKey 

func (x *SignSSHKeyResponse) GetSignedPublicSshKey() []byte

func (*SignSSHKeyResponse) ProtoMessage 

func (*SignSSHKeyResponse) ProtoMessage()

func (*SignSSHKeyResponse) ProtoReflect 

func (x *SignSSHKeyResponse) ProtoReflect() protoreflect.Message

func (*SignSSHKeyResponse) Reset 

func (x *SignSSHKeyResponse) Reset()

func (*SignSSHKeyResponse) String 

func (x *SignSSHKeyResponse) String() string

type UnimplementedGomoteServiceServer 

type UnimplementedGomoteServiceServer struct{}

UnimplementedGomoteServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedGomoteServiceServer) AddBootstrap 

func (UnimplementedGomoteServiceServer) AddBootstrap(context.Context, *AddBootstrapRequest) (*AddBootstrapResponse, error)

func (UnimplementedGomoteServiceServer) Authenticate 

func (UnimplementedGomoteServiceServer) Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error)

func (UnimplementedGomoteServiceServer) CreateInstance 

func (UnimplementedGomoteServiceServer) CreateInstance(*CreateInstanceRequest, grpc.ServerStreamingServer[CreateInstanceResponse]) error

func (UnimplementedGomoteServiceServer) DestroyInstance 

func (UnimplementedGomoteServiceServer) DestroyInstance(context.Context, *DestroyInstanceRequest) (*DestroyInstanceResponse, error)

func (UnimplementedGomoteServiceServer) ExecuteCommand 

func (UnimplementedGomoteServiceServer) ExecuteCommand(*ExecuteCommandRequest, grpc.ServerStreamingServer[ExecuteCommandResponse]) error

func (UnimplementedGomoteServiceServer) InstanceAlive 

func (UnimplementedGomoteServiceServer) InstanceAlive(context.Context, *InstanceAliveRequest) (*InstanceAliveResponse, error)

func (UnimplementedGomoteServiceServer) ListDirectory 

func (UnimplementedGomoteServiceServer) ListDirectory(context.Context, *ListDirectoryRequest) (*ListDirectoryResponse, error)

func (UnimplementedGomoteServiceServer) ListDirectoryStreaming 

func (UnimplementedGomoteServiceServer) ListDirectoryStreaming(*ListDirectoryRequest, grpc.ServerStreamingServer[ListDirectoryResponse]) error

func (UnimplementedGomoteServiceServer) ListInstances 

func (UnimplementedGomoteServiceServer) ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)

func (UnimplementedGomoteServiceServer) ListSwarmingBuilders 

func (UnimplementedGomoteServiceServer) ListSwarmingBuilders(context.Context, *ListSwarmingBuildersRequest) (*ListSwarmingBuildersResponse, error)

func (UnimplementedGomoteServiceServer) ReadTGZToURL 

func (UnimplementedGomoteServiceServer) ReadTGZToURL(context.Context, *ReadTGZToURLRequest) (*ReadTGZToURLResponse, error)

func (UnimplementedGomoteServiceServer) RemoveFiles 

func (UnimplementedGomoteServiceServer) RemoveFiles(context.Context, *RemoveFilesRequest) (*RemoveFilesResponse, error)

func (UnimplementedGomoteServiceServer) SignSSHKey 

func (UnimplementedGomoteServiceServer) SignSSHKey(context.Context, *SignSSHKeyRequest) (*SignSSHKeyResponse, error)

func (UnimplementedGomoteServiceServer) UploadFile 

func (UnimplementedGomoteServiceServer) UploadFile(context.Context, *UploadFileRequest) (*UploadFileResponse, error)

func (UnimplementedGomoteServiceServer) WriteFileFromURL 

func (UnimplementedGomoteServiceServer) WriteFileFromURL(context.Context, *WriteFileFromURLRequest) (*WriteFileFromURLResponse, error)

func (UnimplementedGomoteServiceServer) WriteTGZFromURL 

func (UnimplementedGomoteServiceServer) WriteTGZFromURL(context.Context, *WriteTGZFromURLRequest) (*WriteTGZFromURLResponse, error)

type UnsafeGomoteServiceServer 

type UnsafeGomoteServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeGomoteServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GomoteServiceServer will result in compilation errors.

type UploadFileRequest 

type UploadFileRequest struct {
	// contains filtered or unexported fields
}

UploadFileRequest specifies the data needed to create a request to upload an object to GCS.

func (*UploadFileRequest) Descriptor deprecated 

func (*UploadFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use UploadFileRequest.ProtoReflect.Descriptor instead.

func (*UploadFileRequest) ProtoMessage 

func (*UploadFileRequest) ProtoMessage()

func (*UploadFileRequest) ProtoReflect 

func (x *UploadFileRequest) ProtoReflect() protoreflect.Message

func (*UploadFileRequest) Reset 

func (x *UploadFileRequest) Reset()

func (*UploadFileRequest) String 

func (x *UploadFileRequest) String() string

type UploadFileResponse 

type UploadFileResponse struct {

	// URL to post file to.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Form fields used when http posting files to GCS.
	Fields map[string]string `` /* 153-byte string literal not displayed */
	// Name used to reference the object.
	ObjectName string `protobuf:"bytes,3,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// contains filtered or unexported fields
}

UploadFileResponse contains the results from a request to upload an object to GCS.

func (*UploadFileResponse) Descriptor deprecated 

func (*UploadFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use UploadFileResponse.ProtoReflect.Descriptor instead.

func (*UploadFileResponse) GetFields 

func (x *UploadFileResponse) GetFields() map[string]string

func (*UploadFileResponse) GetObjectName 

func (x *UploadFileResponse) GetObjectName() string

func (*UploadFileResponse) GetUrl 

func (x *UploadFileResponse) GetUrl() string

func (*UploadFileResponse) ProtoMessage 

func (*UploadFileResponse) ProtoMessage()

func (*UploadFileResponse) ProtoReflect 

func (x *UploadFileResponse) ProtoReflect() protoreflect.Message

func (*UploadFileResponse) Reset 

func (x *UploadFileResponse) Reset()

func (*UploadFileResponse) String 

func (x *UploadFileResponse) String() string

type WriteFileFromURLRequest 

type WriteFileFromURLRequest struct {

	// The unique identifier for a gomote instance.
	GomoteId string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	// URL to post get file from.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// The filename as it should appear at the destination.
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	// The file mode.
	Mode uint32 `protobuf:"fixed32,4,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

WriteFileFromURLRequest specifies the data needed to request that a gomote download the contents of a URL and place the contents in a file.

func (*WriteFileFromURLRequest) Descriptor deprecated 

func (*WriteFileFromURLRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteFileFromURLRequest.ProtoReflect.Descriptor instead.

func (*WriteFileFromURLRequest) GetFilename 

func (x *WriteFileFromURLRequest) GetFilename() string

func (*WriteFileFromURLRequest) GetGomoteId 

func (x *WriteFileFromURLRequest) GetGomoteId() string

func (*WriteFileFromURLRequest) GetMode 

func (x *WriteFileFromURLRequest) GetMode() uint32

func (*WriteFileFromURLRequest) GetUrl 

func (x *WriteFileFromURLRequest) GetUrl() string

func (*WriteFileFromURLRequest) ProtoMessage 

func (*WriteFileFromURLRequest) ProtoMessage()

func (*WriteFileFromURLRequest) ProtoReflect 

func (x *WriteFileFromURLRequest) ProtoReflect() protoreflect.Message

func (*WriteFileFromURLRequest) Reset 

func (x *WriteFileFromURLRequest) Reset()

func (*WriteFileFromURLRequest) String 

func (x *WriteFileFromURLRequest) String() string

type WriteFileFromURLResponse 

type WriteFileFromURLResponse struct {
	// contains filtered or unexported fields
}

WriteFileFromURLResponse contains the results from requesting that a file be downloaded onto a gomote instance.

func (*WriteFileFromURLResponse) Descriptor deprecated 

func (*WriteFileFromURLResponse) Descriptor() ([]byte, []int)

Deprecated: Use WriteFileFromURLResponse.ProtoReflect.Descriptor instead.

func (*WriteFileFromURLResponse) ProtoMessage 

func (*WriteFileFromURLResponse) ProtoMessage()

func (*WriteFileFromURLResponse) ProtoReflect 

func (x *WriteFileFromURLResponse) ProtoReflect() protoreflect.Message

func (*WriteFileFromURLResponse) Reset 

func (x *WriteFileFromURLResponse) Reset()

func (*WriteFileFromURLResponse) String 

func (x *WriteFileFromURLResponse) String() string

type WriteTGZFromURLRequest 

type WriteTGZFromURLRequest struct {
	GomoteId  string `protobuf:"bytes,1,opt,name=gomote_id,json=gomoteId,proto3" json:"gomote_id,omitempty"`
	Url       string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Directory string `protobuf:"bytes,3,opt,name=directory,proto3" json:"directory,omitempty"`
	// contains filtered or unexported fields
}

WriteTGZFromURLRequest specifies the data needed to retrieve a file and expand it onto the file system of a gomote instance. It instructs the buildlet to download the tar.gz file from the url and write it to a directory, a relative directory from the workdir. If the directory is empty, they're placed at the root of the buildlet's work directory. The directory is created if necessary. The url must be of a tar.gz file.

func (*WriteTGZFromURLRequest) Descriptor deprecated 

func (*WriteTGZFromURLRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteTGZFromURLRequest.ProtoReflect.Descriptor instead.

func (*WriteTGZFromURLRequest) GetDirectory 

func (x *WriteTGZFromURLRequest) GetDirectory() string

func (*WriteTGZFromURLRequest) GetGomoteId 

func (x *WriteTGZFromURLRequest) GetGomoteId() string

func (*WriteTGZFromURLRequest) GetUrl 

func (x *WriteTGZFromURLRequest) GetUrl() string

func (*WriteTGZFromURLRequest) ProtoMessage 

func (*WriteTGZFromURLRequest) ProtoMessage()

func (*WriteTGZFromURLRequest) ProtoReflect 

func (x *WriteTGZFromURLRequest) ProtoReflect() protoreflect.Message

func (*WriteTGZFromURLRequest) Reset 

func (x *WriteTGZFromURLRequest) Reset()

func (*WriteTGZFromURLRequest) String 

func (x *WriteTGZFromURLRequest) String() string

type WriteTGZFromURLResponse 

type WriteTGZFromURLResponse struct {
	// contains filtered or unexported fields
}

WriteTGZFromURLResponse contains the results from retrieving a file and expanding it onto the file system of a gomote instance.

func (*WriteTGZFromURLResponse) Descriptor deprecated 

func (*WriteTGZFromURLResponse) Descriptor() ([]byte, []int)

Deprecated: Use WriteTGZFromURLResponse.ProtoReflect.Descriptor instead.

func (*WriteTGZFromURLResponse) ProtoMessage 

func (*WriteTGZFromURLResponse) ProtoMessage()

func (*WriteTGZFromURLResponse) ProtoReflect 

func (x *WriteTGZFromURLResponse) ProtoReflect() protoreflect.Message

func (*WriteTGZFromURLResponse) Reset 

func (x *WriteTGZFromURLResponse) Reset()

func (*WriteTGZFromURLResponse) String 

func (x *WriteTGZFromURLResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.