publisher

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Aug 20, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package publisher is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockPublisher

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

MockPublisher is a mock of Publisher interface.

func NewMockPublisher

func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher

NewMockPublisher creates a new mock instance.

func (*MockPublisher) EXPECT

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

func (*MockPublisher) Run

func (m *MockPublisher) Run(ctx context.Context, wg *sync.WaitGroup)

Run mocks base method.

func (*MockPublisher) SetClient

func (m *MockPublisher) SetClient(arg0 client.Management)

SetClient mocks base method.

func (*MockPublisher) Subscribe

func (m *MockPublisher) Subscribe() Subscription

Subscribe mocks base method.

type MockPublisherMockRecorder

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

MockPublisherMockRecorder is the mock recorder for MockPublisher.

func (*MockPublisherMockRecorder) Run

func (mr *MockPublisherMockRecorder) Run(ctx, wg any) *gomock.Call

Run indicates an expected call of Run.

func (*MockPublisherMockRecorder) SetClient

func (mr *MockPublisherMockRecorder) SetClient(arg0 any) *gomock.Call

SetClient indicates an expected call of SetClient.

func (*MockPublisherMockRecorder) Subscribe

func (mr *MockPublisherMockRecorder) Subscribe() *gomock.Call

Subscribe indicates an expected call of Subscribe.

type Publisher

type Publisher interface {
	Run(ctx context.Context, wg *sync.WaitGroup)
	Subscribe() Subscription
	SetClient(client.Management)
}

func New

func New(deviceName string,
	interval time.Duration,
	backoff wait.Backoff,
	log *log.PrefixLogger) Publisher

type Subscription

type Subscription = *ring_buffer.RingBuffer[*v1alpha1.Device]

func NewSubscription

func NewSubscription() Subscription

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL