Versions in this module Expand all Collapse all v0 v0.0.1 Oct 18, 2022 Changes in this version + var ErrInvalidOperationGivenPartLoopState = errors.New("invalid operation given state of loop") + func CreateErrUnmarshalLogLine(marshalized []byte, originalErr error) error + func NewChildPart(profileReader *os.File, logsWriter *os.File, ...) (*childPart, error) + func NewParentPart(childName string, logLineMarshalizer logger.Marshalizer) (*parentPart, error) + type ChildMessenger struct + func NewChildMessenger(profileReader *os.File, logsWriter *os.File) *ChildMessenger + func (messenger *ChildMessenger) ReadProfile() (logger.Profile, error) + func (messenger *ChildMessenger) SendLogLine(logLineMarshalized []byte) (int, error) + type Messenger struct + func NewMessenger(reader *os.File, writer *os.File) *Messenger + func (messenger *Messenger) ReadMessage() ([]byte, error) + func (messenger *Messenger) SendMessage(message []byte) (int, error) + type ParentMessenger struct + func NewParentMessenger(logsReader *os.File, profileWriter *os.File, ...) *ParentMessenger + func (messenger *ParentMessenger) ReadLogLine() (*logger.LogLine, error) + func (messenger *ParentMessenger) SendProfile(profile logger.Profile) error + type PartLoopStateType = uint32 + const PartLoopInit + const PartLoopRunning + const PartLoopStopped
Go to main page