store

Documentation

Index

• Variables
• func IgnoreAlreadyExists(err error) error
• func IgnoreErrNotFound(err error) error
• type Store
• type Watch
• type WatchEvent
• type WatchEventType

Variables

var (
	ErrNotFound      = errors.New("not found")
	ErrAlreadyExists = errors.New("already exists")
)

Functions

func IgnoreAlreadyExists

func IgnoreAlreadyExists(err error) error

func IgnoreErrNotFound

func IgnoreErrNotFound(err error) error

Types

type Store

type Store[E api.Object] interface {
	Create(ctx context.Context, obj E) (E, error)
	Get(ctx context.Context, id string) (E, error)
	Update(ctx context.Context, obj E) (E, error)
	Delete(ctx context.Context, id string) error
	List(ctx context.Context) ([]E, error)

	Watch(ctx context.Context) (Watch[E], error)
}

type Watch

type Watch[E api.Object] interface {
	Stop()
	Events() <-chan WatchEvent[E]
}

type WatchEvent

type WatchEvent[E api.Object] struct {
	Type   WatchEventType
	Object E
}

type WatchEventType

type WatchEventType string

const (
	WatchEventTypeCreated WatchEventType = "Created"
	WatchEventTypeUpdated WatchEventType = "Updated"
	WatchEventTypeDeleted WatchEventType = "Deleted"
)