Help us shape the future of Go! Take the 2026 Go Developer Survey

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.