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 }