socket

package
v4.20.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 23, 2023 License: AGPL-3.0 Imports: 60 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ResultError             = websocket_pb.ResultType_Error
	ResultSuccess           = websocket_pb.ResultType_Success
	ResultDeployed          = websocket_pb.ResultType_Deployed
	ResultDeployFailed      = websocket_pb.ResultType_DeployedFailed
	ResultDeployCanceled    = websocket_pb.ResultType_DeployedCanceled
	ResultLogWithContainers = websocket_pb.ResultType_LogWithContainers

	WsSetUid             = websocket_pb.Type_SetUid
	WsReloadProjects     = websocket_pb.Type_ReloadProjects
	WsCancel             = websocket_pb.Type_CancelProject
	WsCreateProject      = websocket_pb.Type_CreateProject
	WsUpdateProject      = websocket_pb.Type_UpdateProject
	WsProcessPercent     = websocket_pb.Type_ProcessPercent
	WsClusterInfoSync    = websocket_pb.Type_ClusterInfoSync
	WsInternalError      = websocket_pb.Type_InternalError
	WsHandleExecShell    = websocket_pb.Type_HandleExecShell
	WsHandleExecShellMsg = websocket_pb.Type_HandleExecShellMsg
	WsHandleCloseShell   = websocket_pb.Type_HandleCloseShell
	WsAuthorize          = websocket_pb.Type_HandleAuthorize
	ProjectPodEvent      = websocket_pb.Type_ProjectPodEvent
)
View Source 
const (
	VarImagePullSecrets = "ImagePullSecrets"
	VarBranch           = "Branch"
	VarCommit           = "Commit"
	VarPipeline         = "Pipeline"
	VarClusterIssuer    = "ClusterIssuer"
	VarHost             = "Host"
	VarTlsSecret        = "TlsSecret"
)
View Source 
const (
	OpStdout = "stdout"
	OpStdin  = "stdin"
	OpResize = "resize"
	OpToast  = "toast"
)

Variables

View Source 
var (
	ETX                 = []byte("\u0003")
	END_OF_TRANSMISSION = []byte("\u0004")
)
View Source 
var AuditLogWithChange = events.AuditLog
View Source 
var (
	ErrorVersionNotMatched = errors.New("当前版本和最新版本存在差异，请刷新重试")
)

Functions

func GenMyPtyHandlerId 

func GenMyPtyHandlerId() string

func HandleExecShell 

func HandleExecShell(input *websocket_pb.WsHandleExecShellInput, conn *WsConn) (string, error)

func HandleWsAuthorize 

func HandleWsAuthorize(c *WsConn, t websocket_pb.Type, message []byte)

func HandleWsCancel 

func HandleWsCancel(c *WsConn, t websocket_pb.Type, message []byte)

func HandleWsCreateProject 

func HandleWsCreateProject(c *WsConn, t websocket_pb.Type, message []byte)

func HandleWsHandleCloseShell 

func HandleWsHandleCloseShell(c *WsConn, t websocket_pb.Type, message []byte)

func HandleWsHandleExecShell 

func HandleWsHandleExecShell(c *WsConn, t websocket_pb.Type, message []byte)

func HandleWsHandleExecShellMsg 

func HandleWsHandleExecShellMsg(c *WsConn, t websocket_pb.Type, message []byte)

func HandleWsProjectPodEvent 

func HandleWsProjectPodEvent(c *WsConn, t websocket_pb.Type, message []byte)

func HandleWsUpdateProject 

func HandleWsUpdateProject(c *WsConn, t websocket_pb.Type, message []byte)

func InstallProject 

func InstallProject(job contracts.Job) (err error)

func NewJober 

func NewJober(
	input *JobInput,
	user contracts.UserInfo,
	slugName string,
	messager contracts.DeployMsger,
	pubsub contracts.PubSub,
	timeoutSeconds int64,
	opts ...Option,
) contracts.Job

func NewMessageSender 

func NewMessageSender(conn *WsConn, slugName string, wsType websocket_pb.Type) contracts.DeployMsger

func NewRecorder 

func NewRecorder(action types.EventActionType, user contracts.UserInfo, timer timer.Timer, container contracts.Container) contracts.RecorderInterface

func NewSessionMap 

func NewSessionMap(conn *WsConn) contracts.SessionMapper

func WaitForTerminal 

func WaitForTerminal(conn *WsConn, k8sClient kubernetes.Interface, cfg *rest.Config, container *contracts.Container, shell, sessionId string)

WaitForTerminal is called from apihandler.handleAttach as a goroutine Waits for the SockJS connection to be opened by the client the session to be bound in handleMyPtyHandler

Types

type ChartFileLoader 

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

func (*ChartFileLoader) Load 

func (c *ChartFileLoader) Load(j *jobRunner) error

