entry

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 6, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const Delta = time.Hour

Delta between chunks or chunk size.

View Source 
const Layout = "2006-01-02T15"

Layout of chunk key.

Was adjusted to be the prefix of RFC3339.

Variables

This section is empty.

Functions

func Start 

func Start() time.Time

Start time of entries.

Types

type Decode added in v0.2.0 

type Decode struct {
	Reader  io.Reader
	OnEvent func(ctx context.Context, e *Event) error
	OnError func(ctx context.Context, data []byte, err error) error
}

type Event added in v0.2.0 

type Event struct {
	Type    []byte
	Repo    []byte
	RepoURL []byte
	URL     []byte
	Actor   []byte
	Time    time.Time
}

func (*Event) Decode added in v0.2.0 

func (e *Event) Decode(d *jx.Decoder) error

func (Event) Full added in v0.2.0 

func (e Event) Full() bool

func (Event) Interesting added in v0.2.0 

func (e Event) Interesting() bool

func (*Event) Reset added in v0.2.0 

func (e *Event) Reset()

func (Event) String added in v0.2.0 

func (e Event) String() string

type Reader added in v0.2.0 

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

func NewReader added in v0.2.0 

func NewReader(m *speed.Metric) *Reader

func (*Reader) Close added in v0.2.0 

func (r *Reader) Close()

func (*Reader) Decode added in v0.2.0 

func (r *Reader) Decode(ctx context.Context, d Decode) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.