log

Documentation

Index

• Variables
• func NewLogConsumer(k *conf.KafkaConfig) sarama.ConsumerGroup
• func NewLogServer(config *conf.GrpcServerConfig, lg *log.LogService) *utils.GrpcGatewayServer
• type DeviceLogServer
  • func NewDeviceLogServer(consumerGroup 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,
	NewLogConsumer,
	NewDeviceLogServer,
)

Functions

func NewLogConsumer

func NewLogConsumer(
	k *conf.KafkaConfig,
) 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(
	consumerGroup 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