eventdriver

package

v0.3.0 Latest Latest Go to latest Published: Aug 18, 2025 License: GPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var Config = config.GetConfig()

View Source

var Db = dbdriver.GetDriver()

View Source

var Driver = new(Events)

View Source

var Kafka = kafkadriver.GetDriver()

View Source

var Tracer = otel.Tracer("eventsdriver")

This section is empty.

type Events struct {
}

func GetDriver() *Events

func (e *Events) AccessRequestApprovalError(ctx context.Context, data models.AccessRequest, provider models.ProviderConfig, err error) error

func (e *Events) AccessRequestApproved(ctx context.Context, data models.AccessRequest) error

func (e *Events) AccessRequestCreated(ctx context.Context, data models.AccessRequest) error

func (e *Events) AccessRequestDeleted(ctx context.Context, data models.AccessRequest) error

func (e *Events) AccessRequestExpireError(ctx context.Context, data models.AccessRequest, provider models.ProviderConfig, err error) error

func (e *Events) AccessRequestExpired(ctx context.Context, data models.AccessRequest) error

func (e *Events) NewDriver() *Events

Setup Initialize Kafka client

func (e *Events) PermissionDenied(ctx context.Context, sub string, grp []string, obj string, act string) error

func (e *Events) UserLoggedIn(ctx context.Context, claims models.ClaimsMap) error