bridge

package

v0.0.0-...-bb1bb1d Latest Latest Go to latest Published: Nov 30, 2024 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

View Source

var ErrUnknownBackend = errors.New("unknown backend type")

This section is empty.

type Config struct {
	Address string `json:"address"`
	Backend string `json:"backend"`
}

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

func (c *Conn) Bury(id uint64, pri uint64) error

func (c *Conn) Delete(id uint64) error

func (c *Conn) Ignore(tube string) (int, error)

func (c *Conn) Put(pri uint64, delay uint64, ttr uint64, data []byte) (uint64, bool, error)

func (c *Conn) Release(id uint64, pri uint64, delay uint64) error

func (c *Conn) Reserve(timeout int64) (uint64, []byte, error)

func (c *Conn) ReserveByID(id uint64) (uint64, []byte, error)

func (c *Conn) Touch(id uint64) error

func (c *Conn) Use(tube string) (string, error)

func (c *Conn) Watch(tube string) (int, error)

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

func NewServer(logger *slog.Logger, cfg *Config) (*Server, error)

func (s *Server) Serve() error