source

Documentation

Index

• Constants
• type BaseSourceHandler
  • func NewSourceHandler(config *config.SourceConfig) *BaseSourceHandler
  • func (h *BaseSourceHandler) AddDatabaseSource(source *sourceApi.DatabaseSource) error
  • func (h *BaseSourceHandler) GetSource(name string) *sourceApi.DatabaseSource
  • func (h *BaseSourceHandler) Handle(msg server.NamedElement) error
  • func (h *BaseSourceHandler) Init(setter server.GlobalSetter) error
  • func (h *BaseSourceHandler) IsReady(dbName, instanceName string) bool
  • func (h *BaseSourceHandler) MarkDatabaseSourceIdle(name string) error
  • func (h *BaseSourceHandler) OnDbStatusChanged(dbStatus *grpcServerApi.DbStatusResponse) bool
  • func (h *BaseSourceHandler) OnInstanceStatusChanged(instanceStatus *grpcServerApi.InstanceStatusResponse) bool
  • func (h *BaseSourceHandler) PostInit(getter server.GlobalGetter) error
  • func (h *BaseSourceHandler) RemoveDatabaseSource(source *sourceApi.DatabaseSource)
• type FileSourceHandler
  • func NewFileSourceHandler(handler sourceApi.SourceHandler, config *config.FileSourceConfig) *FileSourceHandler
  • func (h *FileSourceHandler) FilesToWatch() []string
  • func (h *FileSourceHandler) Handle(msg server.NamedElement) error
  • func (h *FileSourceHandler) Init(setter server.GlobalSetter) error
  • func (h *FileSourceHandler) OnWatchError(err error)
  • func (h *FileSourceHandler) PostInit(getter server.GlobalGetter) error

Constants

const FileSourceEnding = ".yaml"

Types

type BaseSourceHandler

type BaseSourceHandler struct {
	Config *config.SourceConfig

	Databases map[string]*sourceApi.DatabaseSource

	Instances map[string]bool
	// contains filtered or unexported fields
}

func NewSourceHandler

func NewSourceHandler(config *config.SourceConfig) *BaseSourceHandler

func (*BaseSourceHandler) AddDatabaseSource

func (h *BaseSourceHandler) AddDatabaseSource(source *sourceApi.DatabaseSource) error

func (*BaseSourceHandler) GetSource

func (h *BaseSourceHandler) GetSource(name string) *sourceApi.DatabaseSource

func (*BaseSourceHandler) Handle

func (h *BaseSourceHandler) Handle(msg server.NamedElement) error

func (*BaseSourceHandler) Init

func (h *BaseSourceHandler) Init(setter server.GlobalSetter) error

func (*BaseSourceHandler) IsReady

func (h *BaseSourceHandler) IsReady(dbName, instanceName string) bool

func (*BaseSourceHandler) MarkDatabaseSourceIdle

func (h *BaseSourceHandler) MarkDatabaseSourceIdle(name string) error

func (*BaseSourceHandler) OnDbStatusChanged

func (h *BaseSourceHandler) OnDbStatusChanged(dbStatus *grpcServerApi.DbStatusResponse) bool

func (*BaseSourceHandler) OnInstanceStatusChanged

func (h *BaseSourceHandler) OnInstanceStatusChanged(instanceStatus *grpcServerApi.InstanceStatusResponse) bool

func (*BaseSourceHandler) PostInit

func (h *BaseSourceHandler) PostInit(getter server.GlobalGetter) error

func (*BaseSourceHandler) RemoveDatabaseSource

func (h *BaseSourceHandler) RemoveDatabaseSource(source *sourceApi.DatabaseSource)

type FileSourceHandler

type FileSourceHandler struct {
	sourceApi.SourceHandler

	Config *config.FileSourceConfig
	// contains filtered or unexported fields
}

func NewFileSourceHandler

func NewFileSourceHandler(handler sourceApi.SourceHandler, config *config.FileSourceConfig) *FileSourceHandler

func (*FileSourceHandler) FilesToWatch

func (h *FileSourceHandler) FilesToWatch() []string

func (*FileSourceHandler) Handle

func (h *FileSourceHandler) Handle(msg server.NamedElement) error

func (*FileSourceHandler) Init

func (h *FileSourceHandler) Init(setter server.GlobalSetter) error

func (*FileSourceHandler) OnWatchError

func (h *FileSourceHandler) OnWatchError(err error)

func (*FileSourceHandler) PostInit

func (h *FileSourceHandler) PostInit(getter server.GlobalGetter) error