logger

Documentation

Index

• Constants
• Variables
• type Config
  • func (c *Config) PrettyString() string
• type DataUnit
  • func (*DataUnit) Descriptor() ([]byte, []int)
  • func (x *DataUnit) GetData() []byte
  • func (x *DataUnit) GetTime() *timestamp.Timestamp
  • func (du *DataUnit) PrettyString() string
  • func (*DataUnit) ProtoMessage()
  • func (x *DataUnit) ProtoReflect() protoreflect.Message
  • func (x *DataUnit) Reset()
  • func (x *DataUnit) String() string
• type Logger
  • func New(c *Config) (l *Logger, err error)
  • func (l *Logger) Close()
  • func (l *Logger) Subscribe(c chan DataUnit)
  • func (l *Logger) Unsubscribe()
• type LoggerBuffer
  • func (*LoggerBuffer) Descriptor() ([]byte, []int)
  • func (x *LoggerBuffer) GetDataUnit() []*DataUnit
  • func (lb *LoggerBuffer) PrettyString() (s string)
  • func (*LoggerBuffer) ProtoMessage()
  • func (x *LoggerBuffer) ProtoReflect() protoreflect.Message
  • func (x *LoggerBuffer) Reset()
  • func (lb *LoggerBuffer) Size() int
  • func (x *LoggerBuffer) String() string

Constants

const (
	// LoggerFlushAfterSecondsModbusRTU flush data from logger, if data older than this [seconds]
	LoggerFlushAfterSecondsModbusRTU = 10

	LoggerFlushAfterSecondsMax = LoggerFlushAfterSecondsModbusRTU
)

Variables

var File_logger_logger_proto protoreflect.FileDescriptor

Types

type Config

type Config struct {
	Port        string
	Baud        int
	FrameFormat string

	FlushAfterSeconds int

	Debug bool
}

func (*Config) PrettyString

func (c *Config) PrettyString() string

type DataUnit

type DataUnit struct {
	Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Data []byte               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*DataUnit) Descriptor

func (*DataUnit) Descriptor() ([]byte, []int)

Deprecated: Use DataUnit.ProtoReflect.Descriptor instead.

func (*DataUnit) GetData

func (x *DataUnit) GetData() []byte

func (*DataUnit) GetTime

func (x *DataUnit) GetTime() *timestamp.Timestamp

func (*DataUnit) PrettyString

func (du *DataUnit) PrettyString() string

func (*DataUnit) ProtoMessage

func (*DataUnit) ProtoMessage()

func (*DataUnit) ProtoReflect

func (x *DataUnit) ProtoReflect() protoreflect.Message

func (*DataUnit) Reset

func (x *DataUnit) Reset()

func (*DataUnit) String

func (x *DataUnit) String() string

type Logger

type Logger struct {
	LoggerBuffer
	// contains filtered or unexported fields
}

func New

func New(c *Config) (l *Logger, err error)

New builds new logger with specified Config

func (*Logger) Close

func (l *Logger) Close()

Close closes

func (*Logger) Subscribe

func (l *Logger) Subscribe(c chan DataUnit)

Subscribe sends each new DataUnit to specified channel

func (*Logger) Unsubscribe

func (l *Logger) Unsubscribe()

Unsubscrbe deletes all subscriptions

type LoggerBuffer

type LoggerBuffer struct {
	DataUnit []*DataUnit `protobuf:"bytes,1,rep,name=dataUnit,proto3" json:"dataUnit,omitempty"`
	// contains filtered or unexported fields
}

Logger

func (*LoggerBuffer) Descriptor

func (*LoggerBuffer) Descriptor() ([]byte, []int)

Deprecated: Use LoggerBuffer.ProtoReflect.Descriptor instead.

func (*LoggerBuffer) GetDataUnit

func (x *LoggerBuffer) GetDataUnit() []*DataUnit

func (*LoggerBuffer) PrettyString

func (lb *LoggerBuffer) PrettyString() (s string)

func (*LoggerBuffer) ProtoMessage

func (*LoggerBuffer) ProtoMessage()

func (*LoggerBuffer) ProtoReflect

func (x *LoggerBuffer) ProtoReflect() protoreflect.Message

func (*LoggerBuffer) Reset

func (x *LoggerBuffer) Reset()

func (*LoggerBuffer) Size

func (lb *LoggerBuffer) Size() int

Size in bytes

func (*LoggerBuffer) String

func (x *LoggerBuffer) String() string