crostoolrunner

package
v0.0.0-...-40fa89b Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2025 License: BSD-3-Clause Imports: 20 Imported by: 0

Documentation

Overview

Package crostoolrunner includes all CTR logic.

Package mocked_services is a generated GoMock package.

Index

Constants

View Source 
const (
	Oauth2Username = "oauth2accesstoken"
	Oauth2Password = "$(gcloud auth print-access-token)"
	ImageRegistry  = "us-docker.pkg.dev"
)

Variables

View Source 
var BackoffFunc = backoffFunc

BackoffFunc exposed for test override.

Functions

This section is empty.

Types

type CrosToolRunner 

type CrosToolRunner struct {
	CtrCipdInfo

	CtrClient         testapi.CrosToolRunnerContainerServiceClient
	EnvVarsToPreserve []string

	NoSudo bool
	// contains filtered or unexported fields
}

CrosToolRunner represents the tool that enables communicating with CTRv2.

func (*CrosToolRunner) ConnectToCTRServer 

func (ctr *CrosToolRunner) ConnectToCTRServer(
	ctx context.Context,
	serverAddress string) (_ testapi.CrosToolRunnerContainerServiceClient, err error)

ConnectToCTRServer connects to the CTR server in provided server address.

func (*CrosToolRunner) CreateNetwork 

func (ctr *CrosToolRunner) CreateNetwork(
	ctx context.Context,
	networkName string) (_ *testapi.CreateNetworkResponse, err error)

CreateNetwork creates a bridge network with the provided name.

func (*CrosToolRunner) GcloudAuth 

func (ctr *CrosToolRunner) GcloudAuth(
	ctx context.Context,
	dockerFileLocation string,
	useDockerKeyDirectly bool) (_ *testapi.LoginRegistryResponse, err error)

GcloudAuth does auth to the registry.

func (*CrosToolRunner) GetContainer 

func (ctr *CrosToolRunner) GetContainer(
	ctx context.Context,
	containerName string) (_ *testapi.GetContainerResponse, err error)

GetContainer gets the container with provided name.

func (*CrosToolRunner) GetNetwork 

func (ctr *CrosToolRunner) GetNetwork(
	ctx context.Context,
	networkName string) (_ *testapi.GetNetworkResponse, err error)

GetNetwork provides the network ID of the provided name if it exists.

func (*CrosToolRunner) GetServerAddressFromServiceMetadata 

func (ctr *CrosToolRunner) GetServerAddressFromServiceMetadata(ctx context.Context) (_ string, err error)

GetServerAddressFromServiceMetadata waits for the service metadata file and gets ctr server address from it.

func (*CrosToolRunner) StartCTRServer 

func (ctr *CrosToolRunner) StartCTRServer(ctx context.Context) (err error)

StartCTRServer starts the server and exports service metadata to already created temp dir.

func (*CrosToolRunner) StartCTRServerAsync 

func (ctr *CrosToolRunner) StartCTRServerAsync(ctx context.Context) (err error)

StartCTRServerAsync starts the server asynchronously. This is necessary as we would want the server to run in background.

func (*CrosToolRunner) StartContainer 

func (ctr *CrosToolRunner) StartContainer(
	ctx context.Context,
	startContainerReq *testapi.StartContainerRequest) (_ *testapi.StartContainerResponse, err error)

StartContainer starts a non-templated container using ctr client.

func (*CrosToolRunner) StartTemplatedContainer 

func (ctr *CrosToolRunner) StartTemplatedContainer(
	ctx context.Context,
	startContainerReq *testapi.StartTemplatedContainerRequest) (_ *testapi.StartContainerResponse, err error)

StartTemplatedContainer starts a templated container using ctr client.

func (*CrosToolRunner) StopCTRServer 

func (ctr *CrosToolRunner) StopCTRServer(ctx context.Context) error

StopCTRServer stops currently running CTR server.

func (*CrosToolRunner) StopContainer 

func (ctr *CrosToolRunner) StopContainer(ctx context.Context, containerName string) (err error)

StopContainer stops the container with provided name.

type CtrCipdInfo 

type CtrCipdInfo struct {
	Version        string
	IsInitialized  bool
	CtrPath        string
	CtrCipdPackage string
	CtrTempDirLoc  string
}

CtrCipdInfo represents Ctr cipd related info.

func (*CtrCipdInfo) Initialize 

func (ctrCipd *CtrCipdInfo) Initialize(ctx context.Context) error

Initialize initializes Ctr.

func (*CtrCipdInfo) Validate 

func (ctrCipd *CtrCipdInfo) Validate(ctx context.Context) error

Validate validates required ctr cipd info.

type MockCrosToolRunnerContainerServiceClient 

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

MockCrosToolRunnerContainerServiceClient is a mock of CrosToolRunnerContainerServiceClient interface.

func NewMockCrosToolRunnerContainerServiceClient 

func NewMockCrosToolRunnerContainerServiceClient(ctrl *gomock.Controller) *MockCrosToolRunnerContainerServiceClient

NewMockCrosToolRunnerContainerServiceClient creates a new mock instance.

func (*MockCrosToolRunnerContainerServiceClient) CreateNetwork 

func (m *MockCrosToolRunnerContainerServiceClient) CreateNetwork(ctx context.Context, in *api.CreateNetworkRequest, opts ...grpc.CallOption) (*api.CreateNetworkResponse, error)

CreateNetwork mocks base method.

func (*MockCrosToolRunnerContainerServiceClient) EXPECT 

func (m *MockCrosToolRunnerContainerServiceClient) EXPECT() *MockCrosToolRunnerContainerServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCrosToolRunnerContainerServiceClient) GetContainer 

func (m *MockCrosToolRunnerContainerServiceClient) GetContainer(ctx context.Context, in *api.GetContainerRequest, opts ...grpc.CallOption) (*api.GetContainerResponse, error)

GetContainer mocks base method.

func (*MockCrosToolRunnerContainerServiceClient) GetNetwork 

func (m *MockCrosToolRunnerContainerServiceClient) GetNetwork(ctx context.Context, in *api.GetNetworkRequest, opts ...grpc.CallOption) (*api.GetNetworkResponse, error)

GetNetwork mocks base method.

func (*MockCrosToolRunnerContainerServiceClient) LoginRegistry 

func (m *MockCrosToolRunnerContainerServiceClient) LoginRegistry(ctx context.Context, in *api.LoginRegistryRequest, opts ...grpc.CallOption) (*api.LoginRegistryResponse, error)

LoginRegistry mocks base method.

func (*MockCrosToolRunnerContainerServiceClient) Shutdown 

func (m *MockCrosToolRunnerContainerServiceClient) Shutdown(ctx context.Context, in *api.ShutdownRequest, opts ...grpc.CallOption) (*api.ShutdownResponse, error)

Shutdown mocks base method.

func (*MockCrosToolRunnerContainerServiceClient) StackCommands 

func (m *MockCrosToolRunnerContainerServiceClient) StackCommands(ctx context.Context, in *api.StackCommandsRequest, opts ...grpc.CallOption) (*api.StackCommandsResponse, error)

StackCommands mocks base method.

func (*MockCrosToolRunnerContainerServiceClient) StartContainer 

func (m *MockCrosToolRunnerContainerServiceClient) StartContainer(ctx context.Context, in *api.StartContainerRequest, opts ...grpc.CallOption) (*api.StartContainerResponse, error)

StartContainer mocks base method.

func (*MockCrosToolRunnerContainerServiceClient) StartTemplatedContainer 

func (m *MockCrosToolRunnerContainerServiceClient) StartTemplatedContainer(ctx context.Context, in *api.StartTemplatedContainerRequest, opts ...grpc.CallOption) (*api.StartContainerResponse, error)

StartTemplatedContainer mocks base method.

type MockCrosToolRunnerContainerServiceClientMockRecorder 

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

MockCrosToolRunnerContainerServiceClientMockRecorder is the mock recorder for MockCrosToolRunnerContainerServiceClient.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) CreateNetwork 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) CreateNetwork(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateNetwork indicates an expected call of CreateNetwork.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) GetContainer 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) GetContainer(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetContainer indicates an expected call of GetContainer.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) GetNetwork 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) GetNetwork(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetNetwork indicates an expected call of GetNetwork.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) LoginRegistry 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) LoginRegistry(ctx, in interface{}, opts ...interface{}) *gomock.Call

LoginRegistry indicates an expected call of LoginRegistry.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) Shutdown 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) Shutdown(ctx, in interface{}, opts ...interface{}) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) StackCommands 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) StackCommands(ctx, in interface{}, opts ...interface{}) *gomock.Call

StackCommands indicates an expected call of StackCommands.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) StartContainer 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) StartContainer(ctx, in interface{}, opts ...interface{}) *gomock.Call

StartContainer indicates an expected call of StartContainer.

func (*MockCrosToolRunnerContainerServiceClientMockRecorder) StartTemplatedContainer 

func (mr *MockCrosToolRunnerContainerServiceClientMockRecorder) StartTemplatedContainer(ctx, in interface{}, opts ...interface{}) *gomock.Call

StartTemplatedContainer indicates an expected call of StartTemplatedContainer.

type MockCrosToolRunnerContainerServiceServer 

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

MockCrosToolRunnerContainerServiceServer is a mock of CrosToolRunnerContainerServiceServer interface.

func NewMockCrosToolRunnerContainerServiceServer 

func NewMockCrosToolRunnerContainerServiceServer(ctrl *gomock.Controller) *MockCrosToolRunnerContainerServiceServer

NewMockCrosToolRunnerContainerServiceServer creates a new mock instance.

func (*MockCrosToolRunnerContainerServiceServer) CreateNetwork 

