base

package
v3.8.31 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 3, 2024 License: BSD-2-Clause, BSD-2-Clause Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidParameter = errors.New("invalid parameter")
	ErrNotReady         = errors.New("IngesterBase is not ready")
)

Functions

This section is empty.

Types

type IngesterBase 

type IngesterBase struct {
	IngesterBaseConfig
	Verbose bool
	Logger  *log.Logger
	Cfg     interface{}
	// contains filtered or unexported fields
}

func Init 

func Init(ibc IngesterBaseConfig) (ib IngesterBase, err error)

func (IngesterBase) AnnounceShutdown added in v3.8.23 

func (ib IngesterBase) AnnounceShutdown()

func (IngesterBase) AnnounceStartup added in v3.8.23 

func (ib IngesterBase) AnnounceStartup()

func (*IngesterBase) AssignConfig added in v3.8.17 

func (ib *IngesterBase) AssignConfig(v interface{}) (err error)

AssignConfig is a helper function that can take care of most of the sanity checking when trying to turn a native config object generated by IngesterBaseConfig.GetConfigFunc into the native type assigned into IngesterBase.Cfg.

Basically we are going to use some reflect foo to reduct the amount of boiler plate code needed by users of this library

func (*IngesterBase) Debug 

func (ib *IngesterBase) Debug(format string, args ...interface{})

func (*IngesterBase) GetMuxer 

func (ib *IngesterBase) GetMuxer() (igst *ingest.IngestMuxer, err error)

func (*IngesterBase) RegisterStat added in v3.8.27 

func (ib *IngesterBase) RegisterStat(name string) (*utils.StatsItem, error)

type IngesterBaseConfig 

type IngesterBaseConfig struct {
	IngesterName                 string
	AppName                      string
	DefaultConfigLocation        string
	DefaultConfigOverlayLocation string
	GetConfigFunc                interface{}
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.