Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChangesProcessor ¶
type ChangesProcessor struct { Logger hclog.Logger // contains filtered or unexported fields }
func (*ChangesProcessor) CalculateNewUserEffectiveRoles ¶
func (c *ChangesProcessor) CalculateNewUserEffectiveRoles(futureDB *io.MemoryStoreTxn, userUUID pkg.UserUUID, roles []pkg.RoleName) ([]authz.EffectiveRoleResult, error)
func (*ChangesProcessor) UpdateUserEffectiveRoles ¶
func (c *ChangesProcessor) UpdateUserEffectiveRoles(futureDB *io.MemoryStoreTxn, users map[pkg.UserUUID]struct{}, roles map[pkg.RoleName]struct{}) error
type Daemon ¶
type Daemon struct {
// contains filtered or unexported fields
}
func NewDaemon ¶
func NewDaemon(kafkaCFG sharedkafka.BrokerConfig, topicName string, runConsumerID string, parentLogger hclog.Logger) (*Daemon, error)
func (*Daemon) Run ¶
func (d *Daemon) Run(userEffectiveRoleProcessor UserEffectiveRoleProcessor)
type HTTPClient ¶
func NewHTTPClient ¶
func NewHTTPClient(url string, headerName string, headerValue string) *HTTPClient
func (*HTTPClient) ProceedUserEffectiveRole ¶
func (c *HTTPClient) ProceedUserEffectiveRole(userEffectiveRoles pkg.UserEffectiveRoles) error
type Hooker ¶
type Hooker struct { Logger hclog.Logger // contains filtered or unexported fields }
func (*Hooker) RegisterHooks ¶
func (h *Hooker) RegisterHooks(memstorage *sharedio.MemoryStore)
type PrintProceeder ¶
type PrintProceeder struct {
Logger hclog.Logger
}
func (PrintProceeder) ProceedUserEffectiveRole ¶
func (c PrintProceeder) ProceedUserEffectiveRole(newUsersEffectiveRoles pkg.UserEffectiveRoles) error
type UserEffectiveRoleProcessor ¶
type UserEffectiveRoleProcessor interface {
ProceedUserEffectiveRole(userEffectiveRoles pkg.UserEffectiveRoles) error
}
Click to show internal directories.
Click to hide internal directories.