Index

_

_Payload (class in esgf_core_utils.models.kafka.events)

A

add() (esgf_core_utils.models.auth.egi.EGIAuth method) (esgf_core_utils.models.auth.egi.Nodes method) (esgf_core_utils.models.auth.egi.Projects method) Auth (class in esgf_core_utils.models.kafka.events) auth (esgf_core_utils.models.kafka.events.Metadata attribute) auth_policy_id (esgf_core_utils.models.kafka.events.Auth attribute)

AuthorizationException authorize() (esgf_core_utils.models.auth.egi.EGIAuth method) (esgf_core_utils.models.auth.egi.Nodes method) (esgf_core_utils.models.auth.egi.Projects method) authorize_href() (esgf_core_utils.models.auth.egi.Nodes method) auto_offset_reset (esgf_core_utils.models.kafka.config.KafkaConsumerConfig attribute)

B

BaseProducer (class in esgf_core_utils.models.kafka.producer)

bootstrap_servers (esgf_core_utils.models.kafka.config.KafkaConfig attribute)

C

check_debug() (esgf_core_utils.settings.kafka.consumer.ConsumerSettings method) client_id (esgf_core_utils.models.kafka.config.KafkaConfig attribute) (esgf_core_utils.models.kafka.events.RequesterData attribute) collection_id (esgf_core_utils.models.kafka.events._Payload attribute)

config (esgf_core_utils.settings.kafka.consumer.ConsumerSettings attribute) (esgf_core_utils.settings.kafka.producer.ProducerSettings attribute) consumer (esgf_core_utils.models.kafka.consumer.KafkaConsumer attribute) ConsumerSettings (class in esgf_core_utils.settings.kafka.consumer) CreatePayload (class in esgf_core_utils.models.kafka.events)

D

Data (class in esgf_core_utils.models.kafka.events) data (esgf_core_utils.models.kafka.events.KafkaEvent attribute) debug (esgf_core_utils.models.kafka.config.KafkaConsumerConfig attribute) (esgf_core_utils.settings.kafka.consumer.ConsumerSettings attribute) detail (esgf_core_utils.models.exceptions.AuthorizationException attribute) (esgf_core_utils.models.exceptions.ExpectedExtensionsMissingException attribute) (esgf_core_utils.models.exceptions.ItemAlreadyExistsException attribute) (esgf_core_utils.models.exceptions.ItemDoesNotExistException attribute) (esgf_core_utils.models.exceptions.OperationNotPermittedException attribute) (esgf_core_utils.models.exceptions.RFC9457Exception attribute) (esgf_core_utils.models.exceptions.STACValidationException attribute) (esgf_core_utils.models.exceptions.UnexpectedExtensionException attribute) (esgf_core_utils.models.exceptions.UnknownException attribute) (esgf_core_utils.models.kafka.events.Error attribute)

DummyProducer (class in esgf_core_utils.models.kafka.producer)

E

EGIAuth (class in esgf_core_utils.models.auth.egi) enable_auto_commit (esgf_core_utils.models.kafka.config.KafkaConsumerConfig attribute) enable_auto_offset_store (esgf_core_utils.models.kafka.config.KafkaConsumerConfig attribute) Error (class in esgf_core_utils.models.kafka.events) error (esgf_core_utils.models.kafka.events.KafkaErrorEvent attribute) error() (esgf_core_utils.models.kafka.producer.KafkaProducer method) error_topic (esgf_core_utils.settings.kafka.producer.ProducerSettings attribute) esgf_core_utils module esgf_core_utils.models module esgf_core_utils.models.auth module esgf_core_utils.models.auth.egi module esgf_core_utils.models.exceptions module esgf_core_utils.models.kafka module

esgf_core_utils.models.kafka.config module esgf_core_utils.models.kafka.consumer module esgf_core_utils.models.kafka.events module esgf_core_utils.models.kafka.message_processor module esgf_core_utils.models.kafka.producer module esgf_core_utils.settings module esgf_core_utils.settings.kafka module esgf_core_utils.settings.kafka.consumer module esgf_core_utils.settings.kafka.producer module event_id (esgf_core_utils.models.kafka.events.Metadata attribute) ExpectedExtensionsMissingException

G

group_id (esgf_core_utils.models.kafka.config.KafkaConsumerConfig attribute)

I

