memory

Documentation

Index

• type MemoryPlatform
  • func New(entries []*entry.LogEntry) *MemoryPlatform
  • func NewFlow(entries chan *entry.LogEntry) *MemoryPlatform
  • func (p *MemoryPlatform) AddFlags(set *pflag.FlagSet)
  • func (p *MemoryPlatform) GetNotifier(ncfg *notify.Config) (platform.Notifier, error)
  • func (p *MemoryPlatform) GetSource(fileHandler platform.Configer, tailMode bool) (source.Reader, error)
  • func (p *MemoryPlatform) Records() chan *entry.LogEntryResponse

Types

type MemoryPlatform

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

func New

func New(entries []*entry.LogEntry) *MemoryPlatform

New 创建一个内存平台,该平台主要用于测试，不提供init方法，需要手动调用New方法完成初始化并注册

func NewFlow

func NewFlow(entries chan *entry.LogEntry) *MemoryPlatform

New 创建一个内存平台,提供一个chan从外部获得entry，不提供init方法，需要手动调用NewFlow方法完成初始化并注册

func (*MemoryPlatform) AddFlags

func (p *MemoryPlatform) AddFlags(set *pflag.FlagSet)

func (*MemoryPlatform) GetNotifier

func (p *MemoryPlatform) GetNotifier(ncfg *notify.Config) (platform.Notifier, error)

func (*MemoryPlatform) GetSource

func (p *MemoryPlatform) GetSource(fileHandler platform.Configer, tailMode bool) (source.Reader, error)

func (*MemoryPlatform) Records

func (p *MemoryPlatform) Records() chan *entry.LogEntryResponse