triggers

Documentation

Index

• Constants
• func NewClusterEventEvent(eventType testtrigger.EventType, event *corev1.Event) *watcherEvent
• type Execution
• type ExecutorF
• type Option
• type Service
  • func NewService(scheduler *scheduler.Scheduler, clientset *kubernetes.Clientset, ...) *Service
  • func (s *Service) Run(ctx context.Context) error
  • func (s *Service) WithExecutor(executor ExecutorF)
  • func (s *Service) WithScraperInterval(interval time.Duration)

Constants

const (
	ExecutionTest      = "test"
	ExecutionTestSuite = "testsuite"
)

Functions

func NewClusterEventEvent

func NewClusterEventEvent(eventType testtrigger.EventType, event *corev1.Event) *watcherEvent

Types

type Execution

type Execution string

type ExecutorF

type ExecutorF func(context.Context, *testtriggersv1.TestTrigger) error

type Option

type Option func(*Service)

type Service

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

func NewService

func NewService(
	scheduler *scheduler.Scheduler,
	clientset *kubernetes.Clientset,
	testTriggersClientset testkubeclientsetv1.Interface,
	testSuitesClient testsuitesclientv2.Interface,
	testsClient testsclientv3.Interface,
	resultRepository result.Repository,
	testResultRepository testresult.Repository,
	logger *zap.SugaredLogger,
	opts ...Option,
) *Service

func (*Service) Run

func (s *Service) Run(ctx context.Context) error

func (*Service) WithExecutor

func (s *Service) WithExecutor(executor ExecutorF)

func (*Service) WithScraperInterval

func (s *Service) WithScraperInterval(interval time.Duration)