log

Documentation

Index

• Variables
• func NewConsumerGroup(cli sarama.Client) sarama.ConsumerGroup
• func NewLogServer(config *conf.GrpcServerConfig, lg *log.LogService) *utils.GrpcGatewayServer
• type DeviceLogServer
  • func NewDeviceLogServer(group sarama.ConsumerGroup, c *log.DeviceLogConsumer) *DeviceLogServer
  • func (l *DeviceLogServer) Start(ctx context.Context) error
  • func (l *DeviceLogServer) Stop(ctx context.Context) error

Variables

var ProviderSet = wire.NewSet(
	NewLogServer,
	utils.ForceNewKafkaClient,
	NewConsumerGroup,
	NewDeviceLogServer,
)

Functions

func NewConsumerGroup

func NewConsumerGroup(
	cli sarama.Client,
) sarama.ConsumerGroup

func NewLogServer

func NewLogServer(
	config *conf.GrpcServerConfig,
	lg *log.LogService,
) *utils.GrpcGatewayServer

Types

type DeviceLogServer

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

func NewDeviceLogServer

func NewDeviceLogServer(
	group sarama.ConsumerGroup,
	c *log.DeviceLogConsumer,
) *DeviceLogServer

func (*DeviceLogServer) Start

func (l *DeviceLogServer) Start(ctx context.Context) error

func (*DeviceLogServer) Stop

func (l *DeviceLogServer) Stop(ctx context.Context) error