processServer

Documentation

Index

• type ProcessServer
  • func NewProcessServer(config ProcessServerConfig, dispathcerChannel chan<- submitwrap.SubmitTaskWrap) *ProcessServer
  • func (processServer *ProcessServer) AcceptConn(conn net.Conn)
  • func (processServer *ProcessServer) AddSubmit(submitTaskWrap submitwrap.SubmitTaskWrap)
  • func (processServer *ProcessServer) Addr() string
  • func (processServer *ProcessServer) CheckoutSubmit(submitID int) (submitwrap.SubmitTaskWrap, bool)
  • func (processServer *ProcessServer) ExitServer()
  • func (processServer *ProcessServer) HandleAcceptErorr() error
  • func (processServer *ProcessServer) InitServer(listener net.Listener) error
  • func (processServer *ProcessServer) RemoveSubmit(submitTaskWrap submitwrap.SubmitTaskWrap)
• type ProcessServerConfig

Types

type ProcessServer

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

func NewProcessServer

func NewProcessServer(config ProcessServerConfig, dispathcerChannel chan<- submitwrap.SubmitTaskWrap) *ProcessServer

func (*ProcessServer) AcceptConn

func (processServer *ProcessServer) AcceptConn(conn net.Conn)

func (*ProcessServer) AddSubmit

func (processServer *ProcessServer) AddSubmit(submitTaskWrap submitwrap.SubmitTaskWrap)

func (*ProcessServer) Addr

func (processServer *ProcessServer) Addr() string

func (*ProcessServer) CheckoutSubmit

func (processServer *ProcessServer) CheckoutSubmit(submitID int) (submitwrap.SubmitTaskWrap, bool)

func (*ProcessServer) ExitServer

func (processServer *ProcessServer) ExitServer()

func (*ProcessServer) HandleAcceptErorr

func (processServer *ProcessServer) HandleAcceptErorr() error

func (*ProcessServer) InitServer

func (processServer *ProcessServer) InitServer(listener net.Listener) error

func (*ProcessServer) RemoveSubmit

func (processServer *ProcessServer) RemoveSubmit(submitTaskWrap submitwrap.SubmitTaskWrap)

type ProcessServerConfig

type ProcessServerConfig struct {
	ListenAddr  string `json:"listenAddr"`
	ChannelSize int    `json:"channelSize"`
}