process

Documentation

Index

• type AntsGoroutineProcess
  • func NewAntsGoroutineProcess(poolSize int, maxBlockingTasks int) *AntsGoroutineProcess
  • func (s AntsGoroutineProcess) MustStart()
  • func (s AntsGoroutineProcess) Stop()
• type AntsMnsGoroutineProcess
  • func NewAntsMnsGoroutineProcess() *AntsMnsGoroutineProcess
  • func (s *AntsMnsGoroutineProcess) MustStart()
  • func (s *AntsMnsGoroutineProcess) Stop()
• type HttpServer
  • func NewHttpServerProcess(server *http.Server, eventBus event.Bus) *HttpServer
  • func (s *HttpServer) MustStart()
  • func (s *HttpServer) Stop()
• type Processer

Types

type AntsGoroutineProcess

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

func NewAntsGoroutineProcess

func NewAntsGoroutineProcess(poolSize int, maxBlockingTasks int) *AntsGoroutineProcess

func (AntsGoroutineProcess) MustStart

func (s AntsGoroutineProcess) MustStart()

func (AntsGoroutineProcess) Stop

func (s AntsGoroutineProcess) Stop()

type AntsMnsGoroutineProcess

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

func NewAntsMnsGoroutineProcess

func NewAntsMnsGoroutineProcess() *AntsMnsGoroutineProcess

func (*AntsMnsGoroutineProcess) MustStart

func (s *AntsMnsGoroutineProcess) MustStart()

func (*AntsMnsGoroutineProcess) Stop

func (s *AntsMnsGoroutineProcess) Stop()

type HttpServer

type HttpServer struct {
	*http.Server
	EventBus event.Bus
}

func NewHttpServerProcess

func NewHttpServerProcess(server *http.Server, eventBus event.Bus) *HttpServer

func (*HttpServer) MustStart

func (s *HttpServer) MustStart()

func (*HttpServer) Stop

func (s *HttpServer) Stop()

type Processer

type Processer interface {
	MustStart()
	Stop()
}