-
Notifications
You must be signed in to change notification settings - Fork 4.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
use a more 'normal' storage factory #20741
Conversation
c1173bf
to
bd762db
Compare
"k8s.io/apiserver/pkg/storage/storagebackend" | ||
) | ||
|
||
func GetEtcdOptions(startingFlags map[string][]string, etcdConnectionInfo configapi.EtcdConnectionInfo, storagePrefix string, defaultWatchCacheSizes map[schema.GroupResource]int) (*options.EtcdOptions, error) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
godoc. startignFlags are api server flags?
storageConfig.CAFile = etcdConnectionInfo.CA | ||
|
||
etcdOptions := options.NewEtcdOptions(storageConfig) | ||
etcdOptions.DefaultStorageMediaType = "application/json" // TODO(post-1.6.1-rebase): enable protobuf with etcd3 as upstream |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
no proto?
// storage versions: no overrides anymore | ||
map[schema.GroupResource]schema.GroupVersion{}, | ||
// quorum resources: | ||
map[schema.GroupResource]struct{}{ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this special quorum handling is gone, isn't it? So we default to quorum=true?
pkg/cmd/util/flags/flags.go
Outdated
return apply(args, fs, false) | ||
} | ||
|
||
func ResolveIgnoreMissing(args map[string][]string, fn func(*pflag.FlagSet)) []error { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
godoc
bd762db
to
a3e4a17
Compare
/hold holding to make sure we don't accidentally merge a json backed storage impl. @enj Any idea why the proto deserialization doesn't work? I'm looking and I can't see where you generated the proto files for your type, so how did that ever work? reflective conversion? |
a3e4a17
to
6feba2f
Compare
6feba2f
to
c8ac2d5
Compare
/hold cancel This is ready for review/merge now. |
c8ac2d5
to
d205dd3
Compare
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: deads2k The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
@@ -80,8 +80,6 @@ func (opt KubeAPIServerStartConfig) MakeMasterConfig(dockerClient dockerhelper.I | |||
return "", err | |||
} | |||
|
|||
masterconfig.KubernetesMasterConfig.APIServerArguments["feature-gates"] = []string{"CustomResourceSubresources=true"} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this is now on by default.
|
||
// perform watch cache heuristic like upstream | ||
if apiserverOptions.Etcd.EnableWatchCache { | ||
glog.V(2).Infof("Initializing cache sizes based on %dMB limit", apiserverOptions.GenericServerRunOptions.TargetRAMMB) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
the log message is gone. Intentionally?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
the log message is gone. Intentionally?
Yeah. If we need to expose it, we need to expose it a different way. Metric probably.
Have tried to follow the path of all options. Looks good so far. Just a question about the log output. Otherwise lgtm. |
@deads2k: The following tests failed, say
Full PR test history. Your PR dashboard. Please help us cut down on flakes by linking to an open issue when you hit one in your PR. Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository. I understand the commands that are listed here. |
This attempts to remove our special storage factory and collapse onto the same one that upstream uses. It currently fails tests and needs at least one more, so WIP.
@enj this is why I'm worried about that CR test.
/assign @sttts