common

Documentation

Index

• func HandlePTY(c context.Context, conn pb.Master_PTYConnectClient, sessionID string)
• func StartPTYConnect(c context.Context, req *pb.CommonRequest, initMsg *pb.PTYClientMessage) (*pb.CommonResponse, error)
• func StartSteamLogHandler(ctx context.Context, req *pb.CommonRequest, initStreamLogFunc func(*HookMgr)) (*pb.CommonResponse, error)
• func StopSteamLogHandler(ctx context.Context, req *pb.CommonRequest) (*pb.CommonResponse, error)
• type HookMgr
  • func (h *HookMgr) AddStream(send func(msg string), closeSend func())
  • func (h *HookMgr) Close()

Functions

func HandlePTY

func HandlePTY(c context.Context, conn pb.Master_PTYConnectClient, sessionID string)

func StartPTYConnect

func StartPTYConnect(c context.Context, req *pb.CommonRequest, initMsg *pb.PTYClientMessage) (*pb.CommonResponse, error)

func StartSteamLogHandler

func StartSteamLogHandler(ctx context.Context, req *pb.CommonRequest, initStreamLogFunc func(*HookMgr)) (*pb.CommonResponse, error)

func StopSteamLogHandler

func StopSteamLogHandler(ctx context.Context, req *pb.CommonRequest) (*pb.CommonResponse, error)

Types

type HookMgr

type HookMgr struct {
	*sync.Mutex
	// contains filtered or unexported fields
}

func (*HookMgr) AddStream

func (h *HookMgr) AddStream(send func(msg string), closeSend func())

func (*HookMgr) Close

func (h *HookMgr) Close()