build(deps): bump github.com/vmware/govmomi from 0.26.1 to 0.27.4
Bumps [github.com/vmware/govmomi](https://github.com/vmware/govmomi) from 0.26.1 to 0.27.4. - [Release notes](https://github.com/vmware/govmomi/releases) - [Changelog](https://github.com/vmware/govmomi/blob/master/CHANGELOG.md) - [Commits](https://github.com/vmware/govmomi/compare/v0.26.1...v0.27.4) --- updated-dependencies: - dependency-name: github.com/vmware/govmomi dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com>
This commit is contained in:
parent
1ded72b4dc
commit
2ba68442d3
37 changed files with 1535 additions and 237 deletions
86
vendor/github.com/vmware/govmomi/task/history_collector.go
generated
vendored
Normal file
86
vendor/github.com/vmware/govmomi/task/history_collector.go
generated
vendored
Normal file
|
|
@ -0,0 +1,86 @@
|
|||
/*
|
||||
Copyright (c) 2015 VMware, Inc. All Rights Reserved.
|
||||
|
||||
Licensed under the Apache License, Version 2.0 (the "License");
|
||||
you may not use this file except in compliance with the License.
|
||||
You may obtain a copy of the License at
|
||||
|
||||
http://www.apache.org/licenses/LICENSE-2.0
|
||||
|
||||
Unless required by applicable law or agreed to in writing, software
|
||||
distributed under the License is distributed on an "AS IS" BASIS,
|
||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
See the License for the specific language governing permissions and
|
||||
limitations under the License.
|
||||
*/
|
||||
|
||||
package task
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/vmware/govmomi/history"
|
||||
"github.com/vmware/govmomi/vim25"
|
||||
"github.com/vmware/govmomi/vim25/methods"
|
||||
"github.com/vmware/govmomi/vim25/mo"
|
||||
"github.com/vmware/govmomi/vim25/types"
|
||||
)
|
||||
|
||||
// HistoryCollector provides a mechanism for retrieving historical data and
|
||||
// updates when the server appends new tasks.
|
||||
type HistoryCollector struct {
|
||||
*history.Collector
|
||||
}
|
||||
|
||||
func newHistoryCollector(c *vim25.Client, ref types.ManagedObjectReference) *HistoryCollector {
|
||||
return &HistoryCollector{
|
||||
Collector: history.NewCollector(c, ref),
|
||||
}
|
||||
}
|
||||
|
||||
// RecentTasks returns a list of task managed objects that completed recently,
|
||||
// that are currently running, or that are queued to run.
|
||||
func (h HistoryCollector) RecentTasks(ctx context.Context) ([]types.TaskInfo, error) {
|
||||
var o mo.TaskHistoryCollector
|
||||
|
||||
err := h.Properties(ctx, h.Reference(), []string{"recentTask"}, &o)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return o.LatestPage, nil
|
||||
}
|
||||
|
||||
// ReadNextTasks reads the scrollable view from the current position. The
|
||||
// scrollable position is moved to the next newer page after the read. No item
|
||||
// is returned when the end of the collector is reached.
|
||||
func (h HistoryCollector) ReadNextTasks(ctx context.Context, maxCount int32) ([]types.TaskInfo, error) {
|
||||
req := types.ReadNextTasks{
|
||||
This: h.Reference(),
|
||||
MaxCount: maxCount,
|
||||
}
|
||||
|
||||
res, err := methods.ReadNextTasks(ctx, h.Client(), &req)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return res.Returnval, nil
|
||||
}
|
||||
|
||||
// ReadPreviousTasks reads the scrollable view from the current position. The
|
||||
// scrollable position is then moved to the next older page after the read. No
|
||||
// item is returned when the head of the collector is reached.
|
||||
func (h HistoryCollector) ReadPreviousTasks(ctx context.Context, maxCount int32) ([]types.TaskInfo, error) {
|
||||
req := types.ReadPreviousTasks{
|
||||
This: h.Reference(),
|
||||
MaxCount: maxCount,
|
||||
}
|
||||
|
||||
res, err := methods.ReadPreviousTasks(ctx, h.Client(), &req)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return res.Returnval, nil
|
||||
}
|
||||
45
vendor/github.com/vmware/govmomi/task/manager.go
generated
vendored
Normal file
45
vendor/github.com/vmware/govmomi/task/manager.go
generated
vendored
Normal file
|
|
@ -0,0 +1,45 @@
|
|||
package task
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/vmware/govmomi/vim25"
|
||||
"github.com/vmware/govmomi/vim25/methods"
|
||||
"github.com/vmware/govmomi/vim25/types"
|
||||
)
|
||||
|
||||
type Manager struct {
|
||||
r types.ManagedObjectReference
|
||||
c *vim25.Client
|
||||
}
|
||||
|
||||
// NewManager creates a new task manager
|
||||
func NewManager(c *vim25.Client) *Manager {
|
||||
m := Manager{
|
||||
r: *c.ServiceContent.TaskManager,
|
||||
c: c,
|
||||
}
|
||||
|
||||
return &m
|
||||
}
|
||||
|
||||
// Reference returns the task.Manager MOID
|
||||
func (m Manager) Reference() types.ManagedObjectReference {
|
||||
return m.r
|
||||
}
|
||||
|
||||
// CreateCollectorForTasks returns a task history collector, a specialized
|
||||
// history collector that gathers TaskInfo data objects.
|
||||
func (m Manager) CreateCollectorForTasks(ctx context.Context, filter types.TaskFilterSpec) (*HistoryCollector, error) {
|
||||
req := types.CreateCollectorForTasks{
|
||||
This: m.r,
|
||||
Filter: filter,
|
||||
}
|
||||
|
||||
res, err := methods.CreateCollectorForTasks(ctx, m.c, &req)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return newHistoryCollector(m.c, res.Returnval), nil
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue