queue

Documentation

Index

• func WithClient() (net.Conn, error)
• type Server
  • func New(cfgs ...ServerConfiguration) (*Server, error)
  • func (s *Server) Launch()
• type ServerConfiguration
  • func WithRedisClient() ServerConfiguration
  • func WithServer() ServerConfiguration
  • func WithZapper() ServerConfiguration

Functions

func WithClient

func WithClient() (net.Conn, error)

Types

type Server

type Server struct {
	RedisClient *redis.MessageQueue
	Client      net.Conn
	Server      net.Listener
	Logger      *zap.Logger
}

func New

func New(cfgs ...ServerConfiguration) (*Server, error)

func (*Server) Launch

func (s *Server) Launch()

type ServerConfiguration

type ServerConfiguration func(*Server) error

func WithRedisClient

func WithRedisClient() ServerConfiguration

func WithServer

func WithServer() ServerConfiguration

func WithZapper

func WithZapper() ServerConfiguration