logs

package

v0.0.0-...-73e0568 Latest Latest Go to latest Published: Oct 16, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/project-flotta/flotta-device-worker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewSyslogServer(server string, protocol string, deviceID string) (*syslogTransport, error)
type FIFOLog
- func NewFIFOLog(maxSize int) *FIFOLog
type LogEntry
- func NewLogEntry(data []byte, workload string) *LogEntry
type WorkloadWriter
- func NewWorkloadWriter(workload string, manager *workload.WorkloadManager) *WorkloadWriter
type WorkloadsLogsTarget
- func NewWorkloadsLogsTarget(manager *workload.WorkloadManager) *WorkloadsLogsTarget

Constants ¶

View Source

const (
	SyslogTransport = "syslog"
)

Variables ¶

This section is empty.

Functions ¶

func NewSyslogServer ¶

func NewSyslogServer(server string, protocol string, deviceID string) (*syslogTransport, error)

Types ¶

type FIFOLog ¶

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

func NewFIFOLog ¶

func NewFIFOLog(maxSize int) *FIFOLog

NewFIFOLog returns a new FifoLog struct

func (*FIFOLog) CurrentSize ¶

func (f *FIFOLog) CurrentSize() int

CurrentSize returns the buffer size.

func (*FIFOLog) ReadLine ¶

func (f *FIFOLog) ReadLine() (*LogEntry, error)

ReadLine reads the line and delete it from the current buffer.

func (*FIFOLog) Write ¶

func (f *FIFOLog) Write(entry *LogEntry) error

Write fills the current buffer with the next LogEntry

type LogEntry ¶

type LogEntry struct {
	Time time.Time
	// contains filtered or unexported fields
}

func NewLogEntry ¶

func NewLogEntry(data []byte, workload string) *LogEntry

func (*LogEntry) GetWorkload ¶

func (l *LogEntry) GetWorkload() string

func (*LogEntry) Size ¶

func (l *LogEntry) Size() int

func (*LogEntry) String ¶

func (l *LogEntry) String() string

type WorkloadWriter ¶

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

func NewWorkloadWriter ¶

func NewWorkloadWriter(workload string, manager *workload.WorkloadManager) *WorkloadWriter

func (*WorkloadWriter) SetTarget ¶

func (ww *WorkloadWriter) SetTarget(name string, target *FIFOLog)

func (*WorkloadWriter) Start ¶

func (ww *WorkloadWriter) Start() error

Start writer.

func (*WorkloadWriter) Stop ¶

func (ww *WorkloadWriter) Stop()

Stop writer.

func (*WorkloadWriter) Write ¶

func (ww *WorkloadWriter) Write(data []byte) (n int, err error)

type WorkloadsLogsTarget ¶

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

func NewWorkloadsLogsTarget ¶

func NewWorkloadsLogsTarget(manager *workload.WorkloadManager) *WorkloadsLogsTarget

func (*WorkloadsLogsTarget) GetCurrentTransports ¶

func (w *WorkloadsLogsTarget) GetCurrentTransports() []string

func (*WorkloadsLogsTarget) GetCurrentWorkloads ¶

func (w *WorkloadsLogsTarget) GetCurrentWorkloads() []*WorkloadWriter

func (*WorkloadsLogsTarget) Init ¶

func (w *WorkloadsLogsTarget) Init(config models.DeviceConfigurationMessage) error

func (*WorkloadsLogsTarget) Update ¶

func (w *WorkloadsLogsTarget) Update(config models.DeviceConfigurationMessage) error

func (*WorkloadsLogsTarget) WorkloadRemoved ¶

func (w *WorkloadsLogsTarget) WorkloadRemoved(workloadName string)

func (*WorkloadsLogsTarget) WorkloadStarted ¶

func (w *WorkloadsLogsTarget) WorkloadStarted(workloadName string, report []*podman.PodReport)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL