log

Documentation

Index

• Variables
• type DeviceLogConsumer
  • func NewDeviceLogConsumer(dbs *LogService) *DeviceLogConsumer
  • func (s *DeviceLogConsumer) Cleanup(sarama.ConsumerGroupSession) error
  • func (s *DeviceLogConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (s *DeviceLogConsumer) Setup(sarama.ConsumerGroupSession) error
• type LogService
  • func NewLogService(dc *conf.DatabaseServerConfig, lc *conf.LogConfig) *LogService
  • func (ls *LogService) CreateDeviceLog(ctx context.Context, req *logApi.DeviceLog) (*logApi.Empty, error)
  • func (ls *LogService) ListDeviceLog(ctx context.Context, req *logApi.ListDeviceLogReq) (*logApi.ListDeviceLogResp, error)

Variables

var ProviderSet = wire.NewSet(
	NewLogService,
	NewDeviceLogConsumer,
)

ProviderSet is service providers.

Types

type DeviceLogConsumer

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

func NewDeviceLogConsumer

func NewDeviceLogConsumer(dbs *LogService) *DeviceLogConsumer

func (*DeviceLogConsumer) Cleanup

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

func (*DeviceLogConsumer) ConsumeClaim

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

func (*DeviceLogConsumer) Setup

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

type LogService

type LogService struct {
	logApi.UnimplementedLogServer
	// contains filtered or unexported fields
}

func NewLogService

func NewLogService(dc *conf.DatabaseServerConfig, lc *conf.LogConfig) *LogService

func (*LogService) CreateDeviceLog

func (ls *LogService) CreateDeviceLog(ctx context.Context, req *logApi.DeviceLog) (*logApi.Empty, error)

func (*LogService) ListDeviceLog

func (ls *LogService) ListDeviceLog(ctx context.Context, req *logApi.ListDeviceLogReq) (*logApi.ListDeviceLogResp, error)