listener

Documentation

Index

• type SKREventsListener
  • func RegisterListenerComponent(addr, componentName string) (*SKREventsListener, *source.Channel)
  • func (l *SKREventsListener) Start(ctx context.Context) error
• type UnmarshalError
• type WatcherEvent

Types

type SKREventsListener

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

func RegisterListenerComponent

func RegisterListenerComponent(addr, componentName string) (*SKREventsListener, *source.Channel)

func (*SKREventsListener) Start

func (l *SKREventsListener) Start(ctx context.Context) error

type UnmarshalError

type UnmarshalError struct {
	Message string
	// contains filtered or unexported fields
}

type WatcherEvent

type WatcherEvent struct {
	SkrClusterID string `json:"skrClusterID"`
	Component    string `json:"body"`
	Namespace    string `json:"namespace"`
	Name         string `json:"name"`
}