collector

package

v0.2.2 Latest Latest Go to latest Published: Feb 22, 2024 License: MIT Imports: 25 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(NewCollectorService)

ProviderSet is service providers.

This section is empty.

type CollectorService struct {

	// TODO: grpc server
	collectorApi.UnimplementedCollectorServer
	// contains filtered or unexported fields
}

func NewCollectorService(c *conf.CollectorConfig, k *conf.KafkaConfig, reg registry.Registrar) *CollectorService

func (c *CollectorService) GetDeviceStreamLog(req *collectorApi.GetDeviceStreamLogReq, resp collectorApi.Collector_GetDeviceStreamLogServer) error

func (c *CollectorService) RegisterDevice(ctx context.Context, d *device.DeviceInfo) (func() error, error)

func (c *CollectorService) ServeTcp(ctx context.Context, conn net.Conn) error

func (c *CollectorService) SetGrpcEndpoint(endpoint string)

func (c *CollectorService) UpdateDeviceLastSeen(ctx context.Context, id uint64, ip string)

type DeviceStreamLog struct {
	Time    time.Time
	Level   uint32
	Message string
}

type DeviceStreamLogChan struct {
	// contains filtered or unexported fields
}

type DeviceStreamLogChans struct {
	// contains filtered or unexported fields
}

func NewDeviceStreamLogChans() *DeviceStreamLogChans

func (c *DeviceStreamLogChans) Close()

func (c *DeviceStreamLogChans) Watch(levelFilter string) (<-chan *DeviceStreamLog, func(), error)

func (c *DeviceStreamLogChans) WriteLog(log *DeviceStreamLog)

type DeviceStreamLogRegistor struct {
	// contains filtered or unexported fields
}

func NewDeviceStreamLogRegistor() *DeviceStreamLogRegistor

func (r *DeviceStreamLogRegistor) Fire(entry *logrus.Entry) error

func (r *DeviceStreamLogRegistor) GetDeviceLogChans(id uint64) (*DeviceStreamLogChans, bool)

func (r *DeviceStreamLogRegistor) Levels() []logrus.Level

func (r *DeviceStreamLogRegistor) RegisterDevice(id uint64) (*DeviceStreamLogChans, error)

func (r *DeviceStreamLogRegistor) UnregisterDevice(id uint64, dlc *DeviceStreamLogChans) bool