id (esgf_core_utils.models.auth.egi.Node attribute) (esgf_core_utils.models.auth.egi.Project attribute) ingest() (esgf_core_utils.models.kafka.message_processor.MessageProcessor method) instance (esgf_core_utils.models.exceptions.AuthorizationException attribute) (esgf_core_utils.models.exceptions.ItemAlreadyExistsException attribute) (esgf_core_utils.models.exceptions.ItemDoesNotExistException attribute) (esgf_core_utils.models.exceptions.RFC9457Exception attribute) (esgf_core_utils.models.exceptions.UnknownException attribute) (esgf_core_utils.models.kafka.events.Error attribute)

iss (esgf_core_utils.models.kafka.events.RequesterData attribute) item (esgf_core_utils.models.exceptions.ItemAlreadyExistsException attribute) (esgf_core_utils.models.exceptions.ItemDoesNotExistException attribute) (esgf_core_utils.models.kafka.events.CreatePayload attribute) (esgf_core_utils.models.kafka.events.UpdatePayload attribute) item_id (esgf_core_utils.models.kafka.events.PatchPayload attribute) (esgf_core_utils.models.kafka.events.UpdatePayload attribute) ItemAlreadyExistsException ItemDoesNotExistException

K

KafkaConfig (class in esgf_core_utils.models.kafka.config) KafkaConsumer (class in esgf_core_utils.models.kafka.consumer) KafkaConsumerConfig (class in esgf_core_utils.models.kafka.config)

KafkaErrorEvent (class in esgf_core_utils.models.kafka.events) KafkaEvent (class in esgf_core_utils.models.kafka.events) KafkaProducer (class in esgf_core_utils.models.kafka.producer)

L

log_level (esgf_core_utils.models.kafka.config.KafkaConsumerConfig attribute)

logger (in module esgf_core_utils.models.auth.egi) (in module esgf_core_utils.models.kafka.producer)

M

message_processor (esgf_core_utils.models.kafka.consumer.KafkaConsumer attribute) MessageProcessor (class in esgf_core_utils.models.kafka.message_processor) Metadata (class in esgf_core_utils.models.kafka.events) metadata (esgf_core_utils.models.kafka.events.KafkaEvent attribute) method (esgf_core_utils.models.kafka.events.CreatePayload attribute) (esgf_core_utils.models.kafka.events.PatchPayload attribute) (esgf_core_utils.models.kafka.events.UpdatePayload attribute) MissingPermissionException model_config (esgf_core_utils.models.kafka.config.KafkaConfig attribute) (esgf_core_utils.settings.kafka.consumer.ConsumerSettings attribute) (esgf_core_utils.settings.kafka.producer.ProducerSettings attribute) module esgf_core_utils esgf_core_utils.models esgf_core_utils.models.auth esgf_core_utils.models.auth.egi esgf_core_utils.models.exceptions esgf_core_utils.models.kafka esgf_core_utils.models.kafka.config esgf_core_utils.models.kafka.consumer esgf_core_utils.models.kafka.events esgf_core_utils.models.kafka.message_processor esgf_core_utils.models.kafka.producer esgf_core_utils.settings esgf_core_utils.settings.kafka esgf_core_utils.settings.kafka.consumer esgf_core_utils.settings.kafka.producer

N

Node (class in esgf_core_utils.models.auth.egi) Nodes (class in esgf_core_utils.models.auth.egi)

nodes (esgf_core_utils.models.auth.egi.EGIAuth attribute) (esgf_core_utils.models.auth.egi.Nodes attribute)

O

OperationNotPermittedException

P

package (esgf_core_utils.models.kafka.events.Publisher attribute) patch (esgf_core_utils.models.kafka.events.PatchPayload attribute) PatchPayload (class in esgf_core_utils.models.kafka.events) payload (esgf_core_utils.models.kafka.events.Data attribute) produce() (esgf_core_utils.models.kafka.producer.BaseProducer method) (esgf_core_utils.models.kafka.producer.DummyProducer method) (esgf_core_utils.models.kafka.producer.KafkaProducer method)

producer (esgf_core_utils.models.kafka.producer.KafkaProducer attribute) ProducerSettings (class in esgf_core_utils.settings.kafka.producer) Project (class in esgf_core_utils.models.auth.egi) Projects (class in esgf_core_utils.models.auth.egi) projects (esgf_core_utils.models.auth.egi.EGIAuth attribute) (esgf_core_utils.models.auth.egi.Projects attribute) Publisher (class in esgf_core_utils.models.kafka.events) publisher (esgf_core_utils.models.kafka.events.Metadata attribute)

R

