Documentation
¶
Index ¶
Constants ¶
View Source
const (
AuthenticationMechanismConnectionString = "connection_string"
AuthenticationMechanismOAuth = "oauth"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Arguments ¶
type Arguments struct {
FullyQualifiedNamespace string `river:"fully_qualified_namespace,attr"`
EventHubs []string `river:"event_hubs,attr"`
Authentication AzureEventHubsAuthentication `river:"authentication,block"`
GroupID string `river:"group_id,attr,optional"`
UseIncomingTimestamp bool `river:"use_incoming_timestamp,attr,optional"`
DisallowCustomMessages bool `river:"disallow_custom_messages,attr,optional"`
RelabelRules flow_relabel.Rules `river:"relabel_rules,attr,optional"`
Labels map[string]string `river:"labels,attr,optional"`
Assignor string `river:"assignor,attr,optional"`
ForwardTo []loki.LogsReceiver `river:"forward_to,attr"`
}
Arguments holds values which are used to configure the loki.source.azure_event_hubs component.
func (*Arguments) Convert ¶
func (a *Arguments) Convert() (kt.Config, error)
Convert is used to bridge between the River and Promtail types.
func (*Arguments) SetToDefault ¶ added in v0.35.0
func (a *Arguments) SetToDefault()
SetToDefault implements river.Defaulter.
type AzureEventHubsAuthentication ¶
type AzureEventHubsAuthentication struct {
Mechanism string `river:"mechanism,attr"`
Scopes []string `river:"scopes,attr,optional"`
ConnectionString string `river:"connection_string,attr,optional"`
}
AzureEventHubsAuthentication describe the configuration for authentication with Azure Event Hub
type Component ¶
type Component struct {
// contains filtered or unexported fields
}
Component implements the loki.source.azure_event_hubs component.
func New ¶
func New(o component.Options, args Arguments) (*Component, error)
New creates a new loki.source.azure_event_hubs component.
Click to show internal directories.
Click to hide internal directories.