rest

type AuditAction[D any] func(ctx context.Context, workerIndex int, data D, token string) error

type AuditClient[A any] interface {
	Start(ctx context.Context) error
	Stop(stopTimeout time.Duration) error
	Audit(data A) error
	TotalLost() int32
}

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

type AuthAuditClient struct {
	*BaseAuditClient[*models.AuthAuditDTO]
}

type BaseAuditClient[D any] struct {
	// contains filtered or unexported fields
}

type DataAuditClient struct {
	*BaseAuditClient[*models.DataAuditDTO]
}