sqsjkr

package module

Go to main page

Versions in this module

v0

v0.5.1

Mar 4, 2021

Changes in this version

type DefaultJob

+ func (j *DefaultJob) String() string

type Job

+ String func() string

v0.5.0

Feb 16, 2021

Changes in this version

+ type Stats struct

+ Invocations struct{ ... }

+ Workers struct{ ... }

v0.4.1

Oct 13, 2020

v0.4.0

Oct 5, 2020

v0.3.2

Jun 20, 2018

Changes in this version

type MessageBody

+ func (m MessageBody) String() string

v0.3.1

Mar 28, 2018

v0.3.0

Feb 2, 2018

Changes in this version

type MessageBody

+ DisableLifeTimeTrigger bool

v0.2.1

Feb 15, 2017

Changes in this version

+ const ApplicationJSON

+ const DefaultMaxCocurrentNum

+ const DefaultStatsPort

+ const JobRetryInterval

+ const MaxRetrieveMessageNum

+ const VisibilityTimeout

+ const WaitTimeSec

+ var ErrOverLifeTime = errors.New("over life time")

+ var TrapSignals = []os.Signal

+ func Run(ctx context.Context, sjkr SQSJkr, level string) error

+ func SpawnWorker(sjkr SQSJkr, wid int, js <-chan Job, busy chan struct{})

+ type AccountSection struct

+ ID string

+ Profile string

+ Region string

+ type Config struct

+ Account AccountSection

+ Kicker KickerSection

+ SQS SQSSection

+ func LoadConfig(path string) (*Config, error)

+ func NewConfig() *Config

+ func (c *Config) SetAWSAccount(id, profile, region string)

+ func (c *Config) SetConcurrentNum(num int)

+ func (c *Config) SetKickerConfig(num int, trigger string)

+ func (c *Config) SetSQSQueue(qname string)

+ func (c *Config) SetStatsPort(port int) error

+ func (c *Config) SetStatsSocket(sock string) error

+ func (c *Config) SetTriggerCommand(trigger string)

+ func (c *Config) Validate() error

+ type DefaultJob struct

+ func (j *DefaultJob) Execute(lkr lock.Locker) ([]byte, error)

+ func (j DefaultJob) Command() string

+ func (j DefaultJob) EventID() string

+ func (j DefaultJob) JobID() string

+ type DefaultSQSJkr struct

+ RetentionPeriod time.Duration

+ SQS *sqs.SQS

+ func New(c *Config) (*DefaultSQSJkr, error)

+ func (sjkr *DefaultSQSJkr) Config() *Config

+ func (sjkr *DefaultSQSJkr) JobStream() chan Job

+ func (sjkr *DefaultSQSJkr) Locker() lock.Locker

+ func (sjkr *DefaultSQSJkr) Run(ctx context.Context) error

+ func (sjkr *DefaultSQSJkr) SetLocker(l lock.Locker)

+ func (sjkr *DefaultSQSJkr) SetThrottler(t throttle.Throttler)

+ func (sjkr *DefaultSQSJkr) Throttler() throttle.Throttler

+ type Duration struct

+ func (d *Duration) UnmarshalJSON(b []byte) (err error)

+ type Job interface

+ Command func() string

+ EventID func() string

+ Execute func(lock.Locker) ([]byte, error)

+ JobID func() string

+ func NewJob(msg *sqs.Message, trigger string) (Job, error)

+ type KickerSection struct

+ MaxConcurrentNum int

+ StatsPort int

+ StatsSocket string

+ Trigger string

+ type LogLevel int

+ const DebugLevel

+ const ErrorLevel

+ const InfoLevel

+ const WarnLevel

+ type Logger struct

+ Level LogLevel

+ Logger *log.Logger

+ func NewLogger() Logger

+ func (l *Logger) SetLevel(level string)

+ func (l Logger) Debugf(format string, args ...interface{})

+ func (l Logger) Errorf(format string, args ...interface{})

+ func (l Logger) Infof(format string, args ...interface{})

+ func (l Logger) Warnf(format string, args ...interface{})

+ type MessageBody struct

+ AbortIfLocked bool

+ Command string

+ Environments map[string]string

+ EventID string

+ LifeTime Duration

+ LockID string

+ type SQSJkr interface

+ Config func() *Config

+ JobStream func() chan Job

+ Locker func() lock.Locker

+ Run func(context.Context) error

+ SetLocker func(locker lock.Locker)

+ SetThrottler func(throttle throttle.Throttler)

+ Throttler func() throttle.Throttler

+ type SQSSection struct

+ QueueName string

+ type StatsItem struct

+ BusyWorkerNum uint32

+ IdleWorkerNum uint32

+ type Worker struct

+ func (w Worker) ReceiveMessage()

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