repoanalyzesqueue

Documentation

Index

• type Consumer
  • func NewConsumer(subConsumer *analyzesConsumers.AnalyzeRepo) *Consumer
  • func (c Consumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type Producer
  • func (p Producer) Put(repoName, analysisGUID, branch, privateAccessToken, commitSHA string) error
  • func (p *Producer) Register(m *producers.Multiplexer) error

Types

type Consumer

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

func NewConsumer

func NewConsumer(subConsumer *analyzesConsumers.AnalyzeRepo) *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(repoName, analysisGUID, branch, privateAccessToken, commitSHA string) error

func (*Producer) Register

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