sidekip

package module
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 6, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

README

sidekip

Installation

go get -u github.com/coolstina/sidekip

How to use?

It's very simple to use, just out of the box, and you can view the documentation through GoDoc.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithCancel

func WithCancel(cancel context.CancelFunc) Option

func WithClass

func WithClass(class string) Option

func WithContext

func WithContext(ctx context.Context) Option

func WithQueue

func WithQueue(queue string) Option

func WithShowLog

func WithShowLog(show bool) Option

type SideKip

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

func NewSideKip

func NewSideKip(config *config.Config, ops ...Option) *SideKip

func (*SideKip) Enqueue

func (sk *SideKip) Enqueue(queue string, class string, args interface{}) (string, error)

func (*SideKip) Finished added in v0.1.1

func (sk *SideKip) Finished()

func (*SideKip) Process

func (sk *SideKip) Process(queue string, job func(message *workers.Msg), concurrency int, mids ...workers.Action)

func (*SideKip) Run

func (sk *SideKip) Run()

func (*SideKip) SetCancel added in v0.1.1

func (sk *SideKip) SetCancel(cancel context.CancelFunc) *SideKip

func (*SideKip) SetContext added in v0.1.1

func (sk *SideKip) SetContext(ctx context.Context) *SideKip

Directories

Path Synopsis
examples

Jump to

Keyboard shortcuts

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