forward

Documentation

Index

• Constants
• type ForwardTarget
  • func NewForwardTarget(logger log.Logger, handler api.EntryHandler, relabel []*relabel.Config, ...) (*ForwardTarget, error)
  • func (t *ForwardTarget) Details() interface{}
  • func (t *ForwardTarget) DiscoveredLabels() model.LabelSet
  • func (t *ForwardTarget) Labels() model.LabelSet
  • func (t *ForwardTarget) Ready() bool
  • func (t *ForwardTarget) Stop() error
  • func (t *ForwardTarget) Type() target.TargetType
• type ForwardTargetManager
  • func NewForwardTargetManager(logger log.Logger, client api.EntryHandler, ...) (*ForwardTargetManager, error)
  • func (tm *ForwardTargetManager) ActiveTargets() map[string][]target.Target
  • func (tm *ForwardTargetManager) AllTargets() map[string][]target.Target
  • func (tm *ForwardTargetManager) Ready() bool
  • func (tm *ForwardTargetManager) Stop()

Constants

const (
	// ForwardTargetType is a Loki forward target
	ForwardTargetType = target.TargetType("forward")
)

Types

type ForwardTarget

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

func NewForwardTarget

func NewForwardTarget(logger log.Logger,
	handler api.EntryHandler,
	relabel []*relabel.Config,
	jobName string,
	config *scrapeconfig.ForwardTargetConfig) (*ForwardTarget, error)

func (*ForwardTarget) Details

func (t *ForwardTarget) Details() interface{}

Details returns target-specific details.

func (*ForwardTarget) DiscoveredLabels

func (t *ForwardTarget) DiscoveredLabels() model.LabelSet

DiscoveredLabels returns the set of labels discovered by the ForwardTarget, which is always nil. Implements Target.

func (*ForwardTarget) Labels

func (t *ForwardTarget) Labels() model.LabelSet

Labels returns the set of labels that statically apply to all log entries produced by the ForwardTarget.

func (*ForwardTarget) Ready

func (t *ForwardTarget) Ready() bool

Ready indicates whether or not the ForwardTarget target is ready to be read from.

func (*ForwardTarget) Stop

func (t *ForwardTarget) Stop() error

Stop shuts down the ForwardTarget.

func (*ForwardTarget) Type

func (t *ForwardTarget) Type() target.TargetType

Type returns ForwardTargetType.

type ForwardTargetManager

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

ForwardTargetManager manages a series of ForwardTargets.

func NewForwardTargetManager

func NewForwardTargetManager(
	logger log.Logger,
	client api.EntryHandler,
	scrapeConfigs []scrapeconfig.Config,
) (*ForwardTargetManager, error)

NewForwardTargetManager creates a new ForwardTargetManager.

func (*ForwardTargetManager) ActiveTargets

func (tm *ForwardTargetManager) ActiveTargets() map[string][]target.Target

ActiveTargets returns the list of ForwardTargets where Forward data is being read. ActiveTargets is an alias to AllTargets as ForwardTargets cannot be deactivated, only stopped.

func (*ForwardTargetManager) AllTargets

func (tm *ForwardTargetManager) AllTargets() map[string][]target.Target

AllTargets returns the list of all targets where forward data is currently being read.

func (*ForwardTargetManager) Ready

func (tm *ForwardTargetManager) Ready() bool

Ready returns true if at least one ForwardTarget is also ready.

func (*ForwardTargetManager) Stop

func (tm *ForwardTargetManager) Stop()

Stop stops the ForwardTargetManager and all of its ForwardTargets.