db

Documentation

Index

• type DB
  • func Open(path string) (*DB, error)
  • func (db *DB) AddRecord(record *Record) error
  • func (db *DB) Close() error
  • func (db *DB) History(day time.Time) ([]*Record, error)
• type Record
  • func (*Record) Descriptor() ([]byte, []int)
  • func (m *Record) GetMessage() string
  • func (m *Record) GetTime() *time.Time
  • func (m *Record) GetTimestamp() *timestamp.Timestamp
  • func (*Record) ProtoMessage()
  • func (m *Record) Reset()
  • func (m *Record) String() string
  • func (m *Record) XXX_DiscardUnknown()
  • func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *Record) XXX_Merge(src proto.Message)
  • func (m *Record) XXX_Size() int
  • func (m *Record) XXX_Unmarshal(b []byte) error

Types

type DB

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

DB wraps a Bolt database.

func Open

func Open(path string) (*DB, error)

Open the database at the given path.

func (*DB) AddRecord

func (db *DB) AddRecord(record *Record) error

AddRecord adds a record to the database.

func (*DB) Close

func (db *DB) Close() error

Close the database.

func (*DB) History

func (db *DB) History(day time.Time) ([]*Record, error)

History returns the history for the given day.

type Record

type Record struct {
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Message              string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Record) Descriptor

func (*Record) Descriptor() ([]byte, []int)

func (*Record) GetMessage

func (m *Record) GetMessage() string

func (*Record) GetTime

func (m *Record) GetTime() *time.Time

GetTime returns the timestamp as a Go *time.Time.

func (*Record) GetTimestamp

func (m *Record) GetTimestamp() *timestamp.Timestamp

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) Reset

func (m *Record) Reset()

func (*Record) String

func (m *Record) String() string

func (*Record) XXX_DiscardUnknown

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal

func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Record) XXX_Merge

func (dst *Record) XXX_Merge(src proto.Message)

func (*Record) XXX_Size

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal

func (m *Record) XXX_Unmarshal(b []byte) error