pod

Documentation

Index

• Variables
• type GenericPodService
  • func (s *GenericPodService) CreatePod(ctx context.Context, in *pb.CreatePodRequest) (*pb.CreatePodResponse, error)
  • func (ps *GenericPodService) InstanceFactory(ctx context.Context, stubId string, ...) (abstractions.IAutoscaledInstance, error)
  • func (ps *GenericPodService) IsPublic(stubId string) (*types.Workspace, error)
• type PodProxyBuffer
  • func NewPodProxyBuffer(ctx context.Context, rdb *common.RedisClient, workspace *types.Workspace, ...) *PodProxyBuffer
  • func (pb *PodProxyBuffer) ForwardRequest(ctx echo.Context) error
• type PodService
  • func NewPodService(ctx context.Context, opts PodServiceOpts) (PodService, error)
• type PodServiceOpts

Variables

var Keys = &keys{}

Types

type GenericPodService

type GenericPodService struct {
	pb.PodServiceServer
	// contains filtered or unexported fields
}

func (*GenericPodService) CreatePod

func (s *GenericPodService) CreatePod(ctx context.Context, in *pb.CreatePodRequest) (*pb.CreatePodResponse, error)

CreatePod creates a new container that will run to completion, with an associated task

func (*GenericPodService) InstanceFactory

func (ps *GenericPodService) InstanceFactory(ctx context.Context, stubId string, options ...func(abstractions.IAutoscaledInstance)) (abstractions.IAutoscaledInstance, error)

func (*GenericPodService) IsPublic

func (ps *GenericPodService) IsPublic(stubId string) (*types.Workspace, error)

type PodProxyBuffer

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

func NewPodProxyBuffer

func NewPodProxyBuffer(ctx context.Context,
	rdb *common.RedisClient,
	workspace *types.Workspace,
	stubId string,
	size int,
	containerRepo repository.ContainerRepository,
	keyEventManager *common.KeyEventManager,
	stubConfig *types.StubConfigV1,
	tailscale *network.Tailscale,
	tsConfig types.TailscaleConfig,
) *PodProxyBuffer

func (*PodProxyBuffer) ForwardRequest

func (pb *PodProxyBuffer) ForwardRequest(ctx echo.Context) error

type PodService

type PodService interface {
	pb.PodServiceServer
	CreatePod(ctx context.Context, in *pb.CreatePodRequest) (*pb.CreatePodResponse, error)
}

func NewPodService

func NewPodService(
	ctx context.Context,
	opts PodServiceOpts,
) (PodService, error)

type PodServiceOpts

type PodServiceOpts struct {
	Config        types.AppConfig
	BackendRepo   repository.BackendRepository
	ContainerRepo repository.ContainerRepository
	WorkspaceRepo repository.WorkspaceRepository
	Tailscale     *network.Tailscale
	Scheduler     *scheduler.Scheduler
	RedisClient   *common.RedisClient
	EventRepo     repository.EventRepository
	RouteGroup    *echo.Group
}