internal

package
v0.0.0-...-4892902 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

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)

func (*Daemon) Stop

func (d *Daemon) Stop()

type HTTPClient

type HTTPClient struct {
	Client      *http.Client
	URL         string
	HeaderName  string
	HeaderValue string
}

func NewHTTPClient

func NewHTTPClient(url string, headerName string, headerValue string) *HTTPClient

func (*HTTPClient) Post

func (c *HTTPClient) Post(url string, contentType string, body *bytes.Reader) (*http.Response, error)

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
}

Jump to

Keyboard shortcuts

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