worker

Documentation

Index

• type ClientConfig
• type Config
• type Worker
  • func NewWorker(ctx context.Context, log *logrus.Entry) (*Worker, error)
  • func (w *Worker) Start() error
  • func (w *Worker) Stop() error
• type WorkerClient
  • func NewWorkerClient(logger *logrus.Entry) (*WorkerClient, error)
  • func (p *WorkerClient) UpdateCollectionStats(collectionId uint64)
  • func (p *WorkerClient) UpdateCollectionTraits(collectionId uint64)

Types

type ClientConfig

type ClientConfig struct {
	DatabaseDNS string `envconfig:"DATABASE_DNS" required:"true"`
}

type Config

type Config struct {
	DatabaseDSN string `envconfig:"DATABASE_DSN" required:"true"`
}

type Worker

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

func NewWorker

func NewWorker(ctx context.Context, log *logrus.Entry) (*Worker, error)

func (*Worker) Start

func (w *Worker) Start() error

func (*Worker) Stop

func (w *Worker) Stop() error

type WorkerClient

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

func NewWorkerClient

func NewWorkerClient(logger *logrus.Entry) (*WorkerClient, error)

func (*WorkerClient) UpdateCollectionStats

func (p *WorkerClient) UpdateCollectionStats(collectionId uint64)

func (*WorkerClient) UpdateCollectionTraits

func (p *WorkerClient) UpdateCollectionTraits(collectionId uint64)