monitor

Documentation

Index

• Constants
• type Service
  • func NewMonitorService(logger *zap.Logger, sinksClient *sinkspb.SinkServiceClient, ...) Service

Constants

const (
	TickerForScan = 1 * time.Minute
)

Types

type Service

type Service interface {
	Start(ctx context.Context, cancelFunc context.CancelFunc) error
	GetRunningPods(ctx context.Context) ([]string, error)
}

func NewMonitorService

func NewMonitorService(logger *zap.Logger, sinksClient *sinkspb.SinkServiceClient, mp producer.Producer, kubecontrol *kubecontrol.Service, deploySvc deployment.Service) Service