k8s

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 13, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Overview

Package k8s is a generated GoMock package.

Index

Constants

View Source 
const (
	AuthzKey mtls.RequestAuthKey = "APIAuthzkey"
)

Variables

This section is empty.

Functions

func GetDefaultMetricsReceiver 

func GetDefaultMetricsReceiver() *models.MetricsReceiverConfiguration

func NewBackend 

func NewBackend(repository RepositoryFacade, assembler *ConfigurationAssembler,
	logger *zap.SugaredLogger, initialNamespace string, recorder record.EventRecorder) backendapi.EdgeDeviceBackend

Types

type ConfigurationAssembler 

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

func NewConfigurationAssembler 

func NewConfigurationAssembler(allowLists devicemetrics.AllowListGenerator,
	claimer *storage.Claimer,
	configMaps configmaps.ConfigMap,
	recorder record.EventRecorder,
	registryAuthRepository images.RegistryAuthAPI,
	repository RepositoryFacade) *ConfigurationAssembler

func (*ConfigurationAssembler) GetDeviceConfiguration 

func (a *ConfigurationAssembler) GetDeviceConfiguration(ctx context.Context, edgeDevice *v1alpha1.EdgeDevice, logger *zap.SugaredLogger) (*models.DeviceConfigurationMessage, error)

type CoreRepository 

type CoreRepository interface {
	GetSecret(ctx context.Context, name string, namespace string) (*v1.Secret, error)
	GetConfigMap(ctx context.Context, name string, namespace string) (*v1.ConfigMap, error)
}

type EdgeDeviceRepository 

type EdgeDeviceRepository interface {
	GetEdgeDevice(ctx context.Context, name, namespace string) (*v1alpha1.EdgeDevice, error)
	PatchEdgeDeviceStatus(ctx context.Context, edgeDevice *v1alpha1.EdgeDevice, patch *client.Patch) error
	UpdateEdgeDeviceLabels(ctx context.Context, device *v1alpha1.EdgeDevice, labels map[string]string) error
	PatchEdgeDevice(ctx context.Context, old, new *v1alpha1.EdgeDevice) error
}

type EdgeDeviceSetRepository 

type EdgeDeviceSetRepository interface {
	GetEdgeDeviceSet(ctx context.Context, name string, namespace string) (*v1alpha1.EdgeDeviceSet, error)
}

type EdgeDeviceSignedRequestRepository 

type EdgeDeviceSignedRequestRepository interface {
	GetEdgeDeviceSignedRequest(ctx context.Context, name string, namespace string) (*v1alpha1.EdgeDeviceSignedRequest, error)
	CreateEdgeDeviceSignedRequest(ctx context.Context, edgeDeviceSignedRequest *v1alpha1.EdgeDeviceSignedRequest) error
}

type EdgeWorkloadRepository 

type EdgeWorkloadRepository interface {
	GetEdgeWorkload(ctx context.Context, name string, namespace string) (*v1alpha1.EdgeWorkload, error)
}

type MockRepositoryFacade 

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

MockRepositoryFacade is a mock of RepositoryFacade interface.

func NewMockRepositoryFacade 

func NewMockRepositoryFacade(ctrl *gomock.Controller) *MockRepositoryFacade

NewMockRepositoryFacade creates a new mock instance.

func (*MockRepositoryFacade) CreateEdgeDeviceSignedRequest 

func (m *MockRepositoryFacade) CreateEdgeDeviceSignedRequest(arg0 context.Context, arg1 *v1alpha1.EdgeDeviceSignedRequest) error

CreateEdgeDeviceSignedRequest mocks base method.

func (*MockRepositoryFacade) EXPECT 

func (m *MockRepositoryFacade) EXPECT() *MockRepositoryFacadeMockRecorder

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

func (*MockRepositoryFacade) GetConfigMap 

func (m *MockRepositoryFacade) GetConfigMap(arg0 context.Context, arg1, arg2 string) (*v1.ConfigMap, error)

GetConfigMap mocks base method.

func (*MockRepositoryFacade) GetEdgeDevice 

func (m *MockRepositoryFacade) GetEdgeDevice(arg0 context.Context, arg1, arg2 string) (*v1alpha1.EdgeDevice, error)

GetEdgeDevice mocks base method.

func (*MockRepositoryFacade) GetEdgeDeviceSet 

func (m *MockRepositoryFacade) GetEdgeDeviceSet(arg0 context.Context, arg1, arg2 string) (*v1alpha1.EdgeDeviceSet, error)

GetEdgeDeviceSet mocks base method.

func (*MockRepositoryFacade) GetEdgeDeviceSignedRequest 

func (m *MockRepositoryFacade) GetEdgeDeviceSignedRequest(arg0 context.Context, arg1, arg2 string) (*v1alpha1.EdgeDeviceSignedRequest, error)

GetEdgeDeviceSignedRequest mocks base method.

func (*MockRepositoryFacade) GetEdgeWorkload 

func (m *MockRepositoryFacade) GetEdgeWorkload(arg0 context.Context, arg1, arg2 string) (*v1alpha1.EdgeWorkload, error)

GetEdgeWorkload mocks base method.

func (*MockRepositoryFacade) GetSecret 

