Types & classes — github.com/densumesh/broccoli

CodeHub MCPcopy Create free account

hub / github.com/densumesh/broccoli / types & classes

Types & classes41 in github.com/densumesh/broccoli

⨍ Functions 186◇ Types & classes 41

↓ 81 callersInterfaceBroker

src/brokers/broker.rs:10

↓ 2 callersClassQueueStatus

Struct representing the status of a queue.

src/brokers/management.rs:37

↓ 1 callersClassOptionalInternalBrokerMessage

src/brokers/redis/utils.rs:234

ClassBenchmarkMessage

benches/surrealdb_benchmark.rs:16

ClassBenchmarkMessage

benches/redis_benchmark.rs:9

ClassBenchmarkMessage

benches/amqp_benchmark.rs:9

ClassBenchmarkMessageEntry

benches/surrealdb_benchmark.rs:22

ClassBenchmarkMessageIndex

benches/surrealdb_benchmark.rs:28

EnumBroccoliError

ClassBroccoliQueue

Main queue interface for interacting with the message broker. `BroccoliQueue` provides methods for publishing and consuming messages, as well as proc

src/queue.rs:407

ClassBroccoliQueueBuilder

Builder for configuring and creating a `BroccoliQueue` instance. This struct provides a fluent interface for setting up queue parameters such as retr

src/queue.rs:85

ClassBrokerConfig

src/brokers/broker.rs:143

ClassBrokerMessage

src/brokers/broker.rs:179

Supported message broker implementations.

src/brokers/broker.rs:295

InterfaceBrokerWithManagement

src/brokers/management.rs:33

ClassConsumeOptions

src/queue.rs:218

ClassConsumeOptionsBuilder

src/queue.rs:254

ClassInternalBrokerMessage

src/brokers/broker.rs:214

ClassInternalSurrealDBBrokerFailedMessage

src/brokers/surrealdb/broker.rs:47

ClassInternalSurrealDBBrokerMessage

src/brokers/surrealdb/broker.rs:23

ClassInternalSurrealDBBrokerMessageEntry

src/brokers/surrealdb/broker.rs:39

ClassInternalSurrealDBBrokerQueueIndex

src/brokers/surrealdb/utils.rs:27

ClassJobPayload

examples/publisher.rs:9

ClassJobPayload

examples/consumer.rs:6

EnumMetadataTypes

src/brokers/broker.rs:207

ClassParameters

examples/publisher.rs:17

ClassParameters

examples/consumer.rs:14

ClassPublishOptions

src/queue.rs:315

ClassPublishOptionsBuilder

src/queue.rs:336

InterfaceQueueManagement

Trait for managing the state of broccoli queues.

src/brokers/management.rs:7

Enum representing the type of queue.

src/brokers/management.rs:18

ClassRabbitMQBroker

A message broker implementation for `RabbitMQ`.

src/brokers/rabbitmq/broker.rs:28

ClassRedisBroker

A message broker implementation for Redis.

src/brokers/redis/broker.rs:17

ClassRetriableSurrealDBResult

helper to process results from surrealdb that are retriable

src/brokers/surrealdb/utils.rs:1047

ClassRetryStrategy

Configuration for message retry behavior. This struct defines how failed messages should be handled, including whether they should be retried and how

src/queue.rs:23

ClassSurrealDBBroker

`SurrealDB` state struct

src/brokers/surrealdb/broker.rs:16

ClassSurrealDBConnectionConfig

src/brokers/surrealdb/utils.rs:19

ClassTestMessage

tests/edge_cases.rs:15

ClassTestMessage

tests/management.rs:8

ClassTestMessage

tests/happy_path.rs:16

ClassTestMessage

tests/fairness.rs:15