server.go 746 B

123456789101112131415161718192021222324252627282930313233
  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. rootCA *ca.RootCA
  18. pg plugingetter.PluginGetter
  19. }
  20. // NewServer creates a Cluster API server.
  21. func NewServer(store *store.MemoryStore, raft *raft.Node, rootCA *ca.RootCA, pg plugingetter.PluginGetter) *Server {
  22. return &Server{
  23. store: store,
  24. raft: raft,
  25. rootCA: rootCA,
  26. pg: pg,
  27. }
  28. }