triggers

Documentation

Overview

Package triggers is a generated GoMock package.

Index

• Constants
• Variables
• type AcquireAlwaysLeaseBackend
  • func NewAcquireAlwaysLeaseBackend() *AcquireAlwaysLeaseBackend
  • func (b *AcquireAlwaysLeaseBackend) TryAcquire(ctx context.Context, id, clusterID string) (leased bool, err error)
• type Execution
• type ExecutorF
• type Lease
  • func NewLease(identifier, clusterID string) *Lease
• type LeaseBackend
• type MockLeaseBackend
  • func NewMockLeaseBackend(ctrl *gomock.Controller) *MockLeaseBackend
  • func (m *MockLeaseBackend) EXPECT() *MockLeaseBackendMockRecorder
  • func (m *MockLeaseBackend) TryAcquire(arg0 context.Context, arg1, arg2 string) (bool, error)
• type MockLeaseBackendMockRecorder
  • func (mr *MockLeaseBackendMockRecorder) TryAcquire(arg0, arg1, arg2 interface{}) *gomock.Call
• type MongoLease
• type MongoLeaseBackend
  • func NewMongoLeaseBackend(db *mongo.Database) *MongoLeaseBackend
  • func (b *MongoLeaseBackend) TryAcquire(ctx context.Context, id, clusterID string) (leased bool, err error)
• type Option
  • func WithClusterID(id string) Option
  • func WithExecutor(triggerExecutor ExecutorF) Option
  • func WithHostnameIdentifier() Option
  • func WithIdentifier(id string) Option
  • func WithLeaseCheckerInterval(interval time.Duration) Option
  • func WithScraperInterval(interval time.Duration) Option
  • func WithTestkubeNamespace(namespace string) Option
  • func WithWatchFromDate(from time.Time) Option
  • func WithWatcherNamespaces(namespaces string) Option
• type Service
  • func NewService(scheduler *scheduler.Scheduler, clientset kubernetes.Interface, ...) *Service
  • func (s *Service) Run(ctx context.Context)

Constants

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

Variables

var (
	ErrConditionTimeout = errors.New("timed-out waiting for trigger conditions")
	ErrProbeTimeout     = errors.New("timed-out waiting for trigger probes")
)

Types

type AcquireAlwaysLeaseBackend

type AcquireAlwaysLeaseBackend struct{}

func NewAcquireAlwaysLeaseBackend

func NewAcquireAlwaysLeaseBackend() *AcquireAlwaysLeaseBackend

func (*AcquireAlwaysLeaseBackend) TryAcquire

func (b *AcquireAlwaysLeaseBackend) TryAcquire(ctx context.Context, id, clusterID string) (leased bool, err error)

type Execution

type Execution string

type ExecutorF

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

type Lease

type Lease struct {
	Identifier string    `bson:"identifier"`
	ClusterID  string    `bson:"cluster_id"`
	AcquiredAt time.Time `bson:"acquired_at"`
	RenewedAt  time.Time `bson:"renewed_at"`
}

func NewLease

func NewLease(identifier, clusterID string) *Lease

type LeaseBackend

type LeaseBackend interface {
	// TryAcquire tries to acquire lease from underlying datastore
	TryAcquire(ctx context.Context, id, clusterID string) (leased bool, err error)
}

LeaseBackend does a check and set operation on the Lease object in the defined data source

type MockLeaseBackend

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

MockLeaseBackend is a mock of LeaseBackend interface.

func NewMockLeaseBackend

func NewMockLeaseBackend(ctrl *gomock.Controller) *MockLeaseBackend

NewMockLeaseBackend creates a new mock instance.

func (*MockLeaseBackend) EXPECT

func (m *MockLeaseBackend) EXPECT() *MockLeaseBackendMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLeaseBackend) TryAcquire

func (m *MockLeaseBackend) TryAcquire(arg0 context.Context, arg1, arg2 string) (bool, error)

TryAcquire mocks base method.

type MockLeaseBackendMockRecorder

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

MockLeaseBackendMockRecorder is the mock recorder for MockLeaseBackend.

func (*MockLeaseBackendMockRecorder) TryAcquire

func (mr *MockLeaseBackendMockRecorder) TryAcquire(arg0, arg1, arg2 interface{}) *gomock.Call

TryAcquire indicates an expected call of TryAcquire.

type MongoLease

type MongoLease struct {
	Lease
	// contains filtered or unexported fields
}

type MongoLeaseBackend

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

func NewMongoLeaseBackend

func NewMongoLeaseBackend(db *mongo.Database) *MongoLeaseBackend

func (*MongoLeaseBackend) TryAcquire

func (b *MongoLeaseBackend) TryAcquire(ctx context.Context, id, clusterID string) (leased bool, err error)

type Option

type Option func(*Service)

func WithClusterID

func WithClusterID(id string) Option

func WithExecutor

func WithExecutor(triggerExecutor ExecutorF) Option

func WithHostnameIdentifier

func WithHostnameIdentifier() Option

func WithIdentifier

func WithIdentifier(id string) Option

func WithLeaseCheckerInterval

func WithLeaseCheckerInterval(interval time.Duration) Option

func WithScraperInterval

func WithScraperInterval(interval time.Duration) Option

func WithTestkubeNamespace

func WithTestkubeNamespace(namespace string) Option

func WithWatchFromDate

func WithWatchFromDate(from time.Time) Option

func WithWatcherNamespaces

func WithWatcherNamespaces(namespaces string) Option

type Service

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

func NewService

func NewService(
	scheduler *scheduler.Scheduler,
	clientset kubernetes.Interface,
	testKubeClientset testkubeclientsetv1.Interface,
	testSuitesClient testsuitesclientv3.Interface,
	testsClient testsclientv3.Interface,
	resultRepository result.Repository,
	testResultRepository testresult.Repository,
	leaseBackend LeaseBackend,
	logger *zap.SugaredLogger,
	configMap config.Repository,
	executorsClient executorsclientv1.Interface,
	testExecutor client.Executor,
	eventsBus bus.Bus,
	metrics metrics.Metrics,
	opts ...Option,
) *Service

func (*Service) Run

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