transactionbatcher

type BatchTransaction struct {
	TransactionID        string
	CompletedTransaction bool
}

type MockTransactionalBatcher struct {
	CollectedTopology TransactionBatchBuilder
	// contains filtered or unexported fields
}

type StartTransaction struct {
	CheckID       check.CheckID
	TransactionID string
}

type SubmitClearState struct {
	CheckID check.CheckID
}

type SubmitCompleteTransaction struct {
	CheckID       check.CheckID
	TransactionID string
}

type SubmitComponent struct {
	CheckID       check.CheckID
	TransactionID string
	Instance      topology.Instance
	Component     topology.Component
}

type SubmitDelete struct {
	CheckID       check.CheckID
	TransactionID string
	Instance      topology.Instance
	DeleteID      string
}

type SubmitEvent struct {
	CheckID       check.CheckID
	TransactionID string
	Event         telemetry.Event
}

type SubmitHealthCheckData struct {
	CheckID       check.CheckID
	TransactionID string
	Stream        health.Stream
	Data          health.CheckData
}

type SubmitHealthStartSnapshot struct {
	CheckID         check.CheckID
	TransactionID   string
	Stream          health.Stream
	IntervalSeconds int
	ExpirySeconds   int
}

type SubmitHealthStopSnapshot struct {
	CheckID       check.CheckID
	TransactionID string
	Stream        health.Stream
}

type SubmitRawMetricsData struct {
	CheckID       check.CheckID
	TransactionID string
	RawMetric     telemetry.RawMetric
}

type SubmitRelation struct {
	CheckID       check.CheckID
	TransactionID string
	Instance      topology.Instance
	Relation      topology.Relation
}

type SubmitShutdown struct{}

type SubmitStartSnapshot struct {
	CheckID       check.CheckID
	TransactionID string
	Instance      topology.Instance
}

type SubmitStopSnapshot struct {
	CheckID       check.CheckID
	TransactionID string
	Instance      topology.Instance
}

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

type TransactionCheckInstanceBatchState struct {
	Transaction *BatchTransaction
	Topology    *topology.Topology
	Metrics     *telemetry.Metrics
	Health      map[string]health.Health
	Events      *telemetry.IntakeEvents
}

type TransactionCheckInstanceBatchStates map[check.CheckID]TransactionCheckInstanceBatchState

type TransactionalBatcher interface {
	// Topology
	SubmitComponent(checkID check.CheckID, transactionID string, instance topology.Instance, component topology.Component)
	SubmitRelation(checkID check.CheckID, transactionID string, instance topology.Instance, relation topology.Relation)
	SubmitStartSnapshot(checkID check.CheckID, transactionID string, instance topology.Instance)
	SubmitStopSnapshot(checkID check.CheckID, transactionID string, instance topology.Instance)
	SubmitDelete(checkID check.CheckID, transactionID string, instance topology.Instance, topologyElementID string)

	// Health
	SubmitHealthCheckData(checkID check.CheckID, transactionID string, stream health.Stream, data health.CheckData)
	SubmitHealthStartSnapshot(checkID check.CheckID, transactionID string, stream health.Stream, intervalSeconds int, expirySeconds int)
	SubmitHealthStopSnapshot(checkID check.CheckID, transactionID string, stream health.Stream)

	// Raw Metrics
	SubmitRawMetricsData(checkID check.CheckID, transactionID string, data telemetry.RawMetric)

	// Events
	SubmitEvent(checkID check.CheckID, transactionID string, event telemetry.Event)

	// Transactional
	StartTransaction(checkID check.CheckID, transactionID string)
	SubmitCompleteTransaction(checkID check.CheckID, transactionID string)

	// lifecycle
	SubmitClearState(checkID check.CheckID)
	Stop()
}