regex (esgf_core_utils.models.auth.egi.EGIAuth attribute) request_id (esgf_core_utils.models.kafka.events.Metadata attribute) requester_data (esgf_core_utils.models.auth.egi.EGIAuth attribute) (esgf_core_utils.models.kafka.events.Auth attribute) RequesterData (class in esgf_core_utils.models.kafka.events)

RFC9457Exception role (esgf_core_utils.models.exceptions.MissingPermissionException attribute) Role (in module esgf_core_utils.models.auth.egi) roles (esgf_core_utils.models.auth.egi.Node attribute) (esgf_core_utils.models.auth.egi.Project attribute)

S

sasl_mechanism (esgf_core_utils.models.kafka.config.KafkaConfig attribute) sasl_password (esgf_core_utils.models.kafka.config.KafkaConfig attribute) sasl_username (esgf_core_utils.models.kafka.config.KafkaConfig attribute) schema_version (esgf_core_utils.models.kafka.events.Metadata attribute) security_protocol (esgf_core_utils.models.kafka.config.KafkaConfig attribute) session_timeout_ms (esgf_core_utils.models.kafka.config.KafkaConsumerConfig attribute) settings (esgf_core_utils.models.kafka.consumer.KafkaConsumer attribute) (esgf_core_utils.models.kafka.producer.KafkaProducer attribute) split_topics() (esgf_core_utils.settings.kafka.consumer.ConsumerSettings class method) STACValidationException start() (esgf_core_utils.models.kafka.consumer.KafkaConsumer method) status (esgf_core_utils.models.kafka.events.Error attribute)

status_code (esgf_core_utils.models.exceptions.AuthorizationException attribute) (esgf_core_utils.models.exceptions.ExpectedExtensionsMissingException attribute) (esgf_core_utils.models.exceptions.ItemAlreadyExistsException attribute) (esgf_core_utils.models.exceptions.ItemDoesNotExistException attribute) (esgf_core_utils.models.exceptions.OperationNotPermittedException attribute) (esgf_core_utils.models.exceptions.RFC9457Exception attribute) (esgf_core_utils.models.exceptions.STACValidationException attribute) (esgf_core_utils.models.exceptions.UnexpectedExtensionException attribute) (esgf_core_utils.models.exceptions.UnknownException attribute) sub (esgf_core_utils.models.kafka.events.RequesterData attribute) success() (esgf_core_utils.models.kafka.producer.KafkaProducer method) success_topic (esgf_core_utils.settings.kafka.producer.ProducerSettings attribute)

T

target (esgf_core_utils.models.exceptions.MissingPermissionException attribute) time (esgf_core_utils.models.kafka.events.Metadata attribute) timeout (esgf_core_utils.settings.kafka.consumer.ConsumerSettings attribute) title (esgf_core_utils.models.exceptions.AuthorizationException attribute) (esgf_core_utils.models.exceptions.ExpectedExtensionsMissingException attribute) (esgf_core_utils.models.exceptions.ItemAlreadyExistsException attribute) (esgf_core_utils.models.exceptions.ItemDoesNotExistException attribute) (esgf_core_utils.models.exceptions.OperationNotPermittedException attribute) (esgf_core_utils.models.exceptions.RFC9457Exception attribute) (esgf_core_utils.models.exceptions.STACValidationException attribute) (esgf_core_utils.models.exceptions.UnexpectedExtensionException attribute) (esgf_core_utils.models.exceptions.UnknownException attribute) (esgf_core_utils.models.kafka.events.Error attribute)

topics (esgf_core_utils.settings.kafka.consumer.ConsumerSettings attribute) type (esgf_core_utils.models.exceptions.AuthorizationException attribute) (esgf_core_utils.models.exceptions.ExpectedExtensionsMissingException attribute) (esgf_core_utils.models.exceptions.ItemAlreadyExistsException attribute) (esgf_core_utils.models.exceptions.ItemDoesNotExistException attribute) (esgf_core_utils.models.exceptions.MissingPermissionException attribute) (esgf_core_utils.models.exceptions.OperationNotPermittedException attribute) (esgf_core_utils.models.exceptions.RFC9457Exception attribute) (esgf_core_utils.models.exceptions.STACValidationException attribute) (esgf_core_utils.models.exceptions.UnexpectedExtensionException attribute) (esgf_core_utils.models.exceptions.UnknownException attribute) (esgf_core_utils.models.kafka.events.Data attribute) (esgf_core_utils.models.kafka.events.Error attribute)

U

UnexpectedExtensionException

UnknownException UpdatePayload (class in esgf_core_utils.models.kafka.events)

V

version (esgf_core_utils.models.kafka.events.Publisher attribute)