database

package

v0.1.4 Latest Latest Go to latest Published: Jan 7, 2024 License: MIT Imports: 19 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(NewDatabaseService, NewDeviceLogConsumer)

ProviderSet is service providers.

func Device2Proto(device *model.Device) *database.Device

func NewDatabase(ctx context.Context, dbConf *conf.DatabaseConfig) (*gorm.DB, error)

type DatabaseService struct {
	database.UnimplementedDatabaseServer
	// contains filtered or unexported fields
}

func NewDatabaseService(c *conf.DatabaseConfig) *DatabaseService

func (s *DatabaseService) CreateCollectionInfo(ctx context.Context, req *database.CollectionInfo) (*database.Empty, error)

func (s *DatabaseService) CreateDevice(ctx context.Context, req *database.CreateDeviceReq) (*database.Device, error)

func (s *DatabaseService) FirstOrCreateDevice(ctx context.Context, req *database.CreateDeviceReq) (*database.Device, error)

func (s *DatabaseService) GetDevice(ctx context.Context, req *database.GetDeviceReq) (*database.Device, error)

func (s *DatabaseService) GetDeviceWithMac(ctx context.Context, req *database.GetDeviceWithMacReq) (*database.Device, error)

func (s *DatabaseService) ListCollectionInfo(ctx context.Context, req *database.ListCollectionInfoReq) (*database.ListCollectionInfoResp, error)

type DeviceLog struct {
	Level string `json:"level"`
	Msg   string `json:"msg"`
	Time  string `json:"time"`
}

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

func NewDeviceLogConsumer(dbs *DatabaseService) *DeviceLogConsumer

func (s *DeviceLogConsumer) Cleanup(sarama.ConsumerGroupSession) error

func (s *DeviceLogConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (s *DeviceLogConsumer) DB() *dbUtils

func (s *DeviceLogConsumer) Setup(sarama.ConsumerGroupSession) error

Path	Synopsis
model