server.go 926 B

1234567891011121314151617181920212223242526272829303132333435
  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/drivers"
  7. "github.com/docker/swarmkit/manager/state/raft"
  8. "github.com/docker/swarmkit/manager/state/store"
  9. )
  10. var (
  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. pg plugingetter.PluginGetter
  19. dr *drivers.DriverProvider
  20. }
  21. // NewServer creates a Cluster API server.
  22. func NewServer(store *store.MemoryStore, raft *raft.Node, securityConfig *ca.SecurityConfig, pg plugingetter.PluginGetter, dr *drivers.DriverProvider) *Server {
  23. return &Server{
  24. store: store,
  25. dr: dr,
  26. raft: raft,
  27. securityConfig: securityConfig,
  28. pg: pg,
  29. }
  30. }