insightcollector

Documentation

Index

• Variables
• type InsightCollector
  • func NewInsightCollector(ds datastore.DataStore, fs filestore.Store, logger *zap.Logger) *InsightCollector
  • func (i *InsightCollector) ProcessNewlyCompletedDeployments(ctx context.Context) error
  • func (i *InsightCollector) ProcessNewlyCreatedDeployments(ctx context.Context) error

Variables

var (
	ErrDeploymentNotFound = errors.New("deployments not found")
)

Types

type InsightCollector

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

InsightCollector implements the behaviors for the gRPC definitions of InsightCollector.

func NewInsightCollector

func NewInsightCollector(
	ds datastore.DataStore,
	fs filestore.Store,
	logger *zap.Logger,
) *InsightCollector

NewInsightCollector creates a new InsightCollector instance.

func (*InsightCollector) ProcessNewlyCompletedDeployments

func (i *InsightCollector) ProcessNewlyCompletedDeployments(ctx context.Context) error

func (*InsightCollector) ProcessNewlyCreatedDeployments

func (i *InsightCollector) ProcessNewlyCreatedDeployments(ctx context.Context) error