Documentation
¶
Index ¶
- func GetTerminalAccessConfig() (*models.UserTerminalSessionConfig, error)
- type UserTerminalAccessService
- type UserTerminalAccessServiceImpl
- func (impl *UserTerminalAccessServiceImpl) DeleteTerminalPod(ctx context.Context, clusterId int, terminalPodName string, namespace string) error
- func (impl *UserTerminalAccessServiceImpl) DeleteTerminalResource(ctx context.Context, clusterId int, terminalResourceName string, ...) error
- func (impl *UserTerminalAccessServiceImpl) DisconnectAllSessionsForUser(ctx context.Context, userId int32)
- func (impl *UserTerminalAccessServiceImpl) DisconnectTerminalSession(ctx context.Context, userTerminalAccessId int) error
- func (impl *UserTerminalAccessServiceImpl) FetchPodEvents(ctx context.Context, userTerminalAccessId int) (*application.EventsResponse, error)
- func (impl *UserTerminalAccessServiceImpl) FetchPodManifest(ctx context.Context, userTerminalAccessId int) (resp *application.ManifestResponse, err error)
- func (impl *UserTerminalAccessServiceImpl) FetchTerminalStatus(ctx context.Context, terminalAccessId int) (*models.UserTerminalSessionResponse, error)
- func (impl *UserTerminalAccessServiceImpl) StartTerminalSession(ctx context.Context, request *models.UserTerminalSessionRequest) (*models.UserTerminalSessionResponse, error)
- func (impl *UserTerminalAccessServiceImpl) StopTerminalSession(ctx context.Context, userTerminalAccessId int)
- func (impl *UserTerminalAccessServiceImpl) SyncPodStatus()
- func (impl *UserTerminalAccessServiceImpl) SyncRunningInstances()
- func (impl *UserTerminalAccessServiceImpl) UpdateTerminalSession(ctx context.Context, request *models.UserTerminalSessionRequest) (*models.UserTerminalSessionResponse, error)
- func (impl *UserTerminalAccessServiceImpl) UpdateTerminalShellSession(ctx context.Context, request *models.UserTerminalShellSessionRequest) (*models.UserTerminalSessionResponse, error)
- type UserTerminalAccessSessionData
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetTerminalAccessConfig ¶
func GetTerminalAccessConfig() (*models.UserTerminalSessionConfig, error)
Types ¶
type UserTerminalAccessService ¶
type UserTerminalAccessService interface {
StartTerminalSession(ctx context.Context, request *models.UserTerminalSessionRequest) (*models.UserTerminalSessionResponse, error)
UpdateTerminalSession(ctx context.Context, request *models.UserTerminalSessionRequest) (*models.UserTerminalSessionResponse, error)
UpdateTerminalShellSession(ctx context.Context, request *models.UserTerminalShellSessionRequest) (*models.UserTerminalSessionResponse, error)
FetchTerminalStatus(ctx context.Context, terminalAccessId int) (*models.UserTerminalSessionResponse, error)
StopTerminalSession(ctx context.Context, userTerminalAccessId int)
DisconnectTerminalSession(ctx context.Context, userTerminalAccessId int) error
DisconnectAllSessionsForUser(ctx context.Context, userId int32)
FetchPodManifest(ctx context.Context, userTerminalAccessId int) (resp *application.ManifestResponse, err error)
FetchPodEvents(ctx context.Context, userTerminalAccessId int) (*application.EventsResponse, error)
}
type UserTerminalAccessServiceImpl ¶
type UserTerminalAccessServiceImpl struct {
TerminalAccessRepository repository.TerminalAccessRepository
Logger *zap.SugaredLogger
Config *models.UserTerminalSessionConfig
TerminalAccessSessionDataMap *map[int]*UserTerminalAccessSessionData
TerminalAccessDataArrayMutex *sync.RWMutex
PodStatusSyncCron *cron.Cron
// contains filtered or unexported fields
}
func NewUserTerminalAccessServiceImpl ¶
func NewUserTerminalAccessServiceImpl(logger *zap.SugaredLogger, terminalAccessRepository repository.TerminalAccessRepository, config *models.UserTerminalSessionConfig, k8sApplicationService k8s.K8sApplicationService, k8sClientService application.K8sClientService, terminalSessionHandler terminal.TerminalSessionHandler) (*UserTerminalAccessServiceImpl, error)
func (*UserTerminalAccessServiceImpl) DeleteTerminalPod ¶
func (*UserTerminalAccessServiceImpl) DeleteTerminalResource ¶
func (*UserTerminalAccessServiceImpl) DisconnectAllSessionsForUser ¶
func (impl *UserTerminalAccessServiceImpl) DisconnectAllSessionsForUser(ctx context.Context, userId int32)
func (*UserTerminalAccessServiceImpl) DisconnectTerminalSession ¶
func (impl *UserTerminalAccessServiceImpl) DisconnectTerminalSession(ctx context.Context, userTerminalAccessId int) error
func (*UserTerminalAccessServiceImpl) FetchPodEvents ¶
func (impl *UserTerminalAccessServiceImpl) FetchPodEvents(ctx context.Context, userTerminalAccessId int) (*application.EventsResponse, error)
func (*UserTerminalAccessServiceImpl) FetchPodManifest ¶
func (impl *UserTerminalAccessServiceImpl) FetchPodManifest(ctx context.Context, userTerminalAccessId int) (resp *application.ManifestResponse, err error)
func (*UserTerminalAccessServiceImpl) FetchTerminalStatus ¶
func (impl *UserTerminalAccessServiceImpl) FetchTerminalStatus(ctx context.Context, terminalAccessId int) (*models.UserTerminalSessionResponse, error)
func (*UserTerminalAccessServiceImpl) StartTerminalSession ¶
func (impl *UserTerminalAccessServiceImpl) StartTerminalSession(ctx context.Context, request *models.UserTerminalSessionRequest) (*models.UserTerminalSessionResponse, error)
func (*UserTerminalAccessServiceImpl) StopTerminalSession ¶
func (impl *UserTerminalAccessServiceImpl) StopTerminalSession(ctx context.Context, userTerminalAccessId int)
func (*UserTerminalAccessServiceImpl) SyncPodStatus ¶
func (impl *UserTerminalAccessServiceImpl) SyncPodStatus()
func (*UserTerminalAccessServiceImpl) SyncRunningInstances ¶
func (impl *UserTerminalAccessServiceImpl) SyncRunningInstances()
func (*UserTerminalAccessServiceImpl) UpdateTerminalSession ¶
func (impl *UserTerminalAccessServiceImpl) UpdateTerminalSession(ctx context.Context, request *models.UserTerminalSessionRequest) (*models.UserTerminalSessionResponse, error)
func (*UserTerminalAccessServiceImpl) UpdateTerminalShellSession ¶
func (impl *UserTerminalAccessServiceImpl) UpdateTerminalShellSession(ctx context.Context, request *models.UserTerminalShellSessionRequest) (*models.UserTerminalSessionResponse, error)
type UserTerminalAccessSessionData ¶
type UserTerminalAccessSessionData struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.