logstore

Documentation

Index

• type LogLine
• type LogStore
  • func NewLogStore() *LogStore
  • func (s *LogStore) AddResourceLogs(resourceLogs *util.Concurrent[*ResourceLogs])
  • func (s *LogStore) ResourcesLogs() []*util.Concurrent[*ResourceLogs]
• type ResourceLogs
  • func NewResourceLogs(name, namespace string, groupVersionKind schema.GroupVersionKind) *ResourceLogs
  • func (s *ResourceLogs) AddLogLine(line, source string, timestamp time.Time)
  • func (s *ResourceLogs) GroupVersionKind() schema.GroupVersionKind
  • func (s *ResourceLogs) LogLines() map[string][]*LogLine
  • func (s *ResourceLogs) Name() string
  • func (s *ResourceLogs) Namespace() string

Types

type LogLine

type LogLine struct {
	Time time.Time
	Line string
}

type LogStore

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

func NewLogStore

func NewLogStore() *LogStore

func (*LogStore) AddResourceLogs

func (s *LogStore) AddResourceLogs(resourceLogs *util.Concurrent[*ResourceLogs])

func (*LogStore) ResourcesLogs

func (s *LogStore) ResourcesLogs() []*util.Concurrent[*ResourceLogs]

type ResourceLogs

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

func NewResourceLogs

func NewResourceLogs(name, namespace string, groupVersionKind schema.GroupVersionKind) *ResourceLogs

func (*ResourceLogs) AddLogLine

func (s *ResourceLogs) AddLogLine(line, source string, timestamp time.Time)

func (*ResourceLogs) GroupVersionKind

func (s *ResourceLogs) GroupVersionKind() schema.GroupVersionKind

func (*ResourceLogs) LogLines

func (s *ResourceLogs) LogLines() map[string][]*LogLine

func (*ResourceLogs) Name

func (s *ResourceLogs) Name() string

func (*ResourceLogs) Namespace

func (s *ResourceLogs) Namespace() string