insightstore

Documentation

Index

• func NewStore(fs fileStore, chunkMaxCount int, rd redis.Redis, logger *zap.Logger) insight.Store
• type DeploymentBlockMetadata
  • func (m *DeploymentBlockMetadata) FindChunks(from, to int64) []DeploymentChunkMetadata
• type DeploymentChunk
  • func (c *DeploymentChunk) FindDeployments(from, to int64) []*insight.DeploymentData
  • func (c *DeploymentChunk) Size() (int64, error)
• type DeploymentChunkMetadata

Functions

func NewStore

func NewStore(fs fileStore, chunkMaxCount int, rd redis.Redis, logger *zap.Logger) insight.Store

Types

type DeploymentBlockMetadata

type DeploymentBlockMetadata struct {
	BlockID       string                     `json:"block_id"`
	ChunkMetadata []*DeploymentChunkMetadata `json:"chunk_metadata"`
}

func (*DeploymentBlockMetadata) FindChunks

func (m *DeploymentBlockMetadata) FindChunks(from, to int64) []DeploymentChunkMetadata

type DeploymentChunk

type DeploymentChunk struct {
	ChunkID     string                    `json:"chunk_id"`
	Deployments []*insight.DeploymentData `json:"deployments"`
}

func (*DeploymentChunk) FindDeployments

func (c *DeploymentChunk) FindDeployments(from, to int64) []*insight.DeploymentData

func (*DeploymentChunk) Size

func (c *DeploymentChunk) Size() (int64, error)

type DeploymentChunkMetadata

type DeploymentChunkMetadata struct {
	ChunkID      string `json:"chunk_id"`
	ChunkIndex   int    `json:"chunk_index"`
	MinTimestamp int64  `json:"min_timestamp"`
	MaxTimestamp int64  `json:"max_timestamp"`
	Count        int    `json:"count"`
	Completed    bool   `json:"completed"`
}