vendor/github.com/docker/swarmkit/manager/controlapi/server.go

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