uniq

Documentation

Index

• type Options
• type UniqSubsystem
  • func (u *UniqSubsystem) Name() string
  • func (u *UniqSubsystem) Reload(s *server.Server) error
  • func (u *UniqSubsystem) Shutdown(s *server.Server) error
  • func (u *UniqSubsystem) Start(s *server.Server) error

Types

type Options

type Options struct {
	// whether or not to enable the plugin
	Enabled bool
}

type UniqSubsystem

type UniqSubsystem struct {
	Server *server.Server
	// uniq plugin options
	Options *Options
}

The UniqSubsytem generates a lock using redis to ensure jobs from the same queue, params and name are not queued more than once it follows the spec found at: https://github.com/contribsys/faktory/wiki/Ent-Unique-Jobs

func (*UniqSubsystem) Name

func (u *UniqSubsystem) Name() string

returns the name of the subsystem or plugin

func (*UniqSubsystem) Reload

func (u *UniqSubsystem) Reload(s *server.Server) error

reload - nothing needs to be done but the function must exist for subsystems

func (*UniqSubsystem) Shutdown

func (u *UniqSubsystem) Shutdown(s *server.Server) error

shutdown - nothing needs to be done but the function must exist for subsystems

func (*UniqSubsystem) Start

func (u *UniqSubsystem) Start(s *server.Server) error

starts the subsystem and adds the needed middleware