collector

type CollectorServiceClient interface {
	CreateEventLog(ctx context.Context, in *EventLog, opts ...grpc.CallOption) (*empty.Empty, error)
	// NOTICE: not implemented
	CreateDetectorLink(ctx context.Context, in *DetectorLink, opts ...grpc.CallOption) (*empty.Empty, error)
	StreamEventLog(ctx context.Context, opts ...grpc.CallOption) (CollectorService_StreamEventLogClient, error)
	CreateCoordinates(ctx context.Context, in *Coordinates, opts ...grpc.CallOption) (*empty.Empty, error)
	CreateDetectorStatus(ctx context.Context, in *DetectorStatus, opts ...grpc.CallOption) (*empty.Empty, error)
}

type CollectorServiceServer interface {
	CreateEventLog(context.Context, *EventLog) (*empty.Empty, error)
	// NOTICE: not implemented
	CreateDetectorLink(context.Context, *DetectorLink) (*empty.Empty, error)
	StreamEventLog(CollectorService_StreamEventLogServer) error
	CreateCoordinates(context.Context, *Coordinates) (*empty.Empty, error)
	CreateDetectorStatus(context.Context, *DetectorStatus) (*empty.Empty, error)
}

type CollectorService_StreamEventLogClient interface {
	Send(*EventLog) error
	CloseAndRecv() (*SendStreamResponse, error)
	grpc.ClientStream
}

type CollectorService_StreamEventLogServer interface {
	SendAndClose(*SendStreamResponse) error
	Recv() (*EventLog, error)
	grpc.ServerStream
}

type Coordinates struct {
	DetectorId string `protobuf:"bytes,1,opt,name=detector_id,json=detectorId,proto3" json:"detector_id,omitempty"`
	// Since decimal is not supported. We use int64 scaled values with fixed 5 decimal places.
	// This means that 1 is equivalent to 0.00001 decimal degrees so ground precision is around 1.1132 m
	Latitude             int64    `protobuf:"varint,2,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude            int64    `protobuf:"varint,3,opt,name=longitude,proto3" json:"longitude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type DEVICE int32

type DetectionEvent struct {
	Time []*timestamp.Timestamp `protobuf:"bytes,1,rep,name=time,proto3" json:"time,omitempty"`
	// Types that are valid to be assigned to DeviceId:
	//	*DetectionEvent_Wifi
	//	*DetectionEvent_Bluetooth
	//	*DetectionEvent_Mobile
	DeviceId             isDetectionEvent_DeviceId `protobuf_oneof:"device_id"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

type DetectionEvent_Bluetooth struct {
	Bluetooth string `protobuf:"bytes,3,opt,name=bluetooth,proto3,oneof"`
}

type DetectionEvent_Mobile struct {
	Mobile string `protobuf:"bytes,4,opt,name=mobile,proto3,oneof"`
}

type DetectionEvent_Wifi struct {
	Wifi string `protobuf:"bytes,2,opt,name=wifi,proto3,oneof"`
}

type DetectorLink struct {
	DestDetectorId       string                         `protobuf:"bytes,1,opt,name=dest_detector_id,json=destDetectorId,proto3" json:"dest_detector_id,omitempty"`
	SrcDetectors         []*DetectorLink_SourceDetector `protobuf:"bytes,2,rep,name=src_detectors,json=srcDetectors,proto3" json:"src_detectors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

type DetectorLink_SourceDetector struct {
	DetectorId string `protobuf:"bytes,1,opt,name=detector_id,json=detectorId,proto3" json:"detector_id,omitempty"`
	// Maximum travel time from source detector to destination detector that is considered possible.
	MaxSeconds           int64    `protobuf:"varint,2,opt,name=max_seconds,json=maxSeconds,proto3" json:"max_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type DetectorStatus struct {
	Loc                  *Coordinates    `protobuf:"bytes,1,opt,name=loc,proto3" json:"loc,omitempty"`
	ActiveDetectors      []DEVICE        `` /* 136-byte string literal not displayed */
	BatteryVoltage       float64         `protobuf:"fixed64,3,opt,name=battery_voltage,json=batteryVoltage,proto3" json:"battery_voltage,omitempty"`
	DetectionCount       map[int32]int64 `` /* 193-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

type EventLog struct {
	Loc                  *Coordinates      `protobuf:"bytes,1,opt,name=loc,proto3" json:"loc,omitempty"`
	Events               []*DetectionEvent `protobuf:"bytes,20,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type Repository interface {
	CreateDetectionEvent(ctx context.Context, detectorID string, deviceID string, timestamp time.Time) error
	CreateDetectorLink(ctx context.Context, destDetectorID, srcDetectorID string, maxSeconds int64) error

	// NOTICE: not implemented
	CreateActiveDetectors(ctx context.Context, detectorID string, activeDetectors string, timestamp time.Time) error
	CreateBatteryVoltage(ctx context.Context, detectorID string, voltage float64, timestamp time.Time) error
	CreateDetectionCount(ctx context.Context, detectorID string, detectorType string, count int64, timestamp time.Time) error
	CreateCoordinates(ctx context.Context, detectorID string, latitude, longitude types.DecimalDegrees) error
}

type SendStreamResponse struct {
	Mobile               int64    `protobuf:"varint,2,opt,name=mobile,proto3" json:"mobile,omitempty"`
	Bluetooth            int64    `protobuf:"varint,3,opt,name=bluetooth,proto3" json:"bluetooth,omitempty"`
	Wifi                 int64    `protobuf:"varint,4,opt,name=wifi,proto3" json:"wifi,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type UnimplementedCollectorServiceServer struct {
}