observer

Documentation

Index

• func ListRegisteredSinkTypes() []string
• func Register(item ObRegItem)
• type Configuration
• type ObRegItem
• type Observer
  • func CreateObserver(config Configuration) (Observer, error)
• type ObserverConstructor
  • func GetConstructor(obName string) ObserverConstructor

Functions

func ListRegisteredSinkTypes

func ListRegisteredSinkTypes() []string

func Register

func Register(item ObRegItem)

The sink will register itself in `init`. During that the the logger may not be inited. So here we'd better not log anything

Types

type Configuration

type Configuration struct {
	Type       string                 `json:"type"`
	Properties map[string]interface{} `json:"properties"`
}

type ObRegItem

type ObRegItem struct {
	Name        string
	Constructor ObserverConstructor
}

type Observer

type Observer interface {
	Observe() error
	Stop()
	Wait()
}

func CreateObserver

func CreateObserver(config Configuration) (Observer, error)

type ObserverConstructor

type ObserverConstructor func(properties map[string]interface{}) (Observer, error)

func GetConstructor

func GetConstructor(obName string) ObserverConstructor