util

func GetFirstDate ¶

func GetFirstDate(fname string) (t time.Time, err error)

func GetScanner ¶

func GetScanner(file *os.File) (scanner *bufio.Scanner)

returns an underlying bufio.Scanner if file is bz2 or plan and sets the Split function to SplitMrt from protoparse.

func GetTimestampFromMRT ¶

func GetTimestampFromMRT(data []byte) (t time.Time, err error)

func NBContextClosed ¶

func NBContextClosed(ctx context.Context) bool

Non-blocking context closed function Just a simple function for some repeated code Returns true if the context has been closed, such as with a cancel func