server/internal/async/operations/longRunningOperation/longRunningEntity.go (16 lines of code) (raw):
package longRunningOperation
import (
opbus "github.com/Azure/aks-async/operationsbus"
)
// Setting the variable to ensure all functions of the Entity interface are implemented.
var _ opbus.Entity = &LongRunningEntity{}
type LongRunningEntity struct {
LastOperationId string
}
func NewLongRunningEntity(lastOperationId string) *LongRunningEntity {
return &LongRunningEntity{
LastOperationId: lastOperationId,
}
}
func (lre LongRunningEntity) GetLatestOperationID() string {
return lre.LastOperationId
}