kafkaacls

Documentation

Index

• Constants
• Variables
• type IntentsAdminFactoryFunction
• type KafkaIntentsAdmin
  • func NewKafkaIntentsAdmin(kafkaServer otterizev1alpha2.KafkaServerConfig, ...) (KafkaIntentsAdmin, error)
  • func NewKafkaIntentsAdminImpl(kafkaServer otterizev1alpha2.KafkaServerConfig, a sarama.ClusterAdmin, ...) KafkaIntentsAdmin
• type KafkaIntentsAdminImpl
  • func (a *KafkaIntentsAdminImpl) ApplyClientIntents(clientName string, clientNamespace string, intents []otterizev1alpha2.Intent) error
  • func (a *KafkaIntentsAdminImpl) ApplyServerTopicsConf(topicsConf []otterizev1alpha2.TopicConfig) error
  • func (a *KafkaIntentsAdminImpl) Close()
  • func (a *KafkaIntentsAdminImpl) RemoveAllIntents() error
  • func (a *KafkaIntentsAdminImpl) RemoveClientIntents(clientName string, clientNamespace string) error
• type ServersStore
• type ServersStoreImpl
  • func NewServersStore(tlsSourceFiles otterizev1alpha2.TLSSource, enableKafkaACLCreation bool, ...) *ServersStoreImpl
  • func (s *ServersStoreImpl) Add(config *otterizev1alpha2.KafkaServerConfig)
  • func (s *ServersStoreImpl) Exists(serverName string, namespace string) bool
  • func (s *ServersStoreImpl) Get(serverName string, namespace string) (KafkaIntentsAdmin, error)
  • func (s *ServersStoreImpl) MapErr(f func(types.NamespacedName, *otterizev1alpha2.KafkaServerConfig, ...) error) error
  • func (s *ServersStoreImpl) Remove(serverName string, namespace string)
• type TopicToACLList

Constants

const (
	AnonymousUserPrincipalName = "User:ANONYMOUS"
	AnyUserPrincipalName       = "User:*"
)

Variables

var (
	KafkaOperationToAclOperationBMap = bimap.NewBiMapFromMap(kafkaOperationToAclOperation)
)

var (
	ServerSpecNotFound = errors.New("failed getting kafka server connection - server configuration specs not set")
)

Types

type IntentsAdminFactoryFunction

type IntentsAdminFactoryFunction func(serverConfig otterizev1alpha2.KafkaServerConfig, _ otterizev1alpha2.TLSSource, enableKafkaACLCreation bool, enforcementEnabledGlobally bool) (KafkaIntentsAdmin, error)

type KafkaIntentsAdmin

type KafkaIntentsAdmin interface {
	ApplyServerTopicsConf(topicsConf []otterizev1alpha2.TopicConfig) error
	ApplyClientIntents(clientName string, clientNamespace string, intents []otterizev1alpha2.Intent) error
	RemoveClientIntents(clientName string, clientNamespace string) error
	RemoveAllIntents() error
	Close()
}

func NewKafkaIntentsAdmin

func NewKafkaIntentsAdmin(kafkaServer otterizev1alpha2.KafkaServerConfig, defaultTls otterizev1alpha2.TLSSource, enableKafkaACLCreation bool, enforcementEnabledGlobally bool) (KafkaIntentsAdmin, error)

func NewKafkaIntentsAdminImpl

func NewKafkaIntentsAdminImpl(kafkaServer otterizev1alpha2.KafkaServerConfig, a sarama.ClusterAdmin, usernameMapping string, enableKafkaACLCreation bool, enforcementEnabledGlobally bool) KafkaIntentsAdmin

type KafkaIntentsAdminImpl

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

func (*KafkaIntentsAdminImpl) ApplyClientIntents

func (a *KafkaIntentsAdminImpl) ApplyClientIntents(clientName string, clientNamespace string, intents []otterizev1alpha2.Intent) error

func (*KafkaIntentsAdminImpl) ApplyServerTopicsConf

func (a *KafkaIntentsAdminImpl) ApplyServerTopicsConf(topicsConf []otterizev1alpha2.TopicConfig) error

func (*KafkaIntentsAdminImpl) Close

func (a *KafkaIntentsAdminImpl) Close()

func (*KafkaIntentsAdminImpl) RemoveAllIntents

func (a *KafkaIntentsAdminImpl) RemoveAllIntents() error

func (*KafkaIntentsAdminImpl) RemoveClientIntents

func (a *KafkaIntentsAdminImpl) RemoveClientIntents(clientName string, clientNamespace string) error

type ServersStore

type ServersStore interface {
	Add(config *otterizev1alpha2.KafkaServerConfig)
	Remove(serverName string, namespace string)
	Exists(serverName string, namespace string) bool
	Get(serverName string, namespace string) (KafkaIntentsAdmin, error)
	MapErr(f func(types.NamespacedName, *otterizev1alpha2.KafkaServerConfig, otterizev1alpha2.TLSSource) error) error
}

type ServersStoreImpl

type ServersStoreImpl struct {
	IntentsAdminFactoryFunction IntentsAdminFactoryFunction
	// contains filtered or unexported fields
}

func NewServersStore

func NewServersStore(tlsSourceFiles otterizev1alpha2.TLSSource, enableKafkaACLCreation bool, factoryFunc IntentsAdminFactoryFunction, enforcementEnabledGlobally bool) *ServersStoreImpl

func (*ServersStoreImpl) Add

func (s *ServersStoreImpl) Add(config *otterizev1alpha2.KafkaServerConfig)

func (*ServersStoreImpl) Exists

func (s *ServersStoreImpl) Exists(serverName string, namespace string) bool

func (*ServersStoreImpl) Get

func (s *ServersStoreImpl) Get(serverName string, namespace string) (KafkaIntentsAdmin, error)

func (*ServersStoreImpl) MapErr

func (s *ServersStoreImpl) MapErr(f func(types.NamespacedName, *otterizev1alpha2.KafkaServerConfig, otterizev1alpha2.TLSSource) error) error

func (*ServersStoreImpl) Remove

func (s *ServersStoreImpl) Remove(serverName string, namespace string)

type TopicToACLList

type TopicToACLList map[sarama.Resource][]sarama.Acl