fake

Documentation

Index

• type Fake
  • func NewFake[T differ.Resource]() *Fake[T]
  • func (f *Fake[T]) List(ctx context.Context) (*differ.LocalRemoteResources[T], error)
  • func (f *Fake[T]) Stream(ctx context.Context) (*loader.StreamConn[T], error)
  • func (f *Fake[T]) WithList(fn func(context.Context) (*differ.LocalRemoteResources[T], error)) *Fake[T]
  • func (f *Fake[T]) WithStream(fn func(context.Context) (*loader.StreamConn[T], error)) *Fake[T]
• type FakeT
  • func New() *FakeT
  • func (f *FakeT) Components() loader.Loader[compapi.Component]
  • func (f *FakeT) Run(ctx context.Context) error
  • func (f *FakeT) Subscriptions() loader.Loader[subapi.Subscription]
  • func (f *FakeT) WithComponents(fake *Fake[compapi.Component]) *FakeT
  • func (f *FakeT) WithRun(fn func(context.Context) error) *FakeT

Types

type Fake

type Fake[T differ.Resource] struct {
	// contains filtered or unexported fields
}

func NewFake

func NewFake[T differ.Resource]() *Fake[T]

func (*Fake[T]) List

func (f *Fake[T]) List(ctx context.Context) (*differ.LocalRemoteResources[T], error)

func (*Fake[T]) Stream

func (f *Fake[T]) Stream(ctx context.Context) (*loader.StreamConn[T], error)

func (*Fake[T]) WithList

func (f *Fake[T]) WithList(fn func(context.Context) (*differ.LocalRemoteResources[T], error)) *Fake[T]

func (*Fake[T]) WithStream

func (f *Fake[T]) WithStream(fn func(context.Context) (*loader.StreamConn[T], error)) *Fake[T]

type FakeT

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

func New

func New() *FakeT

func (*FakeT) Components

func (f *FakeT) Components() loader.Loader[compapi.Component]

func (*FakeT) Run

func (f *FakeT) Run(ctx context.Context) error

func (*FakeT) Subscriptions

func (f *FakeT) Subscriptions() loader.Loader[subapi.Subscription]

func (*FakeT) WithComponents

func (f *FakeT) WithComponents(fake *Fake[compapi.Component]) *FakeT

func (*FakeT) WithRun

func (f *FakeT) WithRun(fn func(context.Context) error) *FakeT