Skip to content

Commit

Permalink
Add documentation for queue statistics
Browse files Browse the repository at this point in the history
  • Loading branch information
satabin committed Jul 4, 2024
1 parent d854935 commit b551415
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 0 deletions.
1 change: 1 addition & 0 deletions docs/getting-started/directory.conf
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ laika.navigationOrder = [
queues.md
publishing.md
subscribing.md
stats.md
administration.md
serialization.md
]
2 changes: 2 additions & 0 deletions docs/getting-started/queues.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,8 @@ There are several views possible on a queue:

- as a `QueuePublisher` when you only need to [publish messages](publishing.md) to an existing queue.
- as a `QueueSubscriber` when you only need to [subscribe](subscribing.md) to an existing queue.
- as a `QueueStatistics` when you only need to [gather queue statistics](stats.md) from an existing queue.
- as a `QueueSubscriber` when you only need to [subscribe](subscribing.md) to an existing queue.
- as a `QueueAdministration` when you need to [manage](administration.md) queues (creation, deletion, ...).

The entry point is the `QueueClient` factory for each underlying queue system.
Expand Down
2 changes: 2 additions & 0 deletions docs/systems/index.md
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,15 @@ import com.commercetools.queue.{
QueueClient,
QueueAdministration,
QueuePublisher,
QueueStatistics,
QueueSubscriber,
Serializer
}
import com.commercetools.queue.testkit.QueueClientSuite

class MyQueueClient[F[_]] extends QueueClient[F] {
def administration: QueueAdministration[F] = ???
def statistics(name: String): QueueStatistics[F] = ???
def publish[T: Serializer](name: String): QueuePublisher[F,T] = ???
def subscribe[T: Deserializer](name: String): QueueSubscriber[F,T] = ???

Expand Down

0 comments on commit b551415

Please sign in to comment.