services

Documentation

Overview

Package services is a generated GoMock package.

Index

• func HandleSubscription[T Service, U interface{}](ctx context.Context, topic string, s T, get func() (U, error)) (<-chan U, error)
• func Map[T interface{}, U interface{}](list []T, mapper func(item T) U) []U
• type ExecutorsService
  • func NewExecutorsService(service Service, client *executorsclientv1.ExecutorsClient) ExecutorsService
• type MockExecutorsService
  • func NewMockExecutorsService(ctrl *gomock.Controller) *MockExecutorsService
  • func (m *MockExecutorsService) EXPECT() *MockExecutorsServiceMockRecorder
  • func (m *MockExecutorsService) List(arg0 string) ([]testkube.ExecutorDetails, error)
  • func (m *MockExecutorsService) SubscribeList(arg0 context.Context, arg1 string) (<-chan []testkube.ExecutorDetails, error)
• type MockExecutorsServiceMockRecorder
  • func (mr *MockExecutorsServiceMockRecorder) List(arg0 interface{}) *gomock.Call
  • func (mr *MockExecutorsServiceMockRecorder) SubscribeList(arg0, arg1 interface{}) *gomock.Call
• type MockService
  • func NewMockService() MockService
• type Service
  • func NewService(bus bus.Bus, logger *zap.SugaredLogger) Service
• type ServiceBase
  • func (s *ServiceBase) Bus() bus.Bus
  • func (s *ServiceBase) Logger() *zap.SugaredLogger

Functions

func HandleSubscription

func HandleSubscription[T Service, U interface{}](
	ctx context.Context,
	topic string,
	s T,
	get func() (U, error),
) (<-chan U, error)

func Map

func Map[T interface{}, U interface{}](list []T, mapper func(item T) U) []U

Types

type ExecutorsService

type ExecutorsService interface {
	List(selector string) ([]testkube.ExecutorDetails, error)
	SubscribeList(ctx context.Context, selector string) (<-chan []testkube.ExecutorDetails, error)
}

func NewExecutorsService

func NewExecutorsService(service Service, client *executorsclientv1.ExecutorsClient) ExecutorsService

type MockExecutorsService

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

MockExecutorsService is a mock of ExecutorsService interface.

func NewMockExecutorsService

func NewMockExecutorsService(ctrl *gomock.Controller) *MockExecutorsService

NewMockExecutorsService creates a new mock instance.

func (*MockExecutorsService) EXPECT

func (m *MockExecutorsService) EXPECT() *MockExecutorsServiceMockRecorder

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

func (*MockExecutorsService) List

func (m *MockExecutorsService) List(arg0 string) ([]testkube.ExecutorDetails, error)

List mocks base method.

func (*MockExecutorsService) SubscribeList

func (m *MockExecutorsService) SubscribeList(arg0 context.Context, arg1 string) (<-chan []testkube.ExecutorDetails, error)

SubscribeList mocks base method.

type MockExecutorsServiceMockRecorder

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

MockExecutorsServiceMockRecorder is the mock recorder for MockExecutorsService.

func (*MockExecutorsServiceMockRecorder) List

func (mr *MockExecutorsServiceMockRecorder) List(arg0 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockExecutorsServiceMockRecorder) SubscribeList

func (mr *MockExecutorsServiceMockRecorder) SubscribeList(arg0, arg1 interface{}) *gomock.Call

SubscribeList indicates an expected call of SubscribeList.

type MockService

type MockService interface {
	Service
	BusMock() *bus.EventBusMock
	Reset()
}

func NewMockService

func NewMockService() MockService

type Service

type Service interface {
	Bus() bus.Bus
	Logger() *zap.SugaredLogger
}

func NewService

func NewService(bus bus.Bus, logger *zap.SugaredLogger) Service

type ServiceBase

type ServiceBase struct {
	Service
}

func (*ServiceBase) Bus

func (s *ServiceBase) Bus() bus.Bus

func (*ServiceBase) Logger

func (s *ServiceBase) Logger() *zap.SugaredLogger