posture

Documentation

Index

• func Domain() string
• func MacAddresses() []string
• type Cache
  • func NewCache(submitter Submitter, closeNotify <-chan struct{}) *Cache
  • func (cache *Cache) AddActiveService(serviceId string)
  • func (cache *Cache) Evaluate()
  • func (cache *Cache) GetChangedResponses() []rest_model.PostureResponseCreate
  • func (cache *Cache) Refresh()
  • func (cache *Cache) RemoveActiveService(serviceId string)
  • func (cache *Cache) SendResponses(responses []rest_model.PostureResponseCreate) []error
  • func (cache *Cache) SetServiceQueryMap(serviceQueryMap map[string]map[string]rest_model.PostureQuery)
• type CacheData
  • func NewCacheData() *CacheData
• type OsInfo
  • func Os() OsInfo
• type ProcessInfo
  • func Process(providedPath string) ProcessInfo
• type Submitter

Functions

func Domain

func Domain() string

func MacAddresses

func MacAddresses() []string

Types

type Cache

type Cache struct {
	DomainFunc func() string
	// contains filtered or unexported fields
}

func NewCache

func NewCache(submitter Submitter, closeNotify <-chan struct{}) *Cache

func (*Cache) AddActiveService

func (cache *Cache) AddActiveService(serviceId string)

func (*Cache) Evaluate

func (cache *Cache) Evaluate()

Evaluate refreshes all posture data and determines if new posture responses should be sent out

func (*Cache) GetChangedResponses

func (cache *Cache) GetChangedResponses() []rest_model.PostureResponseCreate

GetChangedResponses determines if posture responses should be sent out.

func (*Cache) Refresh

func (cache *Cache) Refresh()

Refresh refreshes posture data

func (*Cache) RemoveActiveService

func (cache *Cache) RemoveActiveService(serviceId string)

func (*Cache) SendResponses

func (cache *Cache) SendResponses(responses []rest_model.PostureResponseCreate) []error

func (*Cache) SetServiceQueryMap

func (cache *Cache) SetServiceQueryMap(serviceQueryMap map[string]map[string]rest_model.PostureQuery)

SetServiceQueryMap receives of a list of serviceId -> queryId -> queries. Used to determine which queries are necessary to provide data for on a per-service basis.

type CacheData

type CacheData struct {
	Processes    cmap.ConcurrentMap[string, ProcessInfo] // map[processPath]ProcessInfo
	MacAddresses []string
	Os           OsInfo
	Domain       string
	Evaluated    atomic.Bool //marks whether posture responses for this data have been sent out
}

func NewCacheData

func NewCacheData() *CacheData

type OsInfo

type OsInfo struct {
	Type    string
	Version string
}

func Os

func Os() OsInfo

type ProcessInfo

type ProcessInfo struct {
	IsRunning          bool
	Hash               string
	SignerFingerprints []string
}

func Process

func Process(providedPath string) ProcessInfo

type Submitter

type Submitter interface {
	SendPostureResponse(response rest_model.PostureResponseCreate) error
	SendPostureResponseBulk(responses []rest_model.PostureResponseCreate) error
}