googlecloudlogk8saudit_impl

package

v0.52.0 Latest Latest Go to latest Published: Feb 3, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/GoogleCloudPlatform/khi

Links

Documentation ¶

Index ¶

Variables
func GenerateK8sAuditQuery(cluster googlecloudk8scommon_contract.GoogleCloudClusterIdentity, ...) string
func Register(registry coreinspection.InspectionTaskRegistry) error
type GCPK8sAuditLogListLogEntriesTaskSetting

Constants ¶

This section is empty.

Variables ¶

View Source

var GCPK8sAuditLogCommonFieldSetReaderTask = inspectiontaskbase.NewFieldSetReadTask(
	googlecloudlogk8saudit_contract.GCPK8sAuditLogCommonFieldSetReaderTaskID,
	googlecloudlogk8saudit_contract.GCPK8sAuditLogListLogEntriesTaskID.Ref(),
	[]log.FieldSetReader{
		&googlecloudlogk8saudit_contract.GCPK8sAuditLogFieldSetReader{},
	},
	inspectioncore_contract.InspectionTypeLabel(googlecloudinspectiontypegroup_contract.GCPK8sClusterInspectionTypes...),
)

View Source

var GCPK8sAuditLogListLogEntriesTask = googlecloudcommon_contract.NewListLogEntriesTask(&GCPK8sAuditLogListLogEntriesTaskSetting{})

View Source

var GCPK8sAuditLogParserTailTask = inspectiontaskbase.NewInspectionTask(
	googlecloudlogk8saudit_contract.GCPK8sAuditLogParserTailTaskID,
	[]taskid.UntypedTaskReference{
		commonlogk8sauditv2_contract.LogSummaryLogToTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.NonSuccessLogLogToTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.NamespaceRequestLogToTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.ResourceRevisionLogToTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.ConditionLogToTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.ResourceOwnerReferenceTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.PodPhaseLogToTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.EndpointResourceLogToTimelineMapperTaskID.Ref(),
		commonlogk8sauditv2_contract.ContainerLogToTimelineMapperTaskID.Ref(),

		commonlogk8sauditv2_contract.NodeNameDiscoveryTaskID.Ref(),
		commonlogk8sauditv2_contract.ResourceUIDDiscoveryTaskID.Ref(),
		commonlogk8sauditv2_contract.ContainerIDDiscoveryTaskID.Ref(),
		commonlogk8sauditv2_contract.IPLeaseHistoryDiscoveryTaskID.Ref(),
		googlecloudk8scommon_contract.NEGNamesDiscoveryTaskID.Ref(),
	},
	func(ctx context.Context, taskMode inspectioncore_contract.InspectionTaskModeType) (struct{}, error) {
		return struct{}{}, nil
	},
	inspectioncore_contract.FeatureTaskLabel("Kubernetes Audit Log(v3)", `Gather kubernetes audit logs and visualize resource modifications.`, enum.LogTypeAudit, 1001, true, googlecloudinspectiontypegroup_contract.GCPK8sClusterInspectionTypes...), coretask.NewSubsequentTaskRefsTaskLabel(inspectioncore_contract.SerializerTaskID.Ref()),
)

Functions ¶

func GenerateK8sAuditQuery ¶

func GenerateK8sAuditQuery(cluster googlecloudk8scommon_contract.GoogleCloudClusterIdentity, auditKindFilter *gcpqueryutil.SetFilterParseResult, namespaceFilter *gcpqueryutil.SetFilterParseResult) string

GenerateK8sAuditQuery constructs a Google Cloud Logging query string for fetching Kubernetes audit logs based on cluster name, kind filters, and namespace filters.

func Register ¶

func Register(registry coreinspection.InspectionTaskRegistry) error

Register registers all tasks related to GKE Kubernetes audit log.

Types ¶

type GCPK8sAuditLogListLogEntriesTaskSetting ¶ added in v0.50.0

type GCPK8sAuditLogListLogEntriesTaskSetting struct{}

func (*GCPK8sAuditLogListLogEntriesTaskSetting) DefaultResourceNames ¶ added in v0.50.0

func (k *GCPK8sAuditLogListLogEntriesTaskSetting) DefaultResourceNames(ctx context.Context) ([]string, error)

DefaultResourceNames implements googlecloudcommon_contract.ListLogEntriesTaskSetting.

func (*GCPK8sAuditLogListLogEntriesTaskSetting) Dependencies ¶ added in v0.50.0

func (k *GCPK8sAuditLogListLogEntriesTaskSetting) Dependencies() []taskid.UntypedTaskReference

Dependencies implements googlecloudcommon_contract.ListLogEntriesTaskSetting.

func (*GCPK8sAuditLogListLogEntriesTaskSetting) Description ¶ added in v0.50.0

func (k *GCPK8sAuditLogListLogEntriesTaskSetting) Description() *googlecloudcommon_contract.ListLogEntriesTaskDescription

Description implements googlecloudcommon_contract.ListLogEntriesTaskSetting.

func (*GCPK8sAuditLogListLogEntriesTaskSetting) LogFilters ¶ added in v0.50.0

func (k *GCPK8sAuditLogListLogEntriesTaskSetting) LogFilters(ctx context.Context, taskMode inspectioncore_contract.InspectionTaskModeType) ([]string, error)

LogFilters implements googlecloudcommon_contract.ListLogEntriesTaskSetting.

func (*GCPK8sAuditLogListLogEntriesTaskSetting) TaskID ¶ added in v0.50.0

func (k *GCPK8sAuditLogListLogEntriesTaskSetting) TaskID() taskid.TaskImplementationID[[]*log.Log]

TaskID implements googlecloudcommon_contract.ListLogEntriesTaskSetting.

func (*GCPK8sAuditLogListLogEntriesTaskSetting) TimePartitionCount ¶ added in v0.50.0

func (k *GCPK8sAuditLogListLogEntriesTaskSetting) TimePartitionCount(ctx context.Context) (int, error)

TimePartitionCount implements googlecloudcommon_contract.ListLogEntriesTaskSetting.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL