utils

Documentation

Index

• Constants
• func LoadEMLFilesFromDirectory(path string) ([]string, error)
• func LoadFilesFromDirectory(path string, filter func(string, fs.FileInfo) bool) ([]string, error)
• func ReadLinesFromFile(path string) ([]string, error)
• func RegisterConnector(name string, builder ConnectorBuilder) error
• type ConnectorBuilder
• type ConnectorImpl
  • func NewConnector(name string) (ConnectorImpl, error)
• type DummyConnectorBuilder
  • func (*DummyConnectorBuilder) New() (ConnectorImpl, error)
• type DummyConnectorImpl
  • func (d *DummyConnectorImpl) Connector() connector.Connector
  • func (d *DummyConnectorImpl) Sync(ctx context.Context) error
• type DurationCmdProfiler
  • func NewDurationCmdProfiler() *DurationCmdProfiler
  • func (c *DurationCmdProfiler) Start(cmdType int)
  • func (c *DurationCmdProfiler) Stop(cmdType int)
• type DurationCmdProfilerBuilder
  • func NewDurationCmdProfilerBuilder() *DurationCmdProfilerBuilder
  • func (c *DurationCmdProfilerBuilder) Clear()
  • func (c *DurationCmdProfilerBuilder) Collect(profiler profiling.CmdProfiler)
  • func (c *DurationCmdProfilerBuilder) Merge() [profiling.CmdTypeTotal][]time.Duration
  • func (c *DurationCmdProfilerBuilder) New() profiling.CmdProfiler

Constants

const MessageAfterNoonMeeting = `` /* 339-byte string literal not displayed */

const MessageEmbedded = `` /* 999-byte string literal not displayed */

const MessageMultiPartMixed = `` /* 1677-byte string literal not displayed */

Functions

func LoadEMLFilesFromDirectory

func LoadEMLFilesFromDirectory(path string) ([]string, error)

func LoadFilesFromDirectory

func LoadFilesFromDirectory(path string, filter func(string, fs.FileInfo) bool) ([]string, error)

func ReadLinesFromFile

func ReadLinesFromFile(path string) ([]string, error)

func RegisterConnector

func RegisterConnector(name string, builder ConnectorBuilder) error

Types

type ConnectorBuilder

type ConnectorBuilder interface {
	New() (ConnectorImpl, error)
}

type ConnectorImpl

type ConnectorImpl interface {
	Connector() connector.Connector
	Sync(ctx context.Context) error
}

func NewConnector

func NewConnector(name string) (ConnectorImpl, error)

type DummyConnectorBuilder

type DummyConnectorBuilder struct{}

func (*DummyConnectorBuilder) New

func (*DummyConnectorBuilder) New() (ConnectorImpl, error)

type DummyConnectorImpl

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

func (*DummyConnectorImpl) Connector

func (d *DummyConnectorImpl) Connector() connector.Connector

func (*DummyConnectorImpl) Sync

func (d *DummyConnectorImpl) Sync(ctx context.Context) error

type DurationCmdProfiler

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

DurationCmdProfiler records the duration of the duration between invocations of IMAP Commands.

func NewDurationCmdProfiler

func NewDurationCmdProfiler() *DurationCmdProfiler

func (*DurationCmdProfiler) Start

func (c *DurationCmdProfiler) Start(cmdType int)

func (*DurationCmdProfiler) Stop

func (c *DurationCmdProfiler) Stop(cmdType int)

type DurationCmdProfilerBuilder

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

func NewDurationCmdProfilerBuilder

func NewDurationCmdProfilerBuilder() *DurationCmdProfilerBuilder

func (*DurationCmdProfilerBuilder) Clear

func (c *DurationCmdProfilerBuilder) Clear()

func (*DurationCmdProfilerBuilder) Collect

func (c *DurationCmdProfilerBuilder) Collect(profiler profiling.CmdProfiler)

func (*DurationCmdProfilerBuilder) Merge

func (c *DurationCmdProfilerBuilder) Merge() [profiling.CmdTypeTotal][]time.Duration

Merge merges all collected command profilers into a single timing Calculator for each IMAP command.

func (*DurationCmdProfilerBuilder) New

func (c *DurationCmdProfilerBuilder) New() profiling.CmdProfiler