bolthub

Documentation

Index

• type DbEnrollment
• type Server
  • func NewServer(dbPath string, logger *zap.Logger) (*Server, error)
  • func NewServerFromBolthold(db *bolthold.Store, logger *zap.Logger) *Server
  • func (s *Server) Close() error
  • func (s *Server) EnrollHubNode(ctx context.Context, req *gen.EnrollHubNodeRequest) (*gen.HubNode, error)
  • func (s *Server) ForgetHubNode(ctx context.Context, request *gen.ForgetHubNodeRequest) (*gen.ForgetHubNodeResponse, error)
  • func (s *Server) GetHubNode(ctx context.Context, req *gen.GetHubNodeRequest) (*gen.HubNode, error)
  • func (s *Server) InspectHubNode(ctx context.Context, request *gen.InspectHubNodeRequest) (*gen.HubNodeInspection, error)
  • func (s *Server) ListHubNodes(ctx context.Context, request *gen.ListHubNodesRequest) (*gen.ListHubNodesResponse, error)
  • func (s *Server) PullHubNodes(request *gen.PullHubNodesRequest, server gen.HubApi_PullHubNodesServer) error
  • func (s *Server) RenewHubNode(ctx context.Context, request *gen.RenewHubNodeRequest) (*gen.HubNode, error)
  • func (s *Server) TestHubNode(ctx context.Context, request *gen.TestHubNodeRequest) (*gen.TestHubNodeResponse, error)

Types

type DbEnrollment

type DbEnrollment struct {
	Name        string
	Description string
	Address     string
	Cert        []byte
}

type Server

type Server struct {
	gen.UnimplementedHubApiServer

	ManagerName   string
	ManagerAddr   string
	Authority     pki.Source  // trust authority for the cohort of smart core nodes
	TestTLSConfig *tls.Config // TLS config used when initiating test connections with a node
	// contains filtered or unexported fields
}

func NewServer

func NewServer(dbPath string, logger *zap.Logger) (*Server, error)

func NewServerFromBolthold

func NewServerFromBolthold(db *bolthold.Store, logger *zap.Logger) *Server

func (*Server) Close

func (s *Server) Close() error

func (*Server) EnrollHubNode

func (s *Server) EnrollHubNode(ctx context.Context, req *gen.EnrollHubNodeRequest) (*gen.HubNode, error)

func (*Server) ForgetHubNode

func (s *Server) ForgetHubNode(ctx context.Context, request *gen.ForgetHubNodeRequest) (*gen.ForgetHubNodeResponse, error)

func (*Server) GetHubNode

func (s *Server) GetHubNode(ctx context.Context, req *gen.GetHubNodeRequest) (*gen.HubNode, error)

func (*Server) InspectHubNode

func (s *Server) InspectHubNode(ctx context.Context, request *gen.InspectHubNodeRequest) (*gen.HubNodeInspection, error)

func (*Server) ListHubNodes

func (s *Server) ListHubNodes(ctx context.Context, request *gen.ListHubNodesRequest) (*gen.ListHubNodesResponse, error)

func (*Server) PullHubNodes

func (s *Server) PullHubNodes(request *gen.PullHubNodesRequest, server gen.HubApi_PullHubNodesServer) error

func (*Server) RenewHubNode

func (s *Server) RenewHubNode(ctx context.Context, request *gen.RenewHubNodeRequest) (*gen.HubNode, error)

func (*Server) TestHubNode

func (s *Server) TestHubNode(ctx context.Context, request *gen.TestHubNodeRequest) (*gen.TestHubNodeResponse, error)