connectionlog

Documentation

Index

• type DeviceLog
• type HubLog
• type Logger
  • func New(ctx context.Context, kafkaBootstrapUrl string, sync bool, idempotent bool, ...) (logger Logger, err error)
  • func NewWithKafkaConfig(ctx context.Context, kafkaBootstrapUrl string, deviceLogTopic string, ...) (logger Logger, err error)
  • func NewWithProducer(producer kafka.ProducerInterface, deviceLogTopic string, hubLogTopic string) (logger Logger, err error)
• type LoggerImpl
  • func (this *LoggerImpl) LogDeviceConnect(id string) error
  • func (this *LoggerImpl) LogDeviceDisconnect(id string) error
  • func (this *LoggerImpl) LogHubConnect(id string) error
  • func (this *LoggerImpl) LogHubDisconnect(id string) error

Types

type DeviceLog

type DeviceLog struct {
	Id        string    `json:"id"`
	Connected bool      `json:"connected"`
	Time      time.Time `json:"time"`
}

type HubLog

type HubLog struct {
	Id        string    `json:"id"`
	Connected bool      `json:"connected"`
	Time      time.Time `json:"time"`
}

type Logger

type Logger interface {
	LogDeviceDisconnect(id string) error
	LogDeviceConnect(id string) error
	LogHubConnect(gateway string) error
	LogHubDisconnect(gateway string) error
}

func New

func New(ctx context.Context, kafkaBootstrapUrl string, sync bool, idempotent bool, deviceLogTopic string, hubLogTopic string, partitionNum int, replicationFactor int) (logger Logger, err error)

deprecated

func NewWithKafkaConfig

func NewWithKafkaConfig(ctx context.Context, kafkaBootstrapUrl string, deviceLogTopic string, hubLogTopic string, config kafka.Config) (logger Logger, err error)

func NewWithProducer

func NewWithProducer(producer kafka.ProducerInterface, deviceLogTopic string, hubLogTopic string) (logger Logger, err error)

type LoggerImpl

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

func (*LoggerImpl) LogDeviceConnect

func (this *LoggerImpl) LogDeviceConnect(id string) error

func (*LoggerImpl) LogDeviceDisconnect

func (this *LoggerImpl) LogDeviceDisconnect(id string) error

func (*LoggerImpl) LogHubConnect

func (this *LoggerImpl) LogHubConnect(id string) error

func (*LoggerImpl) LogHubDisconnect

func (this *LoggerImpl) LogHubDisconnect(id string) error