resource

type Appendable interface {
	Append() interface{}
}

type Converter interface {
	NewK8s() interface{}
}

type EventHandler interface {
	K8sResource() interface{}
	ShouldNotify() bool
	Notify(gqlschema.SubscriptionEventType)
}

type EventHandlerProvider func() EventHandler

type GenericService struct {
	ServiceBase
}

type GenericServiceFactory struct {
	Client          dynamic.Interface
	InformerFactory dynamicinformer.DynamicSharedInformerFactory
}

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

type Module struct {
	*module.Pluggable
	// contains filtered or unexported fields
}

type Notifier struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Service struct {
	Client   dynamic.NamespaceableResourceInterface
	Informer cache.SharedIndexInformer
	// contains filtered or unexported fields
}

type ServiceBase interface {
	ListByIndex(index, key string, result Appendable) error
	GetByKey(key string, result interface{}) error
	AddIndexers(indexers cache.Indexers) error
	Create(obj interface{}, result interface{}) error
	Apply(obj interface{}, result interface{}) error
	GVR() schema.GroupVersionResource
	DeleteInNamespace(name, namespace string) error
	Delete(name string) error
	Subscribe(handler EventHandlerProvider) (Unsubscribe, error)
}

type ServiceCreator func(factory *GenericServiceFactory) (*GenericService, error)

type ServiceCreators map[schema.GroupVersionResource]ServiceCreator

type ServiceFactory struct {
	Client          dynamic.Interface
	InformerFactory dynamicinformer.DynamicSharedInformerFactory
}

type Unsubscribe func()