diff --git a/pkg/cli/server/server.go b/pkg/cli/server/server.go index 5d1052b2e8..8e4c17043c 100644 --- a/pkg/cli/server/server.go +++ b/pkg/cli/server/server.go @@ -150,12 +150,17 @@ func run(app *cli.Context, cfg *cmds.Server, leaderControllers server.CustomCont serverConfig.ControlConfig.ExtraEtcdArgs = cfg.ExtraEtcdArgs.Value() serverConfig.ControlConfig.ExtraSchedulerAPIArgs = cfg.ExtraSchedulerArgs.Value() serverConfig.ControlConfig.ClusterDomain = cfg.ClusterDomain - serverConfig.ControlConfig.Datastore.NotifyInterval = 5 * time.Second - serverConfig.ControlConfig.Datastore.EmulatedETCDVersion = etcdversion.Version - serverConfig.ControlConfig.Datastore.Endpoint = cfg.DatastoreEndpoint serverConfig.ControlConfig.Datastore.BackendTLSConfig.CAFile = cfg.DatastoreCAFile serverConfig.ControlConfig.Datastore.BackendTLSConfig.CertFile = cfg.DatastoreCertFile serverConfig.ControlConfig.Datastore.BackendTLSConfig.KeyFile = cfg.DatastoreKeyFile + serverConfig.ControlConfig.Datastore.CompactBatchSize = 1000 + serverConfig.ControlConfig.Datastore.CompactInterval = 5 * time.Minute + serverConfig.ControlConfig.Datastore.CompactMinRetain = 1000 + serverConfig.ControlConfig.Datastore.CompactTimeout = 5 * time.Second + serverConfig.ControlConfig.Datastore.EmulatedETCDVersion = etcdversion.Version + serverConfig.ControlConfig.Datastore.Endpoint = cfg.DatastoreEndpoint + serverConfig.ControlConfig.Datastore.NotifyInterval = 5 * time.Second + serverConfig.ControlConfig.Datastore.PollBatchSize = 500 serverConfig.ControlConfig.KineTLS = cfg.KineTLS serverConfig.ControlConfig.AdvertiseIP = cfg.AdvertiseIP serverConfig.ControlConfig.AdvertisePort = cfg.AdvertisePort diff --git a/pkg/daemons/control/server_test.go b/pkg/daemons/control/server_test.go index 1bd184f45d..75f298c471 100644 --- a/pkg/daemons/control/server_test.go +++ b/pkg/daemons/control/server_test.go @@ -19,7 +19,9 @@ import ( "github.com/k3s-io/k3s/pkg/etcd" testutil "github.com/k3s-io/k3s/tests" "github.com/k3s-io/k3s/tests/mock" + "github.com/k3s-io/kine/pkg/endpoint" pkgerrors "github.com/pkg/errors" + etcdversion "go.etcd.io/etcd/api/v3/version" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apiserver/pkg/authentication/authenticator" "k8s.io/apiserver/pkg/authentication/request/anonymous" @@ -183,6 +185,15 @@ func mockControl(ctx context.Context, t *testing.T, clusterInit bool) (*config.C ServerNodeName: "k3s-server-1", ServiceNodePortRange: &utilnet.PortRange{Base: 30000, Size: 2048}, Token: "token", + Datastore: endpoint.Config{ + CompactBatchSize: 1000, + CompactInterval: 5 * time.Minute, + CompactMinRetain: 1000, + CompactTimeout: 5 * time.Second, + EmulatedETCDVersion: etcdversion.Version, + NotifyInterval: 5 * time.Second, + PollBatchSize: 500, + }, } if err := os.Chdir(control.DataDir); err != nil {