slots

package

v1.3.5 Latest Latest Go to latest Published: Jul 23, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Entry struct {
	SlotName string
	Index    int
	Manager  *session.Manager
	Healthy  func() bool
}

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

func NewMultiplexer(groupName string, logger *slog.Logger, entries []Entry) *Multiplexer

func (m *Multiplexer) AdmissionStatus() (atCapacity bool, current int, max int)

func (m *Multiplexer) CloseAll()

func (m *Multiplexer) Rebind(oldKey, newKey string)

func (m *Multiplexer) Release(upstreamSessionID string)

func (m *Multiplexer) ReplaceEntries(entries []Entry)

func (m *Multiplexer) ReportSpawnResult(sessionKey string, err error)

func (m *Multiplexer) SelectForNewSession(_ context.Context, upstreamSessionID string) (*session.Manager, error)

func (m *Multiplexer) SetOnSessionRemoved(fn func(sessionID string))