grpcserver

Documentation

Index

• func ToTime(timestamp *google_protobuf1.Timestamp) (time.Time, error)
• type CfgMgmtServer
  • func NewCfgMgmtServer(cs *config.Service) *CfgMgmtServer
  • func (s *CfgMgmtServer) GetAttributes(ctx context.Context, request *pRequest.Node) (*interserviceResp.NodeAttribute, error)
  • func (s *CfgMgmtServer) GetEventFeed(ctx context.Context, request *request.EventFilter) (*response.Events, error)
  • func (s *CfgMgmtServer) GetEventStringBuckets(ctx context.Context, request *request.EventStrings) (*response.EventStrings, error)
  • func (s *CfgMgmtServer) GetEventTaskCounts(ctx context.Context, request *request.EventCountsFilter) (*response.EventCounts, error)
  • func (s *CfgMgmtServer) GetEventTypeCounts(ctx context.Context, request *request.EventCountsFilter) (*response.EventCounts, error)
  • func (s *CfgMgmtServer) GetHealth(ctx context.Context, empty *request.Health) (*response.Health, error)
  • func (s *CfgMgmtServer) GetInventoryNodes(ctx context.Context, request *pRequest.InventoryNodes) (*interserviceResp.InventoryNodes, error)
  • func (s *CfgMgmtServer) GetNodeRun(ctx context.Context, request *request.NodeRun) (*response.Run, error)
  • func (s *CfgMgmtServer) GetNodes(ctx context.Context, request *pRequest.Nodes) (*gp.ListValue, error)
  • func (s *CfgMgmtServer) GetNodesCounts(ctx context.Context, request *request.NodesCounts) (*response.NodesCounts, error)
  • func (s *CfgMgmtServer) GetOrganizations(ctx context.Context, empty *request.Organizations) (*gpStruct.ListValue, error)
  • func (s *CfgMgmtServer) GetPolicyCookbooks(ctx context.Context, request *request.PolicyRevision) (*response.PolicyCookbooks, error)
  • func (s *CfgMgmtServer) GetRuns(ctx context.Context, request *pRequest.Runs) (*gp.ListValue, error)
  • func (s *CfgMgmtServer) GetRunsCounts(ctx context.Context, request *request.RunsCounts) (*response.RunsCounts, error)
  • func (s *CfgMgmtServer) GetSourceFqdns(ctx context.Context, empty *request.SourceFQDNS) (*gpStruct.ListValue, error)
  • func (s *CfgMgmtServer) GetSuggestions(ctx context.Context, request *request.Suggestion) (*gpStruct.ListValue, error)
  • func (s *CfgMgmtServer) GetVersion(ctx context.Context, empty *request.VersionInfo) (*response.VersionInfo, error)
  • func (s *CfgMgmtServer) NodeExport(request *pRequest.NodeExport, stream service.CfgMgmt_NodeExportServer) error

Functions

func ToTime

func ToTime(timestamp *google_protobuf1.Timestamp) (time.Time, error)

Types

type CfgMgmtServer

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

CfgMgmtServer stores client

func NewCfgMgmtServer

func NewCfgMgmtServer(cs *config.Service) *CfgMgmtServer

NewCfgMgmtServer creates a new server instance and it automatically initializes the ChefRun Pipeline by consuming the provided backend client

func (*CfgMgmtServer) GetAttributes

func (s *CfgMgmtServer) GetAttributes(
	ctx context.Context,
	request *pRequest.Node) (*interserviceResp.NodeAttribute, error)

GetAttributes get node attributes

func (*CfgMgmtServer) GetEventFeed

func (s *CfgMgmtServer) GetEventFeed(ctx context.Context,
	request *request.EventFilter) (*response.Events, error)

GetEventFeed returns a list of all Events

func (*CfgMgmtServer) GetEventStringBuckets

func (s *CfgMgmtServer) GetEventStringBuckets(ctx context.Context, request *request.EventStrings) (*response.EventStrings, error)

