tailex

Documentation

Index

• Constants
• Variables
• func GlobSearch(globPath string) (string, error)
• func Path2Name(p string) string
• func Time2Path(p string, t time.Time) string
• func Truncate(t time.Time, d time.Duration) time.Time
• type Config
• type TailEx
  • func NewTailEx(ctx context.Context, config Config, w chan bool) *TailEx
  • func (c *TailEx) GlobSearchLoop(ctx context.Context, pathFmt string) (string, error)
  • func (c *TailEx) Stop()
  • func (c *TailEx) Tell() (offset int64, err error)

Constants

const (
	GlobLoopNotify int = iota + tail.TickerNotify + 1
)

Variables

var ErrNoSuchFile = errors.New("No such file.")

Functions

func GlobSearch

func GlobSearch(globPath string) (string, error)

func Path2Name

func Path2Name(p string) string

pathFmtのフォーマット文字列をアンダースコアに置換

func Time2Path

func Time2Path(p string, t time.Time) string

Pathの日付フォーマットに日付を適用 %N は日付ではなくN日前の数値

func Truncate

func Truncate(t time.Time, d time.Duration) time.Time

time.Truncateを 1 day(24*time.Hour)を指定された場合にtimezoneを考慮するように see: http://qiita.com/umisama/items/b50df4888665fc36346e

Types

type Config

type Config struct {
	// logrotate log
	Path string

	// Cronolog
	PathFmt       string        // cronologなどのpathに日付が入る場合
	Time          time.Time     // start日時
	RotatePeriod  time.Duration // ログローテーション間隔
	Delay         time.Duration // 切り替えwait
	LinesChanSize int           // Lines channel size
	//Pos           *core.Position
	NoSeek bool // 有効にするとポジション情報がない時に先頭から読み直す

	tail.Config
}

type TailEx

type TailEx struct {
	Config
	WorkLimit chan bool
	Lines     chan *tail.Line
	// contains filtered or unexported fields
}

func NewTailEx

func NewTailEx(ctx context.Context, config Config, w chan bool) *TailEx

func (*TailEx) GlobSearchLoop

func (c *TailEx) GlobSearchLoop(ctx context.Context, pathFmt string) (string, error)

Glob検索で見つかるまで 1*time.Secondでpolling

func (*TailEx) Stop

func (c *TailEx) Stop()

Stop stops the tailing activity.

func (*TailEx) Tell

func (c *TailEx) Tell() (offset int64, err error)