cache

Documentation

Index

• type CacheStats
• type IndexBucket
  • func (b *IndexBucket) Append(item *IndexItem) *IndexBucket
  • func (b *IndexBucket) Get(columns []string, limit int64) *IndexItem
• type IndexItem
  • func NewIndexItem(columns []string, key string, limit int64) *IndexItem
  • func (i IndexItem) SatisfiesColumns(columns []string) bool
  • func (i IndexItem) SatisfiesLimit(limit int64) bool
• type QueryCache
  • func NewQueryCache() (*QueryCache, error)
  • func (c *QueryCache) BuildIndexKey(connection *steampipeconfig.ConnectionPlugin, table string, ...) string
  • func (c *QueryCache) BuildResultKey(connection *steampipeconfig.ConnectionPlugin, table string, ...) string
  • func (c *QueryCache) Clear()
  • func (c *QueryCache) Get(connection *steampipeconfig.ConnectionPlugin, table string, ...) *QueryResult
  • func (c *QueryCache) Set(connection *steampipeconfig.ConnectionPlugin, table string, ...) bool
• type QueryResult
  • func (q *QueryResult) Append(row map[string]interface{})

Types

type CacheStats

type CacheStats struct {
	// keep count of hits and misses
	Hits   int
	Misses int
}

type IndexBucket

type IndexBucket struct {
	Items []*IndexItem
}

IndexBucket contains index items for all cache results for a given table and qual set

func (*IndexBucket) Append

func (b *IndexBucket) Append(item *IndexItem) *IndexBucket

func (*IndexBucket) Get

func (b *IndexBucket) Get(columns []string, limit int64) *IndexItem

Get finds an index item which satisfies all columns

type IndexItem

type IndexItem struct {
	Columns []string
	Key     string
	Limit   int64
}

IndexItem stores the columns and cached index for a single cached query result note - this index item it tied to a specific table and set of quals

func NewIndexItem

func NewIndexItem(columns []string, key string, limit int64) *IndexItem

func (IndexItem) SatisfiesColumns

func (i IndexItem) SatisfiesColumns(columns []string) bool

func (IndexItem) SatisfiesLimit

func (i IndexItem) SatisfiesLimit(limit int64) bool

type QueryCache

type QueryCache struct {
	Stats *CacheStats
	// contains filtered or unexported fields
}

func NewQueryCache

func NewQueryCache() (*QueryCache, error)

func (*QueryCache) BuildIndexKey

func (c *QueryCache) BuildIndexKey(connection *steampipeconfig.ConnectionPlugin, table string, qualMap map[string]*proto.Quals) string

func (*QueryCache) BuildResultKey

func (c *QueryCache) BuildResultKey(connection *steampipeconfig.ConnectionPlugin, table string, qualMap map[string]*proto.Quals, columns []string) string

func (*QueryCache) Clear

func (c *QueryCache) Clear()

func (*QueryCache) Get

func (c *QueryCache) Get(connection *steampipeconfig.ConnectionPlugin, table string, qualMap map[string]*proto.Quals, columns []string, limit int64) *QueryResult

func (*QueryCache) Set

func (c *QueryCache) Set(connection *steampipeconfig.ConnectionPlugin, table string, qualMap map[string]*proto.Quals, columns []string, limit int64, result *QueryResult, ttl time.Duration) bool

type QueryResult

type QueryResult struct {
	Rows []map[string]interface{}
}

func (*QueryResult) Append

func (q *QueryResult) Append(row map[string]interface{})