console

Documentation

Index

• Constants
• type ConsoleSession
• type ConsoleSessionManager
  • func NewConsoleSessionManager(serviceHandler service.Service, log logrus.FieldLogger, ...) *ConsoleSessionManager
  • func (m *ConsoleSessionManager) CloseSession(ctx context.Context, session *ConsoleSession) error
  • func (m *ConsoleSessionManager) StartSession(ctx context.Context, orgId uuid.UUID, deviceName, sessionMetadata string) (*ConsoleSession, error)
• type InternalSessionRegistration

Constants

const ChannelSize = 2048

Types

type ConsoleSession

type ConsoleSession struct {
	UUID       string
	OrgId      uuid.UUID
	DeviceName string
	SendCh     chan []byte
	RecvCh     chan []byte
	ProtocolCh chan string
}

type ConsoleSessionManager

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

func NewConsoleSessionManager

func NewConsoleSessionManager(serviceHandler service.Service, log logrus.FieldLogger, sessionRegistration InternalSessionRegistration) *ConsoleSessionManager

func (*ConsoleSessionManager) CloseSession

func (m *ConsoleSessionManager) CloseSession(ctx context.Context, session *ConsoleSession) error

func (*ConsoleSessionManager) StartSession

func (m *ConsoleSessionManager) StartSession(ctx context.Context, orgId uuid.UUID, deviceName, sessionMetadata string) (*ConsoleSession, error)

type InternalSessionRegistration

type InternalSessionRegistration interface {
	// Register a session with a given UUID and channels
	// Those channels will be used to read from and write to the session
	// in a way that this interface down to the gRPC session is abstracted
	StartSession(*ConsoleSession) error
	CloseSession(*ConsoleSession) error
}