khulnasoft

Documentation

Index

• Variables
• func SendSuccessfulDeploymentSignal(successSignalUrl string)
• func ToKafkaRestFormat(data []interface{}) *bytes.Buffer
• type AccessDeniedResponseError
• type Client
  • func NewClient(config util.Config) (*Client, error)
  • func (c *Client) IngestComplianceResults(complianceDocs []util.ComplianceDoc) error
  • func (c *Client) RegisterCloudAccount(hostId, cloudProvider, cloudMetaId string, multiIds []string, orgId *string, ...) error
  • func (c *Client) RegisterCloudResources(resources []map[string]interface{}) error
  • func (c *Client) SendScanStatusToConsole(ccstatus CloudComplianceScanStatus) error
• type CloudComplianceScanStatus
• type IngestersComplianceStats
• type WaitSignal

Variables

var (
	HomeDirectory string
)

Functions

func SendSuccessfulDeploymentSignal

func SendSuccessfulDeploymentSignal(successSignalUrl string)

func ToKafkaRestFormat

func ToKafkaRestFormat(data []interface{}) *bytes.Buffer

data needs to be in this format for kafka rest proxy {"records":[{"value":<record1>},{"value":record2}]}

Types

type AccessDeniedResponseError

type AccessDeniedResponseError struct {
	XMLName xml.Name `xml:"Error"`
	Code    string   `xml:"Code"`
	Message string   `xml:"Message"`
}

type Client

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

func NewClient

func NewClient(config util.Config) (*Client, error)

func (*Client) IngestComplianceResults

func (c *Client) IngestComplianceResults(complianceDocs []util.ComplianceDoc) error

func (*Client) RegisterCloudAccount

func (c *Client) RegisterCloudAccount(hostId, cloudProvider, cloudMetaId string,
	multiIds []string, orgId *string, version string) error

func (*Client) RegisterCloudResources

func (c *Client) RegisterCloudResources(resources []map[string]interface{}) error

func (*Client) SendScanStatusToConsole

func (c *Client) SendScanStatusToConsole(ccstatus CloudComplianceScanStatus) error

type CloudComplianceScanStatus

type CloudComplianceScanStatus struct {
	ScanId               string                   `json:"scan_id"`
	ScanMessage          string                   `json:"scan_message"`
	ScanStatus           string                   `json:"scan_status"`
	NodeId               string                   `json:"node_id"`
	ComplianceCheckTypes []string                 `json:"compliance_check_types"`
	Result               IngestersComplianceStats `json:"result"`
	TotalChecks          int32                    `json:"total_checks"`
	Type                 string                   `json:"type"`
}

type IngestersComplianceStats

type IngestersComplianceStats struct {
	Alarm                int32   `json:"alarm,omitempty"`
	CompliancePercentage float32 `json:"compliance_percentage,omitempty"`
	Error                int32   `json:"error,omitempty"`
	Info                 int32   `json:"info,omitempty"`
	Ok                   int32   `json:"ok,omitempty"`
	Skip                 int32   `json:"skip,omitempty"`
}

type WaitSignal

type WaitSignal struct {
	Status   string `json:"Status"`
	Reason   string `json:"Reason"`
	UniqueId string `json:"UniqueId"`
	Data     string `json:"Data"`
}