app

package

v0.0.0-...-958ef34 Latest Latest Go to latest Published: Sep 13, 2023 License: MIT Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Juice-Labs/Juice-Labs

Links

Open Source Insights

Documentation ¶

Rendered for

Overview ¶

Index ¶

Constants
Variables
type Agent
- func NewAgent(ctx context.Context, tlsConfig *tls.Config) (*Agent, error)
type Connection
- func (connection *Connection) Connect(c net.Conn) error
- func (connection *Connection) Start(group task.Group, exitCode chan int) error
type EventListener
type Reference
- func NewReference[T any](object *T, onCountZero func()) *Reference[T]
- func (reference *Reference[T]) Acquire() bool
- func (reference *Reference[T]) Release()
type Session

Constants ¶

View Source

const (
	RequestSessionName = "RequestSession"
)

Variables ¶

View Source

var (
	ErrClosed = errors.New("session is closed")
)

Functions ¶

This section is empty.

Types ¶

type Agent ¶

type Agent struct {
	Id string

	Hostname  string
	JuicePath string

	Gpus               *gpu.GpuSet
	GpuMetricsProvider *cmdgpu.MetricsProvider

	Server *server.Server
	// contains filtered or unexported fields
}

func NewAgent ¶

func NewAgent(ctx context.Context, tlsConfig *tls.Config) (*Agent, error)

func (*Agent) ConnectToController ¶

func (agent *Agent) ConnectToController(group task.Group, tlsConfig *tls.Config) error

func (*Agent) ConnectionClosed ¶

func (agent *Agent) ConnectionClosed(sessionId string, connection restapi.ConnectionData, exitCode int)

func (*Agent) ConnectionCreated ¶

func (agent *Agent) ConnectionCreated(sessionId string, connection restapi.ConnectionData)

func (*Agent) Run ¶

func (agent *Agent) Run(group task.Group) error

func (*Agent) SessionActive ¶

func (agent *Agent) SessionActive(id string)

func (*Agent) SessionClosed ¶

func (agent *Agent) SessionClosed(id string)

type Connection ¶

type Connection struct {
	restapi.ConnectionData
	// contains filtered or unexported fields
}

func (*Connection) Connect ¶

func (connection *Connection) Connect(c net.Conn) error

func (*Connection) Start ¶

func (connection *Connection) Start(group task.Group, exitCode chan int) error

type EventListener ¶

type EventListener interface {
	SessionClosed(id string)

	ConnectionCreated(sessionId string, connection restapi.ConnectionData)
	ConnectionClosed(sessionId string, connection restapi.ConnectionData, exitCode int)
}

type Reference ¶

type Reference[T any] struct {
	Object *T
	// contains filtered or unexported fields
}

func NewReference ¶

func NewReference[T any](object *T, onCountZero func()) *Reference[T]

func (*Reference[T]) Acquire ¶

func (reference *Reference[T]) Acquire() bool

func (*Reference[T]) Release ¶

func (reference *Reference[T]) Release()

type Session ¶

type Session struct {
	Id      string
	Version string
	// contains filtered or unexported fields
}

func (*Session) Cancel ¶

func (session *Session) Cancel()

func (*Session) Connect ¶

func (session *Session) Connect(connectionData restapi.ConnectionData, c net.Conn) error

func (*Session) Run ¶

func (session *Session) Run(group task.Group) error

func (*Session) Session ¶

func (session *Session) Session() restapi.Session

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
windows * Copyright (c) 2023 Juice Technologies, Inc.	* Copyright (c) 2023 Juice Technologies, Inc.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL