server.go 943 B

123456789101112131415161718192021222324252627282930313233343536
  1. package controlapi
  2. import (
  3. "errors"
  4. "github.com/docker/docker/pkg/plugingetter"
  5. "github.com/docker/swarmkit/ca"
  6. "github.com/docker/swarmkit/manager/state/raft"
  7. "github.com/docker/swarmkit/manager/state/store"
  8. )
  9. var (
  10. errNotImplemented = errors.New("not implemented")
  11. errInvalidArgument = errors.New("invalid argument")
  12. )
  13. // Server is the Cluster API gRPC server.
  14. type Server struct {
  15. store *store.MemoryStore
  16. raft *raft.Node
  17. securityConfig *ca.SecurityConfig
  18. scu ca.APISecurityConfigUpdater
  19. pg plugingetter.PluginGetter
  20. }
  21. // NewServer creates a Cluster API server.
  22. func NewServer(store *store.MemoryStore, raft *raft.Node, securityConfig *ca.SecurityConfig,
  23. scu ca.APISecurityConfigUpdater, pg plugingetter.PluginGetter) *Server {
  24. return &Server{
  25. store: store,
  26. raft: raft,
  27. securityConfig: securityConfig,
  28. scu: scu,
  29. pg: pg,
  30. }
  31. }