events

Documentation

Index

• type ContentEvent
• type EventHandler
• type EventHandlerFunc
  • func (f EventHandlerFunc) OnEvent(ev ContentEvent) error
• type EventHub
  • func NewEventHub(logger *log.Logger, eventSource EventSource, fileNameHash hash.Hash, ...) *EventHub
  • func (h *EventHub) Close() error
  • func (h *EventHub) Subscribe(handler EventHandler) (id uuid.UUID)
  • func (h *EventHub) Unsubscribe(id uuid.UUID) (err error)
• type EventMutation
• type EventSource
• type MutationConfigReloadForFile
  • func (t MutationConfigReloadForFile) OnEvent(in ContentEvent, ev fs.Event) (out ContentEvent)
• type MutationReloadForFile
  • func (t MutationReloadForFile) OnEvent(in ContentEvent, ev fs.Event) (out ContentEvent)

Types

type ContentEvent

type ContentEvent struct {
	File         string `json:"file"`
	FileNameHash string `json:"fileNameHash"`
	Timestamp    string `json:"ts"`
	ForceReload  bool   `json:"forceReload"`
	ReloadConfig bool   `json:"reloadConfig"`
}

type EventHandler

type EventHandler interface {
	OnEvent(ev ContentEvent) error
	Close() error
}

type EventHandlerFunc

type EventHandlerFunc func(ev ContentEvent) error

func (EventHandlerFunc) OnEvent

func (f EventHandlerFunc) OnEvent(ev ContentEvent) error

type EventHub

type EventHub struct {
	FileNameHash hash.Hash
	Logger       *log.Logger
	// contains filtered or unexported fields
}

func NewEventHub

func NewEventHub(logger *log.Logger, eventSource EventSource, fileNameHash hash.Hash, mutations ...EventMutation) *EventHub

func (*EventHub) Close

func (h *EventHub) Close() error

func (*EventHub) Subscribe

func (h *EventHub) Subscribe(handler EventHandler) (id uuid.UUID)

func (*EventHub) Unsubscribe

func (h *EventHub) Unsubscribe(id uuid.UUID) (err error)

type EventMutation

type EventMutation interface {
	OnEvent(in ContentEvent, ev fs.Event) (out ContentEvent)
}

type EventSource

type EventSource interface {
	io.Closer
	fs.FS
	Events() chan fs.Event
}

type MutationConfigReloadForFile

type MutationConfigReloadForFile string

func (MutationConfigReloadForFile) OnEvent

func (t MutationConfigReloadForFile) OnEvent(in ContentEvent, ev fs.Event) (out ContentEvent)

type MutationReloadForFile

type MutationReloadForFile string

func (MutationReloadForFile) OnEvent

func (t MutationReloadForFile) OnEvent(in ContentEvent, ev fs.Event) (out ContentEvent)