Versions in this module Expand all Collapse all v0 v0.0.2 Jun 9, 2023 v0.0.1 Jun 6, 2023 Changes in this version + func DeepCopy(value map[string]interface{}) map[string]interface + type DataLog interface + Close func() error + Flush func() error + Write func(ctx context.Context, event *Event, attributes ...attribute.KeyValue) error + func Dial(appId string, options ...Option) (DataLog, error) + type DistinctType int8 + const Guest + const User + func (d DistinctType) IsGuest() bool + func (d DistinctType) IsUser() bool + type Event struct + DistinctId string + DistinctType DistinctType + Name string + Time time.Time + type Exporter interface + Close func() error + Flush func() error + Write func(ctx context.Context, event *Event, metadata Metadata) error + type Filter struct + func NewFilter(exporter Exporter, opts ...FilterOption) *Filter + func (f *Filter) Close() error + func (f *Filter) Flush() error + func (f *Filter) Write(ctx context.Context, event *Event, metadata Metadata) error + type FilterOption func(*Filter) + func FilterFunc(f func(ctx context.Context, event *Event, metadata Metadata) bool) FilterOption + func FilterKey(key ...string) FilterOption + func FilterValue(value ...string) FilterOption + type Kafka struct + func NewKafka(opts *config) (*Kafka, error) + func (w *Kafka) Close() error + func (w *Kafka) Flush() error + func (w *Kafka) Write(ctx context.Context, event *Event, metadata Metadata) error + type Logger struct + func NewLogger(opts *config) (*Logger, error) + func (l *Logger) Close() error + func (l *Logger) Flush() error + func (l *Logger) Write(ctx context.Context, event *Event, metadata Metadata) error + type Metadata map[string]interface + type Option interface + func WithAppId(appId string) Option + func WithBasePath(path string) Option + func WithBatch(batch bool) Option + func WithBatchBulkSizeMax(size int) Option + func WithBrokers(brokers []string) Option + func WithDebug(debug bool) Option + func WithEncoderConfig(encoderConfig zapcore.EncoderConfig) Option + func WithLogDisable(disable bool) Option + func WithMetadata(md map[string]string) Option + func WithProjectName(projectName string) Option + func WithServiceName(serviceName string) Option + func WithTimeout(timeout int) Option + func WithToken(token string) Option + type OptionFunc func(*config) + type SensorsData struct + func NewSensorsData(opts *config) *SensorsData + func (s *SensorsData) Close() error + func (s *SensorsData) Flush() error + func (s *SensorsData) Write(ctx context.Context, event *Event, metadata Metadata) error