dynamodependencystore

Documentation

Index

• func TimeToBucket(t time.Time) int64
• func WriteDependencyItem(ctx context.Context, svc DynamoDBAPI, dependenciesTable string, ...) error
• type DependencyCallCounts
  • func NewDependencyCallCounts() *DependencyCallCounts
  • func (d *DependencyCallCounts) CountRequest(parent, child string, count uint64)
• type DependencyItem
• type DynamoDBAPI
• type Reader
  • func NewReader(logger hclog.Logger, svc *dynamodb.Client, dependenciesTable string) *Reader
  • func (r *Reader) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)

Functions

func TimeToBucket

func TimeToBucket(t time.Time) int64

func WriteDependencyItem

func WriteDependencyItem(ctx context.Context, svc DynamoDBAPI, dependenciesTable string, item *DependencyItem) error

Types

type DependencyCallCounts

type DependencyCallCounts struct {
	CallCounts map[string]map[string]uint64
}

func NewDependencyCallCounts

func NewDependencyCallCounts() *DependencyCallCounts

func (*DependencyCallCounts) CountRequest

func (d *DependencyCallCounts) CountRequest(parent, child string, count uint64)

type DependencyItem

type DependencyItem struct {
	Key            string
	Parent         string
	Child          string
	CallCount      uint64
	Source         string
	CallTimeBucket int64
}

type DynamoDBAPI

type DynamoDBAPI interface {
	UpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateItemOutput, error)
}

type Reader

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

func NewReader

func NewReader(logger hclog.Logger, svc *dynamodb.Client, dependenciesTable string) *Reader

func (*Reader) GetDependencies

func (r *Reader) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)