Documentation
¶
Index ¶
- Constants
- Variables
- func ClearBacklogCmd(vc *cmdutils.VerbCmd)
- func ClearOffloadDeletionLagCmd(vc *cmdutils.VerbCmd)
- func Command(flagGrouping *cmdutils.FlagGrouping) *cobra.Command
- func GetCompactionThresholdCmd(vc *cmdutils.VerbCmd)
- func GetDispatchRateCmd(vc *cmdutils.VerbCmd)
- func GetMaxConsumersPerSubscriptionCmd(vc *cmdutils.VerbCmd)
- func GetMaxConsumersPerTopicCmd(vc *cmdutils.VerbCmd)
- func GetMaxProducersPerTopicCmd(vc *cmdutils.VerbCmd)
- func GetOffloadDeletionLagCmd(vc *cmdutils.VerbCmd)
- func GetOffloadThresholdCmd(vc *cmdutils.VerbCmd)
- func GetPermissionsCmd(vc *cmdutils.VerbCmd)
- func GetReplicatorDispatchRateCmd(vc *cmdutils.VerbCmd)
- func GetSchemaAutoUpdateStrategyCmd(vc *cmdutils.VerbCmd)
- func GetSchemaValidationEnforcedCmd(vc *cmdutils.VerbCmd)
- func GetSubscribeRateCmd(vc *cmdutils.VerbCmd)
- func GetSubscriptionDispatchRateCmd(vc *cmdutils.VerbCmd)
- func GrantPermissionsCmd(vc *cmdutils.VerbCmd)
- func GrantSubPermissionsCmd(vc *cmdutils.VerbCmd)
- func RevokePermissionsCmd(vc *cmdutils.VerbCmd)
- func RevokeSubPermissionsCmd(vc *cmdutils.VerbCmd)
- func SetCompactionThresholdCmd(vc *cmdutils.VerbCmd)
- func SetDispatchRateCmd(vc *cmdutils.VerbCmd)
- func SetEncryptionRequiredCmd(vc *cmdutils.VerbCmd)
- func SetMaxConsumersPerSubscriptionCmd(vc *cmdutils.VerbCmd)
- func SetMaxConsumersPerTopicCmd(vc *cmdutils.VerbCmd)
- func SetMaxProducersPerTopicCmd(vc *cmdutils.VerbCmd)
- func SetOffloadDeletionLagCmd(vc *cmdutils.VerbCmd)
- func SetOffloadThresholdCmd(vc *cmdutils.VerbCmd)
- func SetReplicatorDispatchRateCmd(vc *cmdutils.VerbCmd)
- func SetSchemaAutoUpdateStrategyCmd(vc *cmdutils.VerbCmd)
- func SetSchemaValidationEnforcedCmd(vc *cmdutils.VerbCmd)
- func SetSubscribeRateCmd(vc *cmdutils.VerbCmd)
- func SetSubscriptionAuthModeCmd(vc *cmdutils.VerbCmd)
- func SetSubscriptionDispatchRateCmd(vc *cmdutils.VerbCmd)
- func TestNamespaceCommands(newVerb func(cmd *cmdutils.VerbCmd), args []string) (out *bytes.Buffer, execErr, nameErr, err error)
- func UnsubscribeCmd(vc *cmdutils.VerbCmd)
Constants ¶
View Source
const MaxBundles = math.MaxInt32
Variables ¶
View Source
var ArgError = cmdutils.Output{
Desc: "the namespace name is not specified or the namespace name is specified more than one",
Out: "[✖] the namespace name is not specified or the namespace name is specified more than one",
}
View Source
var AuthNotEnable = cmdutils.Output{
Desc: "the authorization is not enabled",
Out: "[✖] code: 501 reason: Authorization is not enabled",
}
View Source
var NsErrors = []cmdutils.Output{
{
Desc: "the namespace name is not in the format of <tenant>/<namespace>",
Out: "[✖] The complete name of namespace is invalid. complete name : <namespace-complete-name>",
},
{
Desc: "the tenant name and(or) namespace name is empty",
Out: "[✖] Invalid tenant or namespace. [<tenant>/<namespace>]",
},
{
Desc: "the tenant name contains unsupported special chars. " +
"the alphanumeric (a-zA-Z0-9) and the special chars (-=:.%) is allowed",
Out: "[✖] Tenant name include unsupported special chars. tenant : [<namespace>]",
},
{
Desc: "the namespace name contains unsupported special chars. " +
"the alphanumeric (a-zA-Z0-9) and the special chars (-=:.%) is allowed",
Out: "[✖] Namespace name include unsupported special chars. namespace : [<namespace>]",
},
}
View Source
var NsNotExistError = cmdutils.Output{
Desc: "the specified namespace name does not exist",
Out: "[✖] code: 404 reason: Namespace does not exist",
}
Functions ¶
func ClearBacklogCmd ¶
func GetDispatchRateCmd ¶
func GetOffloadThresholdCmd ¶
func GetPermissionsCmd ¶
func GetSubscribeRateCmd ¶
func GrantPermissionsCmd ¶
func GrantSubPermissionsCmd ¶
func RevokePermissionsCmd ¶
func RevokeSubPermissionsCmd ¶
func SetDispatchRateCmd ¶
func SetOffloadThresholdCmd ¶
func SetSubscribeRateCmd ¶
func TestNamespaceCommands ¶
func UnsubscribeCmd ¶
Types ¶
This section is empty.
Source Files
¶
- clear_backlog.go
- clear_offload_deletion_lag.go
- create.go
- delete.go
- delete_ns_anti_affinity_group.go
- errors_ns.go
- get_anti_affinity_ns.go
- get_backlog_quota.go
- get_compaction_threshold.go
- get_dispatch_rate.go
- get_max_consumers_per_subscription.go
- get_max_consumers_per_topic.go
- get_max_producers_per_topic.go
- get_message_ttl.go
- get_ns_anti_affinity_group.go
- get_offload_deletion_lag.go
- get_offload_threshold.go
- get_persistence.go
- get_replication_clusters.go
- get_replicator_dispatch_rate.go
- get_retention.go
- get_schema_autoupdate_strategy.go
- get_schema_valudation_enforce.go
- get_subscribe_rate.go
- get_subscription_dispatch_rate.go
- grant_permission.go
- grant_subscription_permission.go
- list.go
- namespace.go
- permissions.go
- policies.go
- remove_backlog_quota.go
- revoke_permission.go
- revoke_subscription_permission.go
- set_backlog_quota.go
- set_compaction_threshold.go
- set_deduplication_status.go
- set_dispatch_rate.go
- set_encryption_require.go
- set_max_consumers_per_subscription.go
- set_max_consumers_per_topic.go
- set_max_producers_per_topic.go
- set_message_ttl.go
- set_ns_anti_affinity_group.go
- set_offload_deletion_lag.go
- set_offload_threshold.go
- set_persistence.go
- set_replication_clusters.go
- set_replicator_dispatch_rate.go
- set_retention.go
- set_schema_autoupdate_strategy.go
- set_schema_validation_enforce.go
- set_subscribe_rate.go
- set_subscription_auth_mode.go
- set_subscription_dispatch_rate.go
- split_bundle.go
- test_help.go
- topics.go
- unload.go
- unsubscribe.go
Click to show internal directories.
Click to hide internal directories.