func (m *MockRepositoryFacade) GetSecret(arg0 context.Context, arg1, arg2 string) (*v1.Secret, error)

GetSecret mocks base method.

func (*MockRepositoryFacade) PatchEdgeDevice 

func (m *MockRepositoryFacade) PatchEdgeDevice(arg0 context.Context, arg1, arg2 *v1alpha1.EdgeDevice) error

PatchEdgeDevice mocks base method.

func (*MockRepositoryFacade) PatchEdgeDeviceStatus 

func (m *MockRepositoryFacade) PatchEdgeDeviceStatus(arg0 context.Context, arg1 *v1alpha1.EdgeDevice, arg2 *client.Patch) error

PatchEdgeDeviceStatus mocks base method.

func (*MockRepositoryFacade) UpdateEdgeDeviceLabels 

func (m *MockRepositoryFacade) UpdateEdgeDeviceLabels(arg0 context.Context, arg1 *v1alpha1.EdgeDevice, arg2 map[string]string) error

UpdateEdgeDeviceLabels mocks base method.

type MockRepositoryFacadeMockRecorder 

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

MockRepositoryFacadeMockRecorder is the mock recorder for MockRepositoryFacade.

func (*MockRepositoryFacadeMockRecorder) CreateEdgeDeviceSignedRequest 

func (mr *MockRepositoryFacadeMockRecorder) CreateEdgeDeviceSignedRequest(arg0, arg1 interface{}) *gomock.Call

CreateEdgeDeviceSignedRequest indicates an expected call of CreateEdgeDeviceSignedRequest.

func (*MockRepositoryFacadeMockRecorder) GetConfigMap 

func (mr *MockRepositoryFacadeMockRecorder) GetConfigMap(arg0, arg1, arg2 interface{}) *gomock.Call

GetConfigMap indicates an expected call of GetConfigMap.

func (*MockRepositoryFacadeMockRecorder) GetEdgeDevice 

func (mr *MockRepositoryFacadeMockRecorder) GetEdgeDevice(arg0, arg1, arg2 interface{}) *gomock.Call

GetEdgeDevice indicates an expected call of GetEdgeDevice.

func (*MockRepositoryFacadeMockRecorder) GetEdgeDeviceSet 

func (mr *MockRepositoryFacadeMockRecorder) GetEdgeDeviceSet(arg0, arg1, arg2 interface{}) *gomock.Call

GetEdgeDeviceSet indicates an expected call of GetEdgeDeviceSet.

func (*MockRepositoryFacadeMockRecorder) GetEdgeDeviceSignedRequest 

func (mr *MockRepositoryFacadeMockRecorder) GetEdgeDeviceSignedRequest(arg0, arg1, arg2 interface{}) *gomock.Call

GetEdgeDeviceSignedRequest indicates an expected call of GetEdgeDeviceSignedRequest.

func (*MockRepositoryFacadeMockRecorder) GetEdgeWorkload 

func (mr *MockRepositoryFacadeMockRecorder) GetEdgeWorkload(arg0, arg1, arg2 interface{}) *gomock.Call

GetEdgeWorkload indicates an expected call of GetEdgeWorkload.

func (*MockRepositoryFacadeMockRecorder) GetSecret 

func (mr *MockRepositoryFacadeMockRecorder) GetSecret(arg0, arg1, arg2 interface{}) *gomock.Call

GetSecret indicates an expected call of GetSecret.

func (*MockRepositoryFacadeMockRecorder) PatchEdgeDevice 

func (mr *MockRepositoryFacadeMockRecorder) PatchEdgeDevice(arg0, arg1, arg2 interface{}) *gomock.Call

PatchEdgeDevice indicates an expected call of PatchEdgeDevice.

func (*MockRepositoryFacadeMockRecorder) PatchEdgeDeviceStatus 

func (mr *MockRepositoryFacadeMockRecorder) PatchEdgeDeviceStatus(arg0, arg1, arg2 interface{}) *gomock.Call

PatchEdgeDeviceStatus indicates an expected call of PatchEdgeDeviceStatus.

func (*MockRepositoryFacadeMockRecorder) UpdateEdgeDeviceLabels 

func (mr *MockRepositoryFacadeMockRecorder) UpdateEdgeDeviceLabels(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateEdgeDeviceLabels indicates an expected call of UpdateEdgeDeviceLabels.

type RepositoryFacade 

type RepositoryFacade interface {
	EdgeDeviceRepository
	EdgeDeviceSignedRequestRepository
	EdgeWorkloadRepository
	EdgeDeviceSetRepository
	CoreRepository
}

func NewRepository 

func NewRepository(deviceSignedRequestRepository edgedevicesignedrequest.Repository,
	deviceRepository edgedevice.Repository,
	workloadRepository edgeworkload.Repository,
	deviceSetRepository edgedeviceset.Repository,
	client k8sclient.K8sClient) RepositoryFacade

type SynchronousHandler 

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

func NewSynchronousHandler 

func NewSynchronousHandler(repository RepositoryFacade, recorder record.EventRecorder,
	logger *zap.SugaredLogger) *SynchronousHandler

func (*SynchronousHandler) Process 

func (h *SynchronousHandler) Process(ctx context.Context, name, namespace string, heartbeat *models.Heartbeat) (bool, error)

type Updater 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.