def egress()

in python/showcase/showcase/__main__.py [0:0]

• 13 lines of code
• 5 McCabe index (conditional complexity)

def egress(context: Context, message: Message):
    # there is a specific builder for messages to be sent to a Kafka egress ...
    context.send_egress(
        kafka_egress_message(typename="showcase/kafka-egress", topic="my-kafka-topic", key="my-key",
                             value="my-utf8-value"))

    # and a builder for kinesis
    context.send(
        kinesis_egress_message(typename="showcase/kinesis-egress",
                               stream="a-stream",
                               partition_key="key",
                               explicit_hash_key="hash-key",
                               value="a value"))

    # if you've implemented your own egress (it is currently only possible to do with Java)
    # then you can send it a message like this:
    context.send_egress(egress_message_builder(target_typename="showecase/my-custom-egress",
                                               value={"name": "Bob"},
                                               value_type=GREET_JSON_TYPE))