spotfeed

type Cost struct {
	// Period defines the time period for which this cost is applicable.
	Period
	// ChargeUSD is the total charge over the time period specified by Period.
	ChargeUSD float64
}

type Entry struct {

	// AccountId is a 12-digit account number (ID) that specifies the AWS account
	// billed for this spot instance-hour.
	AccountId string

	// Timestamp is used to determine the price charged for this instance usage.
	// It is not at the hour boundary but within the hour specified by the title of
	// the data feed file that contains this Entry.
	Timestamp time.Time

	// UsageType is the type of usage and instance type being charged for. For
	// m1.small Spot Instances, this field is set to SpotUsage. For all other
	// instance types, this field is set to SpotUsage:{instance-type}. For
	// example, SpotUsage:c1.medium.
	UsageType string

	// Instance is the instance type being charged for and is a member of the
	// set of information provided by UsageType.
	Instance string

	// Operation is the product being charged for. For Linux Spot Instances,
	// this field is set to RunInstances. For Windows Spot Instances, this
	// field is set to RunInstances:0002. Spot usage is grouped according
	// to Availability Zone.
	Operation string

	// InstanceID is the ID of the Spot Instance that generated this instance
	// usage.
	InstanceID string

	// MyBidID is the ID for the Spot Instance request that generated this instance usage.
	MyBidID string

	// MyMaxPriceUSD is the maximum price specified for this Spot Instance request.
	MyMaxPriceUSD float64

	// MarketPriceUSD is the Spot price at the time specified in the Timestamp field.
	MarketPriceUSD float64

	// ChargeUSD is the price charged for this instance usage.
	ChargeUSD float64

	// Version is the version included in the data feed file name for this record.
	Version int64
	// contains filtered or unexported fields
}

type Loader interface {
	// Fetch performs a single blocking call to fetch a discrete set of Entry objects.
	Fetch(ctx context.Context, tolerateErr bool) ([]*Entry, error)

	// Stream asynchronously retrieves, parses and sends Entry objects on the returned channel.
	// To graciously terminate the goroutine managing the Stream, the client terminates the given context.
	Stream(ctx context.Context, tolerateErr bool) (<-chan *Entry, error)
}

type Period struct {
	Start, End time.Time
}

type Querier interface {

	// Query computes the cost charged for the given instanceId for given time period
	// assuming that terminated was the time at which the instance was terminated.
	//
	// It is not required to specify terminated time.  Specifying it only impacts cost
	// calculations for a time period that overlaps the last partial hour of the instance's lifetime.
	//
	// For example, if the instance was running only for say 30m in the last partial hour, and if the
	// desired time period overlaps say the first 15m of that hour, then one must specify
	// terminated time to compute the cost correctly.  In this example, not specifying terminated time
	// would result in a cost higher than actual (ie for the entire last 30 mins instead of only 15 mins).
	//
	// If the given time period spans beyond the instance's actual lifetime, the returned cost will
	// yet only reflect the lifetime cost.  While the returned cost will have the correct start time,
	// the correct end time will be set only if terminated time is provided.
	//
	// Query will return ErrMissingData if it has no data for the given instanceId or
	// if it doesn't have data overlapping the given time period.
	Query(instanceId string, p Period, terminated time.Time) (Cost, error)
}