serf

Documentation

Index

• type Config
  • func DefaultConfig() *Config
• type DBDelegate
  • func NewDBDelegate(db kioradb.DB, logger zerolog.Logger) *DBDelegate
  • func (d *DBDelegate) LocalState(join bool) []byte
  • func (d *DBDelegate) MergeRemoteState(buf []byte, join bool)
• type DBDump
• type HCLogger
  • func (l *HCLogger) Debug(format string, args ...interface{})
  • func (l *HCLogger) Error(format string, args ...interface{})
  • func (l *HCLogger) GetLevel() hclog.Level
  • func (l *HCLogger) ImpliedArgs() []interface{}
  • func (l *HCLogger) Info(format string, args ...interface{})
  • func (l *HCLogger) IsDebug() bool
  • func (l *HCLogger) IsError() bool
  • func (l *HCLogger) IsInfo() bool
  • func (l *HCLogger) IsTrace() bool
  • func (l *HCLogger) IsWarn() bool
  • func (l *HCLogger) Log(level hclog.Level, format string, args ...interface{})
  • func (l *HCLogger) Name() string
  • func (l *HCLogger) Named(name string) hclog.Logger
  • func (l *HCLogger) ResetNamed(name string) hclog.Logger
  • func (l *HCLogger) SetLevel(level hclog.Level)
  • func (l *HCLogger) StandardLogger(opts *hclog.StandardLoggerOptions) *log.Logger
  • func (l *HCLogger) StandardWriter(opts *hclog.StandardLoggerOptions) io.Writer
  • func (l *HCLogger) Trace(format string, args ...interface{})
  • func (l *HCLogger) Warn(format string, args ...interface{})
  • func (l *HCLogger) With(args ...interface{}) hclog.Logger
• type SerfBroadcaster
  • func NewSerfBroadcaster(conf *Config) (*SerfBroadcaster, error)
  • func (s *SerfBroadcaster) BroadcastAlertAcknowledgement(ctx context.Context, alertID string, ack model.AlertAcknowledgement) error
  • func (s *SerfBroadcaster) BroadcastAlerts(ctx context.Context, alerts ...model.Alert) error
  • func (s *SerfBroadcaster) BroadcastSilences(ctx context.Context, silences ...model.Silence) error
  • func (s *SerfBroadcaster) Name() string
  • func (s *SerfBroadcaster) Run(ctx context.Context) error
  • func (s *SerfBroadcaster) Shutdown()

Types

type Config

type Config struct {
	ListenURL         string
	BootstrapPeers    []string
	NodeName          string
	ClustererDelegate clustering.ClustererDelegate
	EventDelegate     clustering.EventDelegate
	DBDelegate        serf.UserDelegate

	Logger zerolog.Logger
}

func DefaultConfig

func DefaultConfig() *Config

type DBDelegate

type DBDelegate struct {
	// contains filtered or unexported fields
}

func NewDBDelegate

func NewDBDelegate(db kioradb.DB, logger zerolog.Logger) *DBDelegate

func (*DBDelegate) LocalState

func (d *DBDelegate) LocalState(join bool) []byte

func (*DBDelegate) MergeRemoteState

func (d *DBDelegate) MergeRemoteState(buf []byte, join bool)

type DBDump

type DBDump struct {
	Alerts   []model.Alert
	Silences []model.Silence
}

type HCLogger

type HCLogger struct {
	zerolog.Logger
}

Logger is a wrapper around zerolog.Logger that implements hclog.Logger.

func (*HCLogger) Debug

func (l *HCLogger) Debug(format string, args ...interface{})

func (*HCLogger) Error

func (l *HCLogger) Error(format string, args ...interface{})

func (*HCLogger) GetLevel

func (l *HCLogger) GetLevel() hclog.Level

func (*HCLogger) ImpliedArgs

func (l *HCLogger) ImpliedArgs() []interface{}

func (*HCLogger) Info

func (l *HCLogger) Info(format string, args ...interface{})

func (*HCLogger) IsDebug

func (l *HCLogger) IsDebug() bool

func (*HCLogger) IsError

func (l *HCLogger) IsError() bool

func (*HCLogger) IsInfo

func (l *HCLogger) IsInfo() bool

func (*HCLogger) IsTrace

func (l *HCLogger) IsTrace() bool

func (*HCLogger) IsWarn

func (l *HCLogger) IsWarn() bool

func (*HCLogger) Log

func (l *HCLogger) Log(level hclog.Level, format string, args ...interface{})

func (*HCLogger) Name

func (l *HCLogger) Name() string

func (*HCLogger) Named

func (l *HCLogger) Named(name string) hclog.Logger

func (*HCLogger) ResetNamed

func (l *HCLogger) ResetNamed(name string) hclog.Logger

func (*HCLogger) SetLevel

func (l *HCLogger) SetLevel(level hclog.Level)

func (*HCLogger) StandardLogger

func (l *HCLogger) StandardLogger(opts *hclog.StandardLoggerOptions) *log.Logger

func (*HCLogger) StandardWriter

func (l *HCLogger) StandardWriter(opts *hclog.StandardLoggerOptions) io.Writer

func (*HCLogger) Trace

func (l *HCLogger) Trace(format string, args ...interface{})

func (*HCLogger) Warn

func (l *HCLogger) Warn(format string, args ...interface{})

func (*HCLogger) With

func (l *HCLogger) With(args ...interface{}) hclog.Logger

type SerfBroadcaster

type SerfBroadcaster struct {
	// contains filtered or unexported fields
}

func NewSerfBroadcaster

func NewSerfBroadcaster(conf *Config) (*SerfBroadcaster, error)

NewSerfBroadcaster constructs a SerfBroadcaster with the given config, storing models in the given DB.

func (*SerfBroadcaster) BroadcastAlertAcknowledgement

func (s *SerfBroadcaster) BroadcastAlertAcknowledgement(ctx context.Context, alertID string, ack model.AlertAcknowledgement) error

func (*SerfBroadcaster) BroadcastAlerts

func (s *SerfBroadcaster) BroadcastAlerts(ctx context.Context, alerts ...model.Alert) error

BroadcastAlerts sends alerts over the Serf gossip channel to the cluster.

func (*SerfBroadcaster) BroadcastSilences

func (s *SerfBroadcaster) BroadcastSilences(ctx context.Context, silences ...model.Silence) error

func (*SerfBroadcaster) Name

func (s *SerfBroadcaster) Name() string

func (*SerfBroadcaster) Run

func (s *SerfBroadcaster) Run(ctx context.Context) error

Run provides a BackgroundService that processes events that come in via the Serf cluster.

func (*SerfBroadcaster) Shutdown

func (s *SerfBroadcaster) Shutdown()