vm

type Gateway interface {
	GetOrCreateStub(context.Context, *pb.GetOrCreateStubRequest) (*pb.GetOrCreateStubResponse, error)
	StopContainer(context.Context, *pb.StopContainerRequest) (*pb.StopContainerResponse, error)
	ResolveCPUTier(ctx context.Context, workspace *types.Workspace, requested types.CPUTier, pool string, eligible bool) (types.CPUTier, error)
	IsHostedCPUPool(string) bool
}

type ICESession struct {
	VMID        string
	ContainerID string
	TokenHash   string
	Password    string
	WorkspaceID uint
	Generation  int64
}

type ImageVerifier interface {
	VerifyImageBuild(context.Context, *pb.VerifyImageBuildRequest) (*pb.VerifyImageBuildResponse, error)
}

type Runtime interface {
	pb.PodServiceServer
	RunVM(context.Context, *auth.AuthInfo, string, string, types.VMSpec, string, map[string]string) error
	VMPortReady(context.Context, string, string, uint32) (bool, error)
	ForwardVM(echo.Context, string, string) error
	TunnelVM(echo.Context, string, uint32) error
	SetVMICEHandler(func(net.Conn))
}

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

type ServiceOpts struct {
	StateRepo     VMRepository
	Config        types.VMConfig
	BackendRepo   repository.BackendRepository
	ContainerRepo repository.ContainerRepository
	Runtime       Runtime
	Gateway       Gateway
	Images        ImageVerifier
	RouteGroup    *echo.Group
	Server        *echo.Echo
	BackendDialer *network.BackendDialer
	TCPConfig     types.PodTCPConfig // Shared raw TCP listener used by ICE-TCP media.
}

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

type VMRepository interface {
	RenewActivity(ctx context.Context, id, lease string) error
	HasActivity(ctx context.Context, id string) (bool, error)
	ReleaseActivity(ctx context.Context, id, lease string) error
	IncrementICERegistrations(ctx context.Context, id string) (int, error)
	// RegisterICESession returns false for a colliding registration.
	RegisterICESession(ctx context.Context, fragment string, session ICESession, ttl time.Duration) (bool, error)
	// GetICESession returns nil for an absent or expired registration.
	GetICESession(ctx context.Context, fragment string) (*ICESession, error)
	AcquireICELease(ctx context.Context, fragment, lease string, ttl time.Duration) (int, error)
	RenewICELease(ctx context.Context, fragment, lease string, ttl time.Duration) error
	ReleaseICELease(ctx context.Context, fragment, lease string) error
}