server

package

v0.0.0-...-4e26a97 Latest Latest Go to latest Published: Oct 25, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Orlion/cat-agent

Documentation ¶

Constants ¶

View Source

const ReqHeaderLen = 8

View Source

const RespHeaderLen = 8

Variables ¶

View Source

var (
	ErrServerClosed = errors.New("server: Server closed")
)

Functions ¶

This section is empty.

Types ¶

type Cmd ¶

type Cmd uint32

const (
	CmdCreateMessageId Cmd = iota + 1
	CmdSendMessage
)

type Config ¶

type Config struct {
	Addr               string `yaml:"addr"`
	ReadTimeoutMillis  int    `yaml:"read_timeout_millis"`
	WriteTimeoutMillis int    `yaml:"write_timeout_millis"`
}

type Handler ¶

type Handler func(req *Request) (status Status, payload []byte)

type Request ¶

type Request struct {
	Cmd    Cmd
	Length uint32
	Body   []byte
}

type Server ¶

type Server struct {
	Addr         string
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	IdleTimeout  time.Duration
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(config *Config) *Server

func (*Server) Handle ¶

func (srv *Server) Handle(cmd Cmd, handler Handler)

func (*Server) ListenAndServe ¶

func (srv *Server) ListenAndServe() (err error)

func (*Server) Shutdown ¶

func (srv *Server) Shutdown(ctx context.Context) error

type Status ¶

type Status uint32

const (
	StatusOk Status = iota
	StatusMsgReadHeaderErr
	StatusMsgReadMessageErr
	StatusNotFoundCmd
	StatusBadDomain
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL