depot

Documentation

Index

• type Cassandra
  • func NewCassandra(s *Settings, readConsistency []gocql.Consistency, ...) (*Cassandra, error)
  • func (cass *Cassandra) Close()
  • func (cass *Cassandra) GetText(ksid, tsid string, start, end int64, search *regexp.Regexp) ([]TextPnt, int, gobol.Error)
  • func (cass *Cassandra) InsertError(id, msg, errMsg string, date time.Time) gobol.Error
  • func (cass *Cassandra) InsertText(ksid, tsid string, timestamp int64, text string) gobol.Error
  • func (cass *Cassandra) Read(ksid, tsid string, blkid int64) ([]byte, gobol.Error)
  • func (cass *Cassandra) SetReadConsistencies(consistencies []gocql.Consistency)
  • func (cass *Cassandra) SetWriteConsistencies(consistencies []gocql.Consistency)
  • func (cass *Cassandra) Write(ksid, tsid string, blkid int64, points []byte) gobol.Error
• type Persistence
• type Settings
• type TextPnt
• type TextPnts
  • func (s TextPnts) Len() int
  • func (s TextPnts) Less(i, j int) bool
  • func (s TextPnts) Swap(i, j int)

Types

type Cassandra

type Cassandra struct {
	Session *gocql.Session
	// contains filtered or unexported fields
}

func NewCassandra

func NewCassandra(
	s *Settings,
	readConsistency []gocql.Consistency,
	writeConsistency []gocql.Consistency,
	wal *wal.WAL,
	log *zap.Logger,
	sts *tsstats.StatsTS,
) (*Cassandra, error)

func (*Cassandra) Close

func (cass *Cassandra) Close()

func (*Cassandra) GetText

func (cass *Cassandra) GetText(ksid, tsid string, start, end int64, search *regexp.Regexp) ([]TextPnt, int, gobol.Error)

func (*Cassandra) InsertError

func (cass *Cassandra) InsertError(id, msg, errMsg string, date time.Time) gobol.Error

func (*Cassandra) InsertText

func (cass *Cassandra) InsertText(ksid, tsid string, timestamp int64, text string) gobol.Error

func (*Cassandra) Read

func (cass *Cassandra) Read(ksid, tsid string, blkid int64) ([]byte, gobol.Error)

func (*Cassandra) SetReadConsistencies

func (cass *Cassandra) SetReadConsistencies(consistencies []gocql.Consistency)

func (*Cassandra) SetWriteConsistencies

func (cass *Cassandra) SetWriteConsistencies(consistencies []gocql.Consistency)

func (*Cassandra) Write

func (cass *Cassandra) Write(ksid, tsid string, blkid int64, points []byte) gobol.Error

type Persistence

type Persistence interface {
	Read(ksid, tsid string, blkid int64) ([]byte, gobol.Error)
	Write(ksid, tsid string, blkid int64, points []byte) gobol.Error
}

Persistence interface abstracts where we save data

type Settings

type Settings struct {
	Cassandra     cassandra.Settings
	MaxConcurrent int
}

type TextPnt

type TextPnt struct {
	Date  int64  `json:"x"`
	Value string `json:"title"`
}

type TextPnts

type TextPnts []TextPnt

func (TextPnts) Len

func (s TextPnts) Len() int

func (TextPnts) Less

func (s TextPnts) Less(i, j int) bool

func (TextPnts) Swap

func (s TextPnts) Swap(i, j int)