nodes

Documentation

Index

• func GetNode(ctx context.Context, in *nodes.Id, db *pgdb.DB, ...) (*nodes.Node, error)
• type Server
  • func New(db *pgdb.DB, connectionFactory *secureconn.Factory, secretsEndpoint string) *Server
  • func (srv *Server) BulkCreate(ctx context.Context, in *nodes.Nodes) (*nodes.Ids, error)
  • func (srv *Server) BulkDelete(ctx context.Context, in *nodes.Query) (*nodes.BulkDeleteResponse, error)
  • func (srv *Server) BulkDeleteById(ctx context.Context, in *nodes.Ids) (*nodes.BulkDeleteResponse, error)
  • func (srv *Server) Create(ctx context.Context, in *nodes.Node) (*nodes.Id, error)
  • func (srv *Server) Delete(ctx context.Context, in *nodes.Id) (*pb.Empty, error)
  • func (srv *Server) List(ctx context.Context, in *nodes.Query) (*nodes.Nodes, error)
  • func (srv *Server) Read(ctx context.Context, in *nodes.Id) (*nodes.Node, error)
  • func (srv *Server) Update(ctx context.Context, in *nodes.Node) (*pb.Empty, error)
  • func (srv *Server) UpdateNodeConnectionError(ctx context.Context, in *nodes.NodeError) (*pb.Empty, error)
  • func (srv *Server) UpdateNodeDetectInfo(ctx context.Context, in *nodes.NodeDetectJobInfo) (*pb.Empty, error)

Functions

func GetNode

func GetNode(ctx context.Context, in *nodes.Id, db *pgdb.DB, secretsClient secrets.SecretsServiceClient) (*nodes.Node, error)

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server implementation for nodes

func New

func New(db *pgdb.DB, connectionFactory *secureconn.Factory, secretsEndpoint string) *Server

New creates a new server

func (*Server) BulkCreate

func (srv *Server) BulkCreate(ctx context.Context, in *nodes.Nodes) (*nodes.Ids, error)

Create a new node

func (*Server) BulkDelete

func (srv *Server) BulkDelete(ctx context.Context, in *nodes.Query) (*nodes.BulkDeleteResponse, error)

Delete nodes based on a query

func (*Server) BulkDeleteById

func (srv *Server) BulkDeleteById(ctx context.Context, in *nodes.Ids) (*nodes.BulkDeleteResponse, error)

func (*Server) Create

func (srv *Server) Create(ctx context.Context, in *nodes.Node) (*nodes.Id, error)

Create a new node

func (*Server) Delete

func (srv *Server) Delete(ctx context.Context, in *nodes.Id) (*pb.Empty, error)

Delete a node

func (*Server) List

func (srv *Server) List(ctx context.Context, in *nodes.Query) (*nodes.Nodes, error)

List nodes based on a query

func (*Server) Read

func (srv *Server) Read(ctx context.Context, in *nodes.Id) (*nodes.Node, error)

Read a node via ID

func (*Server) Update

func (srv *Server) Update(ctx context.Context, in *nodes.Node) (*pb.Empty, error)

Update one node

func (*Server) UpdateNodeConnectionError

func (srv *Server) UpdateNodeConnectionError(ctx context.Context, in *nodes.NodeError) (*pb.Empty, error)

UpdateNodeDetectInfo updates the connection error for a node. used by the inspec-agent.

func (*Server) UpdateNodeDetectInfo

func (srv *Server) UpdateNodeDetectInfo(ctx context.Context, in *nodes.NodeDetectJobInfo) (*pb.Empty, error)

UpdateNodeDetectInfo updates the detect info for a node. used by the inspec-agent runner