configs.go 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117
  1. package cluster
  2. import (
  3. apitypes "github.com/docker/docker/api/types"
  4. types "github.com/docker/docker/api/types/swarm"
  5. "github.com/docker/docker/daemon/cluster/convert"
  6. swarmapi "github.com/docker/swarmkit/api"
  7. "golang.org/x/net/context"
  8. )
  9. // GetConfig returns a config from a managed swarm cluster
  10. func (c *Cluster) GetConfig(input string) (types.Config, error) {
  11. var config *swarmapi.Config
  12. if err := c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
  13. s, err := getConfig(ctx, state.controlClient, input)
  14. if err != nil {
  15. return err
  16. }
  17. config = s
  18. return nil
  19. }); err != nil {
  20. return types.Config{}, err
  21. }
  22. return convert.ConfigFromGRPC(config), nil
  23. }
  24. // GetConfigs returns all configs of a managed swarm cluster.
  25. func (c *Cluster) GetConfigs(options apitypes.ConfigListOptions) ([]types.Config, error) {
  26. c.mu.RLock()
  27. defer c.mu.RUnlock()
  28. state := c.currentNodeState()
  29. if !state.IsActiveManager() {
  30. return nil, c.errNoManager(state)
  31. }
  32. filters, err := newListConfigsFilters(options.Filters)
  33. if err != nil {
  34. return nil, err
  35. }
  36. ctx, cancel := c.getRequestContext()
  37. defer cancel()
  38. r, err := state.controlClient.ListConfigs(ctx,
  39. &swarmapi.ListConfigsRequest{Filters: filters})
  40. if err != nil {
  41. return nil, err
  42. }
  43. configs := []types.Config{}
  44. for _, config := range r.Configs {
  45. configs = append(configs, convert.ConfigFromGRPC(config))
  46. }
  47. return configs, nil
  48. }
  49. // CreateConfig creates a new config in a managed swarm cluster.
  50. func (c *Cluster) CreateConfig(s types.ConfigSpec) (string, error) {
  51. var resp *swarmapi.CreateConfigResponse
  52. if err := c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
  53. configSpec := convert.ConfigSpecToGRPC(s)
  54. r, err := state.controlClient.CreateConfig(ctx,
  55. &swarmapi.CreateConfigRequest{Spec: &configSpec})
  56. if err != nil {
  57. return err
  58. }
  59. resp = r
  60. return nil
  61. }); err != nil {
  62. return "", err
  63. }
  64. return resp.Config.ID, nil
  65. }
  66. // RemoveConfig removes a config from a managed swarm cluster.
  67. func (c *Cluster) RemoveConfig(input string) error {
  68. return c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
  69. config, err := getConfig(ctx, state.controlClient, input)
  70. if err != nil {
  71. return err
  72. }
  73. req := &swarmapi.RemoveConfigRequest{
  74. ConfigID: config.ID,
  75. }
  76. _, err = state.controlClient.RemoveConfig(ctx, req)
  77. return err
  78. })
  79. }
  80. // UpdateConfig updates a config in a managed swarm cluster.
  81. // Note: this is not exposed to the CLI but is available from the API only
  82. func (c *Cluster) UpdateConfig(input string, version uint64, spec types.ConfigSpec) error {
  83. return c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
  84. config, err := getConfig(ctx, state.controlClient, input)
  85. if err != nil {
  86. return err
  87. }
  88. configSpec := convert.ConfigSpecToGRPC(spec)
  89. _, err = state.controlClient.UpdateConfig(ctx,
  90. &swarmapi.UpdateConfigRequest{
  91. ConfigID: config.ID,
  92. ConfigVersion: &swarmapi.Version{
  93. Index: version,
  94. },
  95. Spec: &configSpec,
  96. })
  97. return err
  98. })
  99. }