client

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Sep 8, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient

func NewClient(cfg *Config) (*kadm.Client, error)

Types

type ACLResult

type ACLResult struct {
	Principal  string
	Host       string
	Type       kmsg.ACLResourceType
	Name       string
	Pattern    kadm.ACLPattern
	Operation  kadm.ACLOperation
	Permission kmsg.ACLPermissionType
	Err        error
}

func CreateACLs

func CreateACLs(ctx context.Context, c *kadm.Client, acl *kadm.ACLBuilder) ([]ACLResult, error)

func DeleteACLs

func DeleteACLs(ctx context.Context, c *kadm.Client, acl *kadm.ACLBuilder) (res []ACLResult, err error)

func ReadACLs

func ReadACLs(ctx context.Context, c *kadm.Client, acl *kadm.ACLBuilder) (res []ACLResult, err error)

type Config

type Config struct {
	BootstrapServers []string
	IAM              *IAM
}

type IAM

type IAM struct {
	RoleArn     string
	SessionName string
	Region      string
}

Jump to

Keyboard shortcuts

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