cfcomponent

package

v0.0.0-...-0848747 Latest Latest Go to latest Published: Apr 2, 2015 License: Apache-2.0, BSD-3-Clause, MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wulonghui/loggregatorlib

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Variables
func DumpGoRoutine()
func GetNewSyslogSink(namespace string) *gosteno.Syslog
func NewLogger(verbose bool, logFilePath, name string, config Config) *gosteno.Logger
func ReadConfigInto(config interface{}, configPath string) error
func RegisterGoRoutineDumpSignalChannel() chan os.Signal
type Component
- func NewComponent(logger *gosteno.Logger, componentType string, index uint, ...) (Component, error)
- func (c Component) StartMonitoringEndpoints() error
type Config
- func (c *Config) Validate(logger *gosteno.Logger) (err error)
type HealthMonitor

Constants ¶

This section is empty.

Variables ¶

View Source

var DefaultYagnatsClientProvider = func(logger *gosteno.Logger, c *Config) (natsClient yagnats.NATSConn, err error) {
	members := make([]string, 0)
	for _, natsHost := range c.NatsHosts {
		members = append(members, fmt.Sprintf("nats://%s:%s@%s:%d", c.NatsUser, c.NatsPass, natsHost, c.NatsPort))
	}

	natsClient, err = yagnats.Connect(members)
	if err != nil {
		return nil, errors.New(fmt.Sprintf("Could not connect to NATS: %v", err.Error()))
	}
	return natsClient, nil
}

View Source

var Logger *gosteno.Logger

Functions ¶

func DumpGoRoutine ¶

func DumpGoRoutine()

func GetNewSyslogSink ¶

func GetNewSyslogSink(namespace string) *gosteno.Syslog

func NewLogger ¶

func NewLogger(verbose bool, logFilePath, name string, config Config) *gosteno.Logger

func ReadConfigInto ¶

func ReadConfigInto(config interface{}, configPath string) error

func RegisterGoRoutineDumpSignalChannel ¶

func RegisterGoRoutineDumpSignalChannel() chan os.Signal

Types ¶

type Component ¶

type Component struct {
	*gosteno.Logger
	IpAddress         string
	HealthMonitor     HealthMonitor
	Type              string //Used by the collector to find data processing class
	Index             uint
	UUID              string
	StatusPort        uint16
	StatusCredentials []string
	Instrumentables   []instrumentation.Instrumentable
}

func NewComponent ¶

func NewComponent(logger *gosteno.Logger, componentType string, index uint, heathMonitor HealthMonitor, statusPort uint16, statusCreds []string, instrumentables []instrumentation.Instrumentable) (Component, error)

func (Component) StartMonitoringEndpoints ¶

func (c Component) StartMonitoringEndpoints() error

type Config ¶

type Config struct {
	Syslog                                 string
	VarzPort                               uint16
	VarzUser                               string
	VarzPass                               string
	NatsHosts                              []string
	NatsPort                               int
	NatsUser                               string
	NatsPass                               string
	MbusClient                             yagnats.NATSConn
	CollectorRegistrarIntervalMilliseconds int
}

func (*Config) Validate ¶

func (c *Config) Validate(logger *gosteno.Logger) (err error)

type HealthMonitor ¶

type HealthMonitor interface {
	Ok() bool
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
auth
generic_logger
instrumentation
testhelpers
registrars
collectorregistrar
legacycollectorregistrar
routerregistrar
uaa

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL