Documentation
¶
Index ¶
- Constants
- func ExecuteACLRuleCreate(req kafkainstanceclient.ApiCreateAclRequest, localizer localize.Localizer, ...) error
- func FormatPrincipal(userID string) string
- func GetMappedOperationFilterValue(operation string) kafkainstanceclient.AclOperationFilter
- func GetMappedPatternTypeFilterValue(patternType string) kafkainstanceclient.AclPatternTypeFilter
- func GetMappedPermissionTypeFilterValue(permission string) kafkainstanceclient.AclPermissionTypeFilter
- func GetMappedResourceTypeFilterValue(resourceType string) kafkainstanceclient.AclResourceTypeFilter
- func GetOperationFilterMap() map[string]kafkainstanceclient.AclOperationFilter
- func GetPatternTypeFilterMap() map[string]kafkainstanceclient.AclPatternTypeFilter
- func GetPermissionTypeFilterMap() map[string]kafkainstanceclient.AclPermissionTypeFilter
- func GetResourceName(resourceName string) string
- func GetResourceTypeFilterMap() map[string]kafkainstanceclient.AclResourceTypeFilter
- func GetResourceTypeOperationKeyMap() map[string]string
- func IsValidResourceOperation(resourceType string, operation string, ...) (bool, []string)
- func MapACLsToTableRows(bindings []kafkainstanceclient.AclBinding, localizer localize.Localizer) []permissionsRow
- func ValidateAPIError(httpRes *http.Response, localizer localize.Localizer, err error, ...) error
Constants ¶
const ( Wildcard = "*" KafkaCluster = "kafka-cluster" )
const ( ResourceTypeFilterANY = "any" ResourceTypeFilterTOPIC = "topic" ResourceTypeFilterCLUSTER = "cluster" ResourceTypeFilterGROUP = "group" ResourceTypeFilterTRANSACTIONAL_ID = "transactional-id" )
const ( PermissionALLOW = "allow" PermissionDENY = "deny" PermissionANY = "any" )
const ( OperationFilterALL = "all" OperationFilterREAD = "read" OperationFilterWRITE = "write" OperationFilterCREATE = "create" OperationFilterDELETE = "delete" OperationFilterALTER = "alter" OperationFilterDESCRIBE = "describe" OperationFilterDESCRIBE_CONFIGS = "describe-configs" OperationFilterALTER_CONFIGS = "alter-configs" )
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 ¶
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 ¶
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 ¶
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
Types ¶
This section is empty.