GetEventStringBuckets - gets the buckets for the guitar strings create = 2 update = 1 delete = 0 ---------------------------------------------------------------------------- | Jan 28 | Jan 29 | Jan 30 | |_____________b__________|________________________|_____________i__________|'create' |________________________|_____________c__________|________________________|'update' |________________________|________________________|________________________|'delete' ---------------------------------------------------------------------------- 24 hours in a day is enforced. For daylight savings time an hour is added or moved.

func (*CfgMgmtServer) GetEventTaskCounts

func (s *CfgMgmtServer) GetEventTaskCounts(ctx context.Context,
	request *request.EventCountsFilter) (*response.EventCounts, error)

GetEventTaskCounts - gets event task counts

func (*CfgMgmtServer) GetEventTypeCounts

func (s *CfgMgmtServer) GetEventTypeCounts(ctx context.Context,
	request *request.EventCountsFilter) (*response.EventCounts, error)

GetEventTypeCounts - gets event type counts

func (*CfgMgmtServer) GetHealth

func (s *CfgMgmtServer) GetHealth(ctx context.Context,
	empty *request.Health) (*response.Health, error)

GetHealth returns the service Health

func (*CfgMgmtServer) GetInventoryNodes

func (s *CfgMgmtServer) GetInventoryNodes(ctx context.Context,
	request *pRequest.InventoryNodes) (*interserviceResp.InventoryNodes, error)

GetInventoryNodes - get all the inventory nodes

func (*CfgMgmtServer) GetNodeRun

func (s *CfgMgmtServer) GetNodeRun(ctx context.Context,
	request *request.NodeRun) (*response.Run, error)

GetNodeRun returns the requested run

func (*CfgMgmtServer) GetNodes

func (s *CfgMgmtServer) GetNodes(
	ctx context.Context,
	request *pRequest.Nodes) (*gp.ListValue, error)

func (*CfgMgmtServer) GetNodesCounts

func (s *CfgMgmtServer) GetNodesCounts(ctx context.Context,
	request *request.NodesCounts) (*response.NodesCounts, error)

GetNodesCounts returns the nodes counts

func (*CfgMgmtServer) GetOrganizations

func (s *CfgMgmtServer) GetOrganizations(ctx context.Context,
	empty *request.Organizations) (*gpStruct.ListValue, error)

GetOrganizations returns the a list of all organizations

func (*CfgMgmtServer) GetPolicyCookbooks

func (s *CfgMgmtServer) GetPolicyCookbooks(ctx context.Context,
	request *request.PolicyRevision) (*response.PolicyCookbooks, error)

GetPolicyCookbooks returns a list of cookbook name, policy identifier and name of policy based on revision id

func (*CfgMgmtServer) GetRuns

func (s *CfgMgmtServer) GetRuns(
	ctx context.Context,
	request *pRequest.Runs) (*gp.ListValue, error)

func (*CfgMgmtServer) GetRunsCounts

func (s *CfgMgmtServer) GetRunsCounts(ctx context.Context,
	request *request.RunsCounts) (*response.RunsCounts, error)

GetRunsCounts returns the runs counts for a node

func (*CfgMgmtServer) GetSourceFqdns

func (s *CfgMgmtServer) GetSourceFqdns(ctx context.Context,
	empty *request.SourceFQDNS) (*gpStruct.ListValue, error)

GetSourceFqdns returns a list of all source_fqdns

func (*CfgMgmtServer) GetSuggestions

func (s *CfgMgmtServer) GetSuggestions(ctx context.Context,
	request *request.Suggestion) (*gpStruct.ListValue, error)

func (*CfgMgmtServer) GetVersion

func (s *CfgMgmtServer) GetVersion(ctx context.Context,
	empty *request.VersionInfo) (*response.VersionInfo, error)

GetVersion returns the service version

func (*CfgMgmtServer) NodeExport

func (s *CfgMgmtServer) NodeExport(request *pRequest.NodeExport, stream service.CfgMgmt_NodeExportServer) error

NodeExport streams a json or csv export