Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Arguments ¶
type Arguments struct {
Server *fnet.ServerConfig `river:",squash"`
UseIncomingTimestamp bool `river:"use_incoming_timestamp,attr,optional"`
ForwardTo []loki.LogsReceiver `river:"forward_to,attr"`
RelabelRules flow_relabel.Rules `river:"relabel_rules,attr,optional"`
}
func (*Arguments) SetToDefault ¶ added in v0.35.0
func (a *Arguments) SetToDefault()
SetToDefault implements river.Defaulter.
type Component ¶
type Component struct {
// contains filtered or unexported fields
}
Component is the main type for the `loki.source.awsfirehose` component.
func New ¶
func New(o component.Options, args Arguments) (*Component, error)
New creates a new Component.
func (*Component) Run ¶
func (c *Component) Run(ctx context.Context) error
Run starts a routine forwards received message to each destination component.
Click to show internal directories.
Click to hide internal directories.