Documentation
¶
Index ¶
Constants ¶
View Source
const (
OtelMetricsTopic = "otlp.*.m.>"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service interface {
// Start set up communication with the message bus to communicate with agents
Start() error
// Stop end communication with the message bus
Stop() error
}
func New ¶
func New(logger *zap.Logger, pubSub mfnats.PubSub, streamsClient *redis.Client, cacheClient *redis.Client, policiesClient policiespb.PolicyServiceClient, fleetClient fleetpb.FleetServiceClient, sinksClient sinkspb.SinkServiceClient, otelKafkaUrl string, enableOtel bool, requestGauge metrics.Gauge, requestCounter metrics.Counter, inputCounter metrics.Counter, defaultCacheExpiration time.Duration, ) Service
New instantiates the sinker service implementation.
type SinkerService ¶
type SinkerService struct {
// contains filtered or unexported fields
}
func (SinkerService) Start ¶
func (svc SinkerService) Start() error
func (SinkerService) Stop ¶
func (svc SinkerService) Stop() error
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
kafkafanoutexporter
Package kafkaexporter exports trace data to Kafka.
|
Package kafkaexporter exports trace data to Kafka. |
|
kafkafanoutexporter/internal/awsmsk
Package msk implements the required IAM auth used by AWS' managed Kafka platform to be used with the Surama kafka producer.
|
Package msk implements the required IAM auth used by AWS' managed Kafka platform to be used with the Surama kafka producer. |
|
redis
|
|
Click to show internal directories.
Click to hide internal directories.