pullanalyzesqueue

Documentation

Index

• type Consumer
  • func NewConsumer(subConsumer *analyzesConsumers.AnalyzePR) *Consumer
  • func (c Consumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type Producer
  • func (p Producer) Put(m queue.Message) error
  • func (p *Producer) Register(m *producers.Multiplexer) error
• type RunMessage
  • func (m RunMessage) LockID() string

Types

type Consumer

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

func NewConsumer

func NewConsumer(subConsumer *analyzesConsumers.AnalyzePR) *Consumer

func (Consumer) Register

func (c Consumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error

type Producer

type Producer struct {
	producers.Base
}

func (Producer) Put

func (p Producer) Put(m queue.Message) error

func (*Producer) Register

func (p *Producer) Register(m *producers.Multiplexer) error

type RunMessage

type RunMessage struct {
	github.Context
	APIRequestID string
	UserID       uint
	AnalysisGUID string
	CommitSHA    string
}

func (RunMessage) LockID

func (m RunMessage) LockID() string