type DefaultHelmer 

type DefaultHelmer struct{}

func (*DefaultHelmer) PackageChart 

func (d *DefaultHelmer) PackageChart(path string, destDir string) (string, error)

func (*DefaultHelmer) ReleaseStatus 

func (d *DefaultHelmer) ReleaseStatus(releaseName, namespace string) types.Deploy

func (*DefaultHelmer) Rollback 

func (d *DefaultHelmer) Rollback(releaseName, namespace string, wait bool, log contracts.LogFn, dryRun bool) error

func (*DefaultHelmer) Uninstall 

func (d *DefaultHelmer) Uninstall(releaseName, namespace string, log contracts.LogFn) error

func (*DefaultHelmer) UpgradeOrInstall 

func (d *DefaultHelmer) UpgradeOrInstall(ctx context.Context, releaseName, namespace string, ch *chart.Chart, valueOpts *values.Options, fn contracts.WrapLogFn, wait bool, timeoutSeconds int64, dryRun bool, desc string) (*release.Release, error)

type DeployResult 

type DeployResult struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*DeployResult) IsSet 

func (d *DeployResult) IsSet() bool

func (*DeployResult) Model 

func (d *DeployResult) Model() *types.ProjectModel

func (*DeployResult) Msg 

func (d *DeployResult) Msg() string

func (*DeployResult) ResultType 

func (d *DeployResult) ResultType() websocket_pb.ResultType

func (*DeployResult) Set 

func (d *DeployResult) Set(t websocket_pb.ResultType, msg string, model *types.ProjectModel)

type DynamicLoader 

type DynamicLoader struct{}

func (*DynamicLoader) Load 

func (d *DynamicLoader) Load(j *jobRunner) error

type ExtraValuesLoader 

type ExtraValuesLoader struct{}

func (*ExtraValuesLoader) Load 

func (d *ExtraValuesLoader) Load(j *jobRunner) error

type HandleRequestFunc 

type HandleRequestFunc func(c *WsConn, t websocket_pb.Type, message []byte)

type JobInput 

type JobInput struct {
	Type         websocket_pb.Type
	NamespaceId  int64
	Name         string
	GitProjectId int64
	GitBranch    string
	GitCommit    string
	Config       string
	Atomic       bool
	ExtraValues  []*types.ExtraValue
	Version      int64
}

type Loader 

type Loader interface {
	Load(*jobRunner) error
}

type MergeValuesLoader 

type MergeValuesLoader struct{}

func (*MergeValuesLoader) Load 

func (m *MergeValuesLoader) Load(j *jobRunner) error

Load imagePullSecrets 会自动注入到 imagePullSecrets 中

type NewJobFunc 

type NewJobFunc func(
	input *JobInput,
	user contracts.UserInfo,
	slugName string,
	messager contracts.DeployMsger,
	pubsub contracts.PubSub,
	timeoutSeconds int64,
	opts ...Option,
) contracts.Job

type Option 

type Option func(*jobRunner)

func WithDryRun 

func WithDryRun() Option

type ReleaseInstallerLoader 

type ReleaseInstallerLoader struct{}

func (*ReleaseInstallerLoader) Load 

func (r *ReleaseInstallerLoader) Load(j *jobRunner) error

type Sleeper 

type Sleeper interface {
	Sleep(time.Duration)
}

type TerminalResponse 

type TerminalResponse struct {
	ID string `json:"id"`
}

type VariableLoader 

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

func (*VariableLoader) Load 

func (v *VariableLoader) Load(j *jobRunner) error

type WaitSocketExitInterface 

type WaitSocketExitInterface interface {
	Inc()
	Dec()
	Wait()
	Count() int
}
var Wait WaitSocketExitInterface = NewWaitSocketExit()

func NewWaitSocketExit 

func NewWaitSocketExit() WaitSocketExitInterface

type WebsocketManager 

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

func NewWebsocketManager 

func NewWebsocketManager(healthTickDuration time.Duration) *WebsocketManager

func (*WebsocketManager) Info 

func (wc *WebsocketManager) Info(writer http.ResponseWriter, request *http.Request)

func (*WebsocketManager) TickClusterHealth 

func (wc *WebsocketManager) TickClusterHealth()

func (*WebsocketManager) Ws 

func (wc *WebsocketManager) Ws(w http.ResponseWriter, r *http.Request)

type WsConn 

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

func (*WsConn) GetUser 

func (c *WsConn) GetUser() contracts.UserInfo

func (*WsConn) SetUser 

func (c *WsConn) SetUser(info contracts.UserInfo)

func (*WsConn) Shutdown 

func (c *WsConn) Shutdown()

type WsResponse 

type WsResponse = websocket_pb.WsMetadataResponse

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.