acl

Documentation

Index

• type ACLAdmin
  • func NewACLAdmin(ctx context.Context, adminClient admin.Client, aclAdminConfig ACLAdminConfig) (*ACLAdmin, error)
  • func (a *ACLAdmin) Create(ctx context.Context) error
  • func (a *ACLAdmin) Delete(ctx context.Context, filter kafka.DeleteACLsFilter) error
• type ACLAdminConfig

Types

type ACLAdmin

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

ACLAdmin executes operations on ACLs by comparing the current ACLs with the desired ACLs.

func NewACLAdmin

func NewACLAdmin(
	ctx context.Context,
	adminClient admin.Client,
	aclAdminConfig ACLAdminConfig,
) (*ACLAdmin, error)

func (*ACLAdmin) Create

func (a *ACLAdmin) Create(ctx context.Context) error

Create creates ACLs that do not already exist based on the ACL config.

func (*ACLAdmin) Delete

func (a *ACLAdmin) Delete(ctx context.Context, filter kafka.DeleteACLsFilter) error

Delete checks if ACLs exist and deletes them if they do.

type ACLAdminConfig

type ACLAdminConfig struct {
	ClusterConfig config.ClusterConfig
	DryRun        bool
	SkipConfirm   bool
	ACLConfig     config.ACLConfig
}

ACLCreatorConfig contains the configuration for an ACL admin.