watchers

package

v0.0.0-...-3ea6822 Latest Latest Go to latest Published: Mar 31, 2023 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/adriansr/sm-controller

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ToK8S(w Watcher, fn ErrorHandler) cache.ResourceEventHandler
type Action
- func (a Action) String() string
type Chain
- func (s Chain) OnAdd(obj schema.Object) error
- func (s Chain) OnDelete(obj schema.Object) error
- func (s Chain) OnUpdate(oldObj, newObj schema.Object) error
type ErrorHandler
type Event
type Filter
- func (f Filter) OnAdd(obj schema.Object) error
- func (f Filter) OnDelete(obj schema.Object) error
- func (f Filter) OnUpdate(oldObj, newObj schema.Object) error
type Logger
- func (l Logger) OnAdd(obj schema.Object) error
- func (l Logger) OnDelete(obj schema.Object) error
- func (l Logger) OnUpdate(oldObj, newObj schema.Object) error
type PipelineError
- func (e PipelineError) Error() string
- func (e PipelineError) Unwrap() error
type Publisher
- func (p Publisher) OnAdd(obj schema.Object) error
- func (p Publisher) OnDelete(obj schema.Object) error
- func (p Publisher) OnUpdate(oldObj, newObj schema.Object) error
type ResourceMetaSetter
- func (s ResourceMetaSetter) OnAdd(obj schema.Object) error
- func (s ResourceMetaSetter) OnDelete(obj schema.Object) error
- func (s ResourceMetaSetter) OnUpdate(oldObj, newObj schema.Object) error
type TypeAssert
- func (t TypeAssert[T]) OnAdd(obj schema.Object) error
- func (t TypeAssert[T]) OnDelete(obj schema.Object) error
- func (t TypeAssert[T]) OnUpdate(oldObj, newObj schema.Object) error
type UpdateFilter
- func (f UpdateFilter) OnAdd(obj schema.Object) error
- func (f UpdateFilter) OnDelete(obj schema.Object) error
- func (f UpdateFilter) OnUpdate(oldObj, newObj schema.Object) error
type Watcher

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrSkipEvent = errors.New("event filtered")
)

Functions ¶

func ToK8S ¶

func ToK8S(w Watcher, fn ErrorHandler) cache.ResourceEventHandler

Types ¶

type Action ¶

type Action uint8

const (
	Add Action = iota + 1
	Update
	Delete
	Cast
)

func (Action) String ¶

func (a Action) String() string

type Chain ¶

type Chain []Watcher

func (Chain) OnAdd ¶

func (s Chain) OnAdd(obj schema.Object) error

func (Chain) OnDelete ¶

func (s Chain) OnDelete(obj schema.Object) error

func (Chain) OnUpdate ¶

func (s Chain) OnUpdate(oldObj, newObj schema.Object) error

type ErrorHandler ¶

type ErrorHandler func(error)

type Event ¶

type Event struct {
	Obj    schema.Object
	Action Action
}

type Filter ¶

type Filter func(schema.Object) bool

func (Filter) OnAdd ¶

func (f Filter) OnAdd(obj schema.Object) error

func (Filter) OnDelete ¶

func (f Filter) OnDelete(obj schema.Object) error

func (Filter) OnUpdate ¶

func (f Filter) OnUpdate(oldObj, newObj schema.Object) error

type Logger ¶

type Logger struct {
	*zerolog.Logger
	Level zerolog.Level
}

func (Logger) OnAdd ¶

func (l Logger) OnAdd(obj schema.Object) error

func (Logger) OnDelete ¶

func (l Logger) OnDelete(obj schema.Object) error

func (Logger) OnUpdate ¶

func (l Logger) OnUpdate(oldObj, newObj schema.Object) error

type PipelineError ¶

type PipelineError struct {
	Err     error
	Object  interface{}
	Watcher Watcher
	Action  Action
}

func (PipelineError) Error ¶

func (e PipelineError) Error() string

func (PipelineError) Unwrap ¶

func (e PipelineError) Unwrap() error

type Publisher ¶

type Publisher struct {
	C   chan<- Event
	Ctx context.Context
}

func (Publisher) OnAdd ¶

func (p Publisher) OnAdd(obj schema.Object) error

func (Publisher) OnDelete ¶

func (p Publisher) OnDelete(obj schema.Object) error

func (Publisher) OnUpdate ¶

func (p Publisher) OnUpdate(oldObj, newObj schema.Object) error

type ResourceMetaSetter ¶

type ResourceMetaSetter schema.Resource

func (ResourceMetaSetter) OnAdd ¶

func (s ResourceMetaSetter) OnAdd(obj schema.Object) error

func (ResourceMetaSetter) OnDelete ¶

func (s ResourceMetaSetter) OnDelete(obj schema.Object) error

func (ResourceMetaSetter) OnUpdate ¶

func (s ResourceMetaSetter) OnUpdate(oldObj, newObj schema.Object) error

type TypeAssert ¶

type TypeAssert[T any] struct{}

func (TypeAssert[T]) OnAdd ¶

func (t TypeAssert[T]) OnAdd(obj schema.Object) error

func (TypeAssert[T]) OnDelete ¶

func (t TypeAssert[T]) OnDelete(obj schema.Object) error

func (TypeAssert[T]) OnUpdate ¶

func (t TypeAssert[T]) OnUpdate(oldObj, newObj schema.Object) error

type UpdateFilter ¶

type UpdateFilter func(oldObj schema.Object, newObj schema.Object) bool

func (UpdateFilter) OnAdd ¶

func (f UpdateFilter) OnAdd(obj schema.Object) error

func (UpdateFilter) OnDelete ¶

func (f UpdateFilter) OnDelete(obj schema.Object) error

func (UpdateFilter) OnUpdate ¶

func (f UpdateFilter) OnUpdate(oldObj, newObj schema.Object) error

type Watcher ¶

type Watcher interface {
	OnAdd(obj schema.Object) error
	OnUpdate(oldObj, newObj schema.Object) error
	OnDelete(obj schema.Object) error
}

Source Files ¶

View all Source files

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