handler

Documentation

Index

• func NewDomainEventHandlers(logger *zap.Logger, config config.IConfig, ...) ddd.IEventHandler[ddd.IEvent]
• func NewNodeEventHandler(ctx context.Context, logger *zap.Logger, config config.IConfig, ...) k8s.IK8sEventHandler
• type NodeEventHandler
  • func (handler *NodeEventHandler) CustomWatchErrorHandler(r *cache.Reflector, err error)
  • func (handler *NodeEventHandler) OnAddObject(obj interface{})
  • func (handler *NodeEventHandler) OnDeleteObject(obj interface{})
  • func (handler *NodeEventHandler) OnUpdateObject(oldObj, newObj interface{})
• type NodeLabel

Functions

func NewDomainEventHandlers

func NewDomainEventHandlers(
	logger *zap.Logger,
	config config.IConfig,
	subscriber ddd.IEventDispatcher[ddd.IEvent],
	repository repository.IKVRepository,
	sessionService session.ISessionService,
) ddd.IEventHandler[ddd.IEvent]

func NewNodeEventHandler

func NewNodeEventHandler(
	ctx context.Context,
	logger *zap.Logger,
	config config.IConfig,
	domainEventDispatcher ddd.IEventDispatcher[ddd.IEvent],
	domainEventHandler ddd.IEventHandler[ddd.IEvent]) k8s.IK8sEventHandler

Types

type NodeEventHandler

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

func (*NodeEventHandler) CustomWatchErrorHandler

func (handler *NodeEventHandler) CustomWatchErrorHandler(r *cache.Reflector, err error)

func (*NodeEventHandler) OnAddObject

func (handler *NodeEventHandler) OnAddObject(obj interface{})

func (*NodeEventHandler) OnDeleteObject

func (handler *NodeEventHandler) OnDeleteObject(obj interface{})

func (*NodeEventHandler) OnUpdateObject

func (handler *NodeEventHandler) OnUpdateObject(oldObj, newObj interface{})

type NodeLabel

type NodeLabel string

const (
	NVIDIA_DRIVER_VERSION_MAJOR NodeLabel = "nvidia.com/cuda.driver.major"
	NVIDIA_DRIVER_VERSION_MINOR NodeLabel = "nvidia.com/cuda.driver.minor"
	NVIDIA_DRIVER_VERSION_REV   NodeLabel = "nvidia.com/cuda.driver.rev"
)