aclutil

package
v0.34.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 19, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Wildcard     = "*"
	KafkaCluster = "kafka-cluster"
)
View Source
const (
	ResourceTypeFilterANY              = "any"
	ResourceTypeFilterTOPIC            = "topic"
	ResourceTypeFilterCLUSTER          = "cluster"
	ResourceTypeFilterGROUP            = "group"
	ResourceTypeFilterTRANSACTIONAL_ID = "transactional-id"
)
View Source
const (
	PermissionALLOW = "allow"
	PermissionDENY  = "deny"
	PermissionANY   = "any"
)
View Source
const (
	OperationFilterALL              = "all"
	OperationFilterREAD             = "read"
	OperationFilterWRITE            = "write"
	OperationFilterCREATE           = "create"
	OperationFilterDELETE           = "delete"
	OperationFilterALTER            = "alter"
	OperationFilterDESCRIBE         = "describe"
	OperationFilterDESCRIBE_CONFIGS = "describe-configs"
	OperationFilterALTER_CONFIGS    = "alter-configs"
)
View Source
const (
	PatternTypeFilterLITERAL = "literal"
	PatternTypeFilterPREFIX  = "prefix"
	PatternTypeFilterANY     = "any"
)

Variables

This section is empty.

Functions

func ExecuteACLRuleCreate

func ExecuteACLRuleCreate(req kafkainstanceclient.ApiCreateAclRequest, localizer localize.Localizer, kafkaInstanceName string) error

ExecuteACLRuleCreate makes request to create an ACL rule

func FormatPrincipal

func FormatPrincipal(userID string) string

FormatPrincipal formats the provided principal ID to "User:principal"

func GetMappedOperationFilterValue

func GetMappedOperationFilterValue(operation string) kafkainstanceclient.AclOperationFilter

GetMappedOperationFilterValue gets the mapped operation filter value

func GetMappedPatternTypeFilterValue

func GetMappedPatternTypeFilterValue(patternType string) kafkainstanceclient.AclPatternTypeFilter

GetMappedPatternTypeFilterValue gets the mapped pattern type filter value

func GetMappedPermissionTypeFilterValue

func GetMappedPermissionTypeFilterValue(permission string) kafkainstanceclient.AclPermissionTypeFilter

GetMappedPermissionTypeFilterValue gets the mapped permission type type filter value

func GetMappedResourceTypeFilterValue

func GetMappedResourceTypeFilterValue(resourceType string) kafkainstanceclient.AclResourceTypeFilter

GetMappedResourceTypeFilterValue gets the mapped resource type filter value

func GetOperationFilterMap

func GetOperationFilterMap() map[string]kafkainstanceclient.AclOperationFilter

GetOperationTypeFilterMap gets the mappings for ACL type filters

func GetPatternTypeFilterMap

func GetPatternTypeFilterMap() map[string]kafkainstanceclient.AclPatternTypeFilter

GetPatternTypeFilterMap gets the mappings for ACL pattern type filters

func GetPermissionTypeFilterMap

func GetPermissionTypeFilterMap() map[string]kafkainstanceclient.AclPermissionTypeFilter

GetPermissionTypeFilterMap gets the mappings for ACL permission type filters

func GetResourceName

func GetResourceName(resourceName string) string

GetResourceName returns the name of the resource transformed into a server recognized format

func GetResourceTypeFilterMap

func GetResourceTypeFilterMap() map[string]kafkainstanceclient.AclResourceTypeFilter

GetResourceTypeFilterMap gets the mappings for ACL resource type filters

func GetResourceTypeOperationKeyMap

func GetResourceTypeOperationKeyMap() map[string]string

GetResourceTypeOperationKeyMap gets the mappings for ACL operations

func IsValidResourceOperation

func IsValidResourceOperation(resourceType string, operation string, resourceOperationsMap map[string][]string) (bool, []string)

IsValidResourceOperation checks if the operation is valid, and returns the list valid operations when invalid

func MapACLsToTableRows

func MapACLsToTableRows(bindings []kafkainstanceclient.AclBinding, localizer localize.Localizer) []permissionsRow

MapACLsToTableRows converts a list of ACL bindings into a formatted table for printing

func ValidateAPIError

func ValidateAPIError(httpRes *http.Response, localizer localize.Localizer, err error, operation string, instanceName string) error

ValidateAPIError checks for a HTTP error and maps it to a user friendly error

Types

This section is empty.

Jump to

Keyboard shortcuts

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