Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewCollectorService)
ProviderSet is service providers.
Functions ¶
This section is empty.
Types ¶
type CollectorService ¶
type CollectorService struct {
// TODO: grpc server
collectorApi.UnimplementedCollectorServer
// contains filtered or unexported fields
}
func NewCollectorService ¶
func NewCollectorService(c *conf.CollectorConfig, k *conf.KafkaConfig, reg registry.Registrar) *CollectorService
func (*CollectorService) SetGrpcEndpoint ¶
func (c *CollectorService) SetGrpcEndpoint(endpoint string)
Source Files
Click to show internal directories.
Click to hide internal directories.