projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
17702: Federated lists supports cluster_id parameter
[arvados.git]
/
lib
/
controller
/
federation
/
generated.go
diff --git
a/lib/controller/federation/generated.go
b/lib/controller/federation/generated.go
index 49a2e5b7513f537f0f129fac6c8ba81103e72a29..3ede1f1154900256bcda9e589013fafe1e30e52a 100755
(executable)
--- a/
lib/controller/federation/generated.go
+++ b/
lib/controller/federation/generated.go
@@
-18,6
+18,12
@@
import (
//
func (conn *Conn) generated_ContainerList(ctx context.Context, options arvados.ListOptions) (arvados.ContainerList, error) {
//
func (conn *Conn) generated_ContainerList(ctx context.Context, options arvados.ListOptions) (arvados.ContainerList, error) {
+ if options.ClusterID != "" {
+ // explicitly selected cluster
+ options.ForwardedFor = conn.cluster.ClusterID + "-" + options.ForwardedFor
+ return conn.chooseBackend(options.ClusterID).ContainerList(ctx, options)
+ }
+
var mtx sync.Mutex
var merged arvados.ContainerList
var needSort atomic.Value
var mtx sync.Mutex
var merged arvados.ContainerList
var needSort atomic.Value
@@
-59,6
+65,12
@@
func (conn *Conn) generated_ContainerList(ctx context.Context, options arvados.L
}
func (conn *Conn) generated_ContainerRequestList(ctx context.Context, options arvados.ListOptions) (arvados.ContainerRequestList, error) {
}
func (conn *Conn) generated_ContainerRequestList(ctx context.Context, options arvados.ListOptions) (arvados.ContainerRequestList, error) {
+ if options.ClusterID != "" {
+ // explicitly selected cluster
+ options.ForwardedFor = conn.cluster.ClusterID + "-" + options.ForwardedFor
+ return conn.chooseBackend(options.ClusterID).ContainerRequestList(ctx, options)
+ }
+
var mtx sync.Mutex
var merged arvados.ContainerRequestList
var needSort atomic.Value
var mtx sync.Mutex
var merged arvados.ContainerRequestList
var needSort atomic.Value
@@
-100,6
+112,12
@@
func (conn *Conn) generated_ContainerRequestList(ctx context.Context, options ar
}
func (conn *Conn) generated_GroupList(ctx context.Context, options arvados.ListOptions) (arvados.GroupList, error) {
}
func (conn *Conn) generated_GroupList(ctx context.Context, options arvados.ListOptions) (arvados.GroupList, error) {
+ if options.ClusterID != "" {
+ // explicitly selected cluster
+ options.ForwardedFor = conn.cluster.ClusterID + "-" + options.ForwardedFor
+ return conn.chooseBackend(options.ClusterID).GroupList(ctx, options)
+ }
+
var mtx sync.Mutex
var merged arvados.GroupList
var needSort atomic.Value
var mtx sync.Mutex
var merged arvados.GroupList
var needSort atomic.Value
@@
-141,6
+159,12
@@
func (conn *Conn) generated_GroupList(ctx context.Context, options arvados.ListO
}
func (conn *Conn) generated_SpecimenList(ctx context.Context, options arvados.ListOptions) (arvados.SpecimenList, error) {
}
func (conn *Conn) generated_SpecimenList(ctx context.Context, options arvados.ListOptions) (arvados.SpecimenList, error) {
+ if options.ClusterID != "" {
+ // explicitly selected cluster
+ options.ForwardedFor = conn.cluster.ClusterID + "-" + options.ForwardedFor
+ return conn.chooseBackend(options.ClusterID).SpecimenList(ctx, options)
+ }
+
var mtx sync.Mutex
var merged arvados.SpecimenList
var needSort atomic.Value
var mtx sync.Mutex
var merged arvados.SpecimenList
var needSort atomic.Value
@@
-182,6
+206,12
@@
func (conn *Conn) generated_SpecimenList(ctx context.Context, options arvados.Li
}
func (conn *Conn) generated_UserList(ctx context.Context, options arvados.ListOptions) (arvados.UserList, error) {
}
func (conn *Conn) generated_UserList(ctx context.Context, options arvados.ListOptions) (arvados.UserList, error) {
+ if options.ClusterID != "" {
+ // explicitly selected cluster
+ options.ForwardedFor = conn.cluster.ClusterID + "-" + options.ForwardedFor
+ return conn.chooseBackend(options.ClusterID).UserList(ctx, options)
+ }
+
var mtx sync.Mutex
var merged arvados.UserList
var needSort atomic.Value
var mtx sync.Mutex
var merged arvados.UserList
var needSort atomic.Value