server

Documentation

Index

• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) AddMessage(conn net.Conn, msg string) error
  • func (q *Queue) AddMessageConfirm(conn net.Conn, confirmed bool) error
  • func (q *Queue) GetMessage(conn net.Conn) (string, error)
  • func (q *Queue) GetMessageConfirm(conn net.Conn, confirmed bool) error
  • func (q *Queue) Lock(conn net.Conn) error
  • func (q *Queue) ResponseSyncMessage(conn net.Conn) (string, error)
  • func (q *Queue) TryLock(conn net.Conn) error
  • func (q *Queue) Unlock(conn net.Conn) error
• type Server
  • func NewServer(port string) (*Server, error)

Types

type Queue

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

func NewQueue

func NewQueue() *Queue

func (*Queue) AddMessage

func (q *Queue) AddMessage(conn net.Conn, msg string) error

func (*Queue) AddMessageConfirm

func (q *Queue) AddMessageConfirm(conn net.Conn, confirmed bool) error

func (*Queue) GetMessage

func (q *Queue) GetMessage(conn net.Conn) (string, error)

func (*Queue) GetMessageConfirm

func (q *Queue) GetMessageConfirm(conn net.Conn, confirmed bool) error

func (*Queue) Lock

func (q *Queue) Lock(conn net.Conn) error

func (*Queue) ResponseSyncMessage

func (q *Queue) ResponseSyncMessage(conn net.Conn) (string, error)

func (*Queue) TryLock

func (q *Queue) TryLock(conn net.Conn) error

func (*Queue) Unlock

func (q *Queue) Unlock(conn net.Conn) error

type Server

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

func NewServer

func NewServer(port string) (*Server, error)