pipes

Nov 12, 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