func (m *MockCrosToolRunnerContainerServiceServer) CreateNetwork(arg0 context.Context, arg1 *api.CreateNetworkRequest) (*api.CreateNetworkResponse, error)

CreateNetwork mocks base method.

func (*MockCrosToolRunnerContainerServiceServer) EXPECT 

func (m *MockCrosToolRunnerContainerServiceServer) EXPECT() *MockCrosToolRunnerContainerServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCrosToolRunnerContainerServiceServer) GetContainer 

func (m *MockCrosToolRunnerContainerServiceServer) GetContainer(arg0 context.Context, arg1 *api.GetContainerRequest) (*api.GetContainerResponse, error)

GetContainer mocks base method.

func (*MockCrosToolRunnerContainerServiceServer) GetNetwork 

func (m *MockCrosToolRunnerContainerServiceServer) GetNetwork(arg0 context.Context, arg1 *api.GetNetworkRequest) (*api.GetNetworkResponse, error)

GetNetwork mocks base method.

func (*MockCrosToolRunnerContainerServiceServer) LoginRegistry 

func (m *MockCrosToolRunnerContainerServiceServer) LoginRegistry(arg0 context.Context, arg1 *api.LoginRegistryRequest) (*api.LoginRegistryResponse, error)

LoginRegistry mocks base method.

func (*MockCrosToolRunnerContainerServiceServer) Shutdown 

func (m *MockCrosToolRunnerContainerServiceServer) Shutdown(arg0 context.Context, arg1 *api.ShutdownRequest) (*api.ShutdownResponse, error)

Shutdown mocks base method.

func (*MockCrosToolRunnerContainerServiceServer) StackCommands 

func (m *MockCrosToolRunnerContainerServiceServer) StackCommands(arg0 context.Context, arg1 *api.StackCommandsRequest) (*api.StackCommandsResponse, error)

StackCommands mocks base method.

func (*MockCrosToolRunnerContainerServiceServer) StartContainer 

func (m *MockCrosToolRunnerContainerServiceServer) StartContainer(arg0 context.Context, arg1 *api.StartContainerRequest) (*api.StartContainerResponse, error)

StartContainer mocks base method.

func (*MockCrosToolRunnerContainerServiceServer) StartTemplatedContainer 

func (m *MockCrosToolRunnerContainerServiceServer) StartTemplatedContainer(arg0 context.Context, arg1 *api.StartTemplatedContainerRequest) (*api.StartContainerResponse, error)

StartTemplatedContainer mocks base method.

type MockCrosToolRunnerContainerServiceServerMockRecorder 

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

MockCrosToolRunnerContainerServiceServerMockRecorder is the mock recorder for MockCrosToolRunnerContainerServiceServer.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) CreateNetwork 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) CreateNetwork(arg0, arg1 interface{}) *gomock.Call

CreateNetwork indicates an expected call of CreateNetwork.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) GetContainer 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) GetContainer(arg0, arg1 interface{}) *gomock.Call

GetContainer indicates an expected call of GetContainer.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) GetNetwork 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) GetNetwork(arg0, arg1 interface{}) *gomock.Call

GetNetwork indicates an expected call of GetNetwork.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) LoginRegistry 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) LoginRegistry(arg0, arg1 interface{}) *gomock.Call

LoginRegistry indicates an expected call of LoginRegistry.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) Shutdown 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) Shutdown(arg0, arg1 interface{}) *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) StackCommands 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) StackCommands(arg0, arg1 interface{}) *gomock.Call

StackCommands indicates an expected call of StackCommands.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) StartContainer 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) StartContainer(arg0, arg1 interface{}) *gomock.Call

StartContainer indicates an expected call of StartContainer.

func (*MockCrosToolRunnerContainerServiceServerMockRecorder) StartTemplatedContainer 

func (mr *MockCrosToolRunnerContainerServiceServerMockRecorder) StartTemplatedContainer(arg0, arg1 interface{}) *gomock.Call

StartTemplatedContainer indicates an expected call of StartTemplatedContainer.

type MockUnsafeCrosToolRunnerContainerServiceServer 

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

MockUnsafeCrosToolRunnerContainerServiceServer is a mock of UnsafeCrosToolRunnerContainerServiceServer interface.

func NewMockUnsafeCrosToolRunnerContainerServiceServer 

func NewMockUnsafeCrosToolRunnerContainerServiceServer(ctrl *gomock.Controller) *MockUnsafeCrosToolRunnerContainerServiceServer

NewMockUnsafeCrosToolRunnerContainerServiceServer creates a new mock instance.

func (*MockUnsafeCrosToolRunnerContainerServiceServer) EXPECT 

func (m *MockUnsafeCrosToolRunnerContainerServiceServer) EXPECT() *MockUnsafeCrosToolRunnerContainerServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeCrosToolRunnerContainerServiceServerMockRecorder 

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

MockUnsafeCrosToolRunnerContainerServiceServerMockRecorder is the mock recorder for MockUnsafeCrosToolRunnerContainerServiceServer.

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.