state

type CachedSyncer struct {
	SyncFinder    SyncFinder
	SyncCache     SyncCache
	Log           *zapctx.Logger
	CacheDuration time.Duration
}

type DynamoDBStorage struct {
	TableName       string
	Log             *zapctx.Logger
	Client          *dynamodb.DynamoDB
	SyncCachePrefix string
}

type HardCodedSyncFinder struct {
	TargetGroupARN TargetGroupARN
	Hostname       string
}

type Keys struct {
	TargetGroupARN TargetGroupARN
	Hostname       string
}

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

type State struct {
	Targets []Target
	Version int
}

type Storage interface {
	// GetStates returns a state result for each state key
	GetStates(ctx context.Context, syncPairs []Keys) (map[Keys]State, error)
	// Store results for all the state keys
	Store(ctx context.Context, toStore map[Keys]State) error
}

type SyncCache interface {
	StoreSync(ctx context.Context, toStore map[TargetGroupARN]string, expireAt time.Time) error
	GetSync(ctx context.Context, currentTime time.Time) (map[TargetGroupARN]string, error)
}

type SyncFinder interface {
	// Get the list of target groups -> hostname we should sync
	ToSync(ctx context.Context) (map[TargetGroupARN]string, error)
}

type TagSyncFinder struct {
	Client *resourcegroupstaggingapi.ResourceGroupsTaggingAPI
	TagKey string
	Log    *zapctx.Logger
}

type Target struct {
	IP           string
	TimesMissing int
}

type TargetGroupARN string