collector

Documentation

Index

• Variables
• type CollectorService
  • func NewCollectorService(c *conf.CollectorConfig, k *conf.KafkaConfig, reg registry.Registrar, ...) *CollectorService
  • func (c *CollectorService) BoatControl(ctx context.Context, req *collectorApi.BoatControlReq) (*collectorApi.Empty, error)
  • func (c *CollectorService) ReportNow(ctx context.Context, req *collectorApi.ReportNowReq) (*collectorApi.Empty, error)
  • func (c *CollectorService) UpdateDeviceLastSeen(ctx context.Context, id uint64, t time.Time, ip string) error

Variables

var ProviderSet = wire.NewSet(NewCollectorService)

ProviderSet is service providers.

Types

type CollectorService

type CollectorService struct {
	collectorApi.UnimplementedCollectorServer
	// contains filtered or unexported fields
}

func NewCollectorService

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

func (*CollectorService) BoatControl

func (c *CollectorService) BoatControl(ctx context.Context, req *collectorApi.BoatControlReq) (*collectorApi.Empty, error)

func (*CollectorService) ReportNow

func (c *CollectorService) ReportNow(ctx context.Context, req *collectorApi.ReportNowReq) (*collectorApi.Empty, error)

func (*CollectorService) UpdateDeviceLastSeen

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