Documentation
¶
Overview ¶
Package cloudfoundryreceiver implements a receiver that can be used by the Opentelemetry collector to receive Cloud Foundry metrics via its Reverse Log Proxy (RLP) Gateway component. The protocol is handled by the go-loggregator library, which uses HTTP to connect to the gateway and receive JSON-protobuf encoded v2 Envelope messages as documented by loggregator-api.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFactory ¶
NewFactory creates a factory for collectd receiver.
Types ¶
type Config ¶
type Config struct { RLPGateway RLPGatewayConfig `mapstructure:"rlp_gateway"` UAA UAAConfig `mapstructure:"uaa"` }
Config defines configuration for Collectd receiver.
type EnvelopeStreamFactory ¶ added in v0.40.0
type EnvelopeStreamFactory struct {
// contains filtered or unexported fields
}
func (*EnvelopeStreamFactory) CreateStream ¶ added in v0.40.0
func (rgc *EnvelopeStreamFactory) CreateStream( ctx context.Context, shardID string) (loggregator.EnvelopeStream, error)
type LimitedClientConfig ¶ added in v0.94.0
type LimitedClientConfig struct { Endpoint string `mapstructure:"endpoint"` TLSSetting LimitedTLSClientSetting `mapstructure:"tls"` }
LimitedClientConfig is a subset of ClientConfig, implemented as a separate type due to the library this configuration is used with not taking a preconfigured http.Client as input, but only taking these specific options
type LimitedTLSClientSetting ¶ added in v0.40.0
type LimitedTLSClientSetting struct {
InsecureSkipVerify bool `mapstructure:"insecure_skip_verify"`
}
LimitedTLSClientSetting is a subset of TLSClientSetting, see LimitedClientConfig for more details
type RLPGatewayConfig ¶ added in v0.40.0
type RLPGatewayConfig struct { confighttp.ClientConfig `mapstructure:",squash"` ShardID string `mapstructure:"shard_id"` }
type UAAConfig ¶ added in v0.40.0
type UAAConfig struct { LimitedClientConfig `mapstructure:",squash"` Username string `mapstructure:"username"` Password configopaque.String `mapstructure:"password"` }
type UAATokenProvider ¶ added in v0.40.0
type UAATokenProvider struct {
// contains filtered or unexported fields
}
func (*UAATokenProvider) ProvideToken ¶ added in v0.40.0
func (utp *UAATokenProvider) ProvideToken() (string, error)