neuroevolution_behavioral_events (macula_neuroevolution v0.29.0)

View Source

Behavioral event constructors for neuroevolution.

This module provides helper functions to construct properly-formed behavioral events. All events include standard metadata and follow the behavioral naming conventions (past tense, domain language).

Usage

   Event = neuroevolution_behavioral_events:offspring_born(#{
       individual_id => IndId,
       parent_ids => [P1, P2],
       generation => 42,
       species_id => SpeciesId,
       population_id => PopId
   }),
   neuroevolution_lineage_events:persist_event(Event, State).

Summary

Types

behavioral_event/0
birth_event/0
breeding_event/0
controller_event/0
death_event/0
fitness/0
fitness_event/0
generation/0
generation_event/0
individual_id/0
lifecycle_event/0
mutation_event/0
population_id/0
species_event/0
species_id/0
timestamp/0

Functions

activation_changed(Data)

Create activation_changed event.

bias_perturbed(Data)

Create bias_perturbed event.

breakthrough_achieved(Data)

Create breakthrough_achieved event.

champion_crowned(Data)

Create champion_crowned event.

clone_produced(Data)

Create clone_produced event.

connection_added(Data)

Create connection_added event.

connection_removed(Data)

Create connection_removed event.

controller_adjusted(Data)

Create controller_adjusted event.

crossover_performed(Data)

Create crossover_performed event.

evaluation_timeout(Data)

Create evaluation_timeout event.

event_to_map(Event)

Convert an event record to a map for serialization.

fertility_waned(Data)

Create fertility_waned event.

fitness_declined(Data)

Create fitness_declined event.

fitness_evaluated(Data)

Create fitness_evaluated event.

fitness_improved(Data)

Create fitness_improved event.

generation_completed(Data)

Create generation_completed event.

immigrant_arrived(Data)

Create immigrant_arrived event.

individual_culled(Data)

Create individual_culled event.

individual_matured(Data)

Create individual_matured event.

individual_perished(Data)

Create individual_perished event.

lifespan_expired(Data)

Create lifespan_expired event.

lineage_diverged(Data)

Create lineage_diverged event.

lineage_ended(Data)

Create lineage_ended event.

make_meta(Emitter)

Create event metadata with default values.

make_meta(Emitter, Opts)

Create event metadata with options.

mating_occurred(Data)

Create mating_occurred event.

mutation_applied(Data)

Create mutation_applied event.

neuron_added(Data)

Create neuron_added event.

neuron_removed(Data)

Create neuron_removed event.

offspring_born(Data)

Create offspring_born event.

pioneer_spawned(Data)

Create pioneer_spawned event.

population_initialized(Data)

Create population_initialized event.

population_terminated(Data)

Create population_terminated event.

silo_activated(Data)

Create silo_activated event.

silo_deactivated(Data)

Create silo_deactivated event.

species_emerged(Data)

Create species_emerged event.

stagnation_detected(Data)

Create stagnation_detected event.

stream_id(Type, Id)

Generate stream ID for an entity.

weight_perturbed(Data)

Create weight_perturbed event.

Types

behavioral_event/0

-type behavioral_event() ::
          birth_event() |
          death_event() |
          mutation_event() |
          fitness_event() |
          generation_event() |
          species_event() |
          breeding_event() |
          lifecycle_event() |
          controller_event().

birth_event/0

-type birth_event() ::
          #offspring_born{meta ::
                              #event_meta{event_id :: binary(),
                                          correlation_id :: binary() | undefined,
                                          causation_id :: binary() | undefined,
                                          timestamp :: timestamp(),
                                          version :: pos_integer(),
                                          emitter :: atom()},
                          individual_id :: individual_id(),
                          parent_ids :: [individual_id()],
                          generation :: generation(),
                          species_id :: species_id(),
                          population_id :: population_id(),
                          genome_hash :: binary(),
                          initial_fitness :: fitness() | undefined} |
          #pioneer_spawned{meta ::
                               #event_meta{event_id :: binary(),
                                           correlation_id :: binary() | undefined,
                                           causation_id :: binary() | undefined,
                                           timestamp :: timestamp(),
                                           version :: pos_integer(),
                                           emitter :: atom()},
                           individual_id :: individual_id(),
                           population_id :: population_id(),
                           species_id :: species_id(),
                           generation :: generation(),
                           genome_hash :: binary()} |
          #clone_produced{meta ::
                              #event_meta{event_id :: binary(),
                                          correlation_id :: binary() | undefined,
                                          causation_id :: binary() | undefined,
                                          timestamp :: timestamp(),
                                          version :: pos_integer(),
                                          emitter :: atom()},
                          individual_id :: individual_id(),
                          parent_id :: individual_id(),
                          generation :: generation(),
                          species_id :: species_id(),
                          population_id :: population_id(),
                          mutation_applied :: boolean()} |
          #immigrant_arrived{meta ::
                                 #event_meta{event_id :: binary(),
                                             correlation_id :: binary() | undefined,
                                             causation_id :: binary() | undefined,
                                             timestamp :: timestamp(),
                                             version :: pos_integer(),
                                             emitter :: atom()},
                             individual_id :: individual_id(),
                             source_population_id :: population_id(),
                             target_population_id :: population_id(),
                             source_species_id :: species_id(),
                             target_species_id :: species_id(),
                             fitness :: fitness()}.

breeding_event/0

-type breeding_event() ::
          #mating_occurred{meta ::
                               #event_meta{event_id :: binary(),
                                           correlation_id :: binary() | undefined,
                                           causation_id :: binary() | undefined,
                                           timestamp :: timestamp(),
                                           version :: pos_integer(),
                                           emitter :: atom()},
                           parent_a_id :: individual_id(),
                           parent_b_id :: individual_id(),
                           offspring_ids :: [individual_id()],
                           crossover_method :: atom(),
                           compatibility_distance :: float(),
                           relatedness_coefficient :: float()} |
          #crossover_performed{meta ::
                                   #event_meta{event_id :: binary(),
                                               correlation_id :: binary() | undefined,
                                               causation_id :: binary() | undefined,
                                               timestamp :: timestamp(),
                                               version :: pos_integer(),
                                               emitter :: atom()},
                               parent_a_id :: individual_id(),
                               parent_b_id :: individual_id(),
                               offspring_id :: individual_id(),
                               crossover_point :: non_neg_integer() | multiple,
                               genes_from_a :: non_neg_integer(),
                               genes_from_b :: non_neg_integer()}.

controller_event/0

-type controller_event() ::
          #controller_adjusted{meta ::
                                   #event_meta{event_id :: binary(),
                                               correlation_id :: binary() | undefined,
                                               causation_id :: binary() | undefined,
                                               timestamp :: timestamp(),
                                               version :: pos_integer(),
                                               emitter :: atom()},
                               controller_id :: binary(),
                               population_id :: population_id(),
                               adjustments :: #{atom() => float()},
                               trigger :: stagnation | diversity_crisis | breakthrough | scheduled} |
          #silo_activated{meta ::
                              #event_meta{event_id :: binary(),
                                          correlation_id :: binary() | undefined,
                                          causation_id :: binary() | undefined,
                                          timestamp :: timestamp(),
                                          version :: pos_integer(),
                                          emitter :: atom()},
                          silo_type :: atom(),
                          realm :: binary(),
                          config :: map()} |
          #silo_deactivated{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            silo_type :: atom(),
                            realm :: binary(),
                            reason :: manual | dependency_removed | error}.

death_event/0

-type death_event() ::
          #individual_culled{meta ::
                                 #event_meta{event_id :: binary(),
                                             correlation_id :: binary() | undefined,
                                             causation_id :: binary() | undefined,
                                             timestamp :: timestamp(),
                                             version :: pos_integer(),
                                             emitter :: atom()},
                             individual_id :: individual_id(),
                             population_id :: population_id(),
                             species_id :: species_id(),
                             final_fitness :: fitness(),
                             age_generations :: non_neg_integer(),
                             cause :: selection | stagnation | overcrowding,
                             lineage_depth :: non_neg_integer()} |
          #lifespan_expired{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            individual_id :: individual_id(),
                            population_id :: population_id(),
                            age_generations :: non_neg_integer(),
                            lifecycle_stage :: senescent,
                            peak_fitness :: fitness(),
                            offspring_count :: non_neg_integer()} |
          #individual_perished{meta ::
                                   #event_meta{event_id :: binary(),
                                               correlation_id :: binary() | undefined,
                                               causation_id :: binary() | undefined,
                                               timestamp :: timestamp(),
                                               version :: pos_integer(),
                                               emitter :: atom()},
                               individual_id :: individual_id(),
                               population_id :: population_id(),
                               cause :: evaluation_crash | simulation_death | timeout,
                               generation :: generation()}.

fitness/0

-type fitness() :: float().

fitness_event/0

-type fitness_event() ::
          #fitness_evaluated{meta ::
                                 #event_meta{event_id :: binary(),
                                             correlation_id :: binary() | undefined,
                                             causation_id :: binary() | undefined,
                                             timestamp :: timestamp(),
                                             version :: pos_integer(),
                                             emitter :: atom()},
                             individual_id :: individual_id(),
                             population_id :: population_id(),
                             fitness :: fitness(),
                             fitness_components :: #{atom() => float()},
                             evaluation_duration_ms :: non_neg_integer(),
                             generation :: generation()} |
          #fitness_improved{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            individual_id :: individual_id(),
                            population_id :: population_id(),
                            previous_fitness :: fitness(),
                            new_fitness :: fitness(),
                            improvement :: float(),
                            generation :: generation()} |
          #fitness_declined{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            individual_id :: individual_id(),
                            population_id :: population_id(),
                            previous_fitness :: fitness(),
                            new_fitness :: fitness(),
                            decline :: float(),
                            generation :: generation()} |
          #champion_crowned{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            individual_id :: individual_id(),
                            population_id :: population_id(),
                            fitness :: fitness(),
                            previous_champion_id :: individual_id() | undefined,
                            previous_champion_fitness :: fitness() | undefined,
                            generation :: generation()} |
          #evaluation_timeout{meta ::
                                  #event_meta{event_id :: binary(),
                                              correlation_id :: binary() | undefined,
                                              causation_id :: binary() | undefined,
                                              timestamp :: timestamp(),
                                              version :: pos_integer(),
                                              emitter :: atom()},
                              individual_id :: individual_id(),
                              population_id :: population_id(),
                              timeout_ms :: non_neg_integer(),
                              generation :: generation()} |
          #stagnation_detected{meta ::
                                   #event_meta{event_id :: binary(),
                                               correlation_id :: binary() | undefined,
                                               causation_id :: binary() | undefined,
                                               timestamp :: timestamp(),
                                               version :: pos_integer(),
                                               emitter :: atom()},
                               population_id :: population_id(),
                               generations_stagnant :: non_neg_integer(),
                               best_fitness :: fitness(),
                               generation :: generation()} |
          #breakthrough_achieved{meta ::
                                     #event_meta{event_id :: binary(),
                                                 correlation_id :: binary() | undefined,
                                                 causation_id :: binary() | undefined,
                                                 timestamp :: timestamp(),
                                                 version :: pos_integer(),
                                                 emitter :: atom()},
                                 individual_id :: individual_id(),
                                 population_id :: population_id(),
                                 previous_best :: fitness(),
                                 new_best :: fitness(),
                                 improvement_ratio :: float(),
                                 generation :: generation()}.

generation/0

-type generation() :: non_neg_integer().

generation_event/0

-type generation_event() ::
          #generation_completed{meta ::
                                    #event_meta{event_id :: binary(),
                                                correlation_id :: binary() | undefined,
                                                causation_id :: binary() | undefined,
                                                timestamp :: timestamp(),
                                                version :: pos_integer(),
                                                emitter :: atom()},
                                population_id :: population_id(),
                                generation :: generation(),
                                statistics ::
                                    #{population_size => non_neg_integer(),
                                      species_count => non_neg_integer(),
                                      mean_fitness => float(),
                                      max_fitness => float(),
                                      min_fitness => float(),
                                      std_fitness => float(),
                                      mean_complexity => float(),
                                      diversity_index => float()},
                                champion_id :: individual_id(),
                                duration_ms :: non_neg_integer()} |
          #population_initialized{meta ::
                                      #event_meta{event_id :: binary(),
                                                  correlation_id :: binary() | undefined,
                                                  causation_id :: binary() | undefined,
                                                  timestamp :: timestamp(),
                                                  version :: pos_integer(),
                                                  emitter :: atom()},
                                  population_id :: population_id(),
                                  initial_size :: non_neg_integer(),
                                  config :: map()} |
          #population_terminated{meta ::
                                     #event_meta{event_id :: binary(),
                                                 correlation_id :: binary() | undefined,
                                                 causation_id :: binary() | undefined,
                                                 timestamp :: timestamp(),
                                                 version :: pos_integer(),
                                                 emitter :: atom()},
                                 population_id :: population_id(),
                                 final_generation :: generation(),
                                 reason :: target_reached | max_generations | manual | error,
                                 final_champion_id :: individual_id(),
                                 final_champion_fitness :: fitness()}.

individual_id/0

-type individual_id() :: binary().

lifecycle_event/0

-type lifecycle_event() ::
          #individual_matured{meta ::
                                  #event_meta{event_id :: binary(),
                                              correlation_id :: binary() | undefined,
                                              causation_id :: binary() | undefined,
                                              timestamp :: timestamp(),
                                              version :: pos_integer(),
                                              emitter :: atom()},
                              individual_id :: individual_id(),
                              population_id :: population_id(),
                              previous_stage :: juvenile,
                              new_stage :: fertile,
                              age_generations :: non_neg_integer(),
                              fitness_at_maturity :: fitness()} |
          #fertility_waned{meta ::
                               #event_meta{event_id :: binary(),
                                           correlation_id :: binary() | undefined,
                                           causation_id :: binary() | undefined,
                                           timestamp :: timestamp(),
                                           version :: pos_integer(),
                                           emitter :: atom()},
                           individual_id :: individual_id(),
                           population_id :: population_id(),
                           previous_stage :: fertile,
                           new_stage :: senescent,
                           age_generations :: non_neg_integer(),
                           offspring_count :: non_neg_integer()}.

mutation_event/0

-type mutation_event() ::
          #mutation_applied{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            individual_id :: individual_id(),
                            mutation_id :: binary(),
                            mutation_type :: atom(),
                            generation :: generation()} |
          #neuron_added{meta ::
                            #event_meta{event_id :: binary(),
                                        correlation_id :: binary() | undefined,
                                        causation_id :: binary() | undefined,
                                        timestamp :: timestamp(),
                                        version :: pos_integer(),
                                        emitter :: atom()},
                        individual_id :: individual_id(),
                        neuron_id :: binary(),
                        layer :: input | hidden | output,
                        layer_index :: float(),
                        activation_function :: atom(),
                        bias :: float(),
                        mutation_id :: binary()} |
          #neuron_removed{meta ::
                              #event_meta{event_id :: binary(),
                                          correlation_id :: binary() | undefined,
                                          causation_id :: binary() | undefined,
                                          timestamp :: timestamp(),
                                          version :: pos_integer(),
                                          emitter :: atom()},
                          individual_id :: individual_id(),
                          neuron_id :: binary(),
                          layer :: input | hidden | output,
                          mutation_id :: binary()} |
          #connection_added{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            individual_id :: individual_id(),
                            connection_id :: binary(),
                            from_neuron_id :: binary(),
                            to_neuron_id :: binary(),
                            weight :: float(),
                            mutation_id :: binary()} |
          #connection_removed{meta ::
                                  #event_meta{event_id :: binary(),
                                              correlation_id :: binary() | undefined,
                                              causation_id :: binary() | undefined,
                                              timestamp :: timestamp(),
                                              version :: pos_integer(),
                                              emitter :: atom()},
                              individual_id :: individual_id(),
                              connection_id :: binary(),
                              from_neuron_id :: binary(),
                              to_neuron_id :: binary(),
                              mutation_id :: binary()} |
          #weight_perturbed{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            individual_id :: individual_id(),
                            connection_id :: binary(),
                            old_weight :: float(),
                            new_weight :: float(),
                            mutation_id :: binary()} |
          #bias_perturbed{meta ::
                              #event_meta{event_id :: binary(),
                                          correlation_id :: binary() | undefined,
                                          causation_id :: binary() | undefined,
                                          timestamp :: timestamp(),
                                          version :: pos_integer(),
                                          emitter :: atom()},
                          individual_id :: individual_id(),
                          neuron_id :: binary(),
                          old_bias :: float(),
                          new_bias :: float(),
                          mutation_id :: binary()} |
          #activation_changed{meta ::
                                  #event_meta{event_id :: binary(),
                                              correlation_id :: binary() | undefined,
                                              causation_id :: binary() | undefined,
                                              timestamp :: timestamp(),
                                              version :: pos_integer(),
                                              emitter :: atom()},
                              individual_id :: individual_id(),
                              neuron_id :: binary(),
                              old_activation :: atom(),
                              new_activation :: atom(),
                              mutation_id :: binary()}.

population_id/0

-type population_id() :: binary().

species_event/0

-type species_event() ::
          #lineage_diverged{meta ::
                                #event_meta{event_id :: binary(),
                                            correlation_id :: binary() | undefined,
                                            causation_id :: binary() | undefined,
                                            timestamp :: timestamp(),
                                            version :: pos_integer(),
                                            emitter :: atom()},
                            new_species_id :: species_id(),
                            parent_species_id :: species_id(),
                            founder_individual_id :: individual_id(),
                            divergence_cause :: structural | behavioral | geographic,
                            compatibility_distance :: float(),
                            generation :: generation()} |
          #species_emerged{meta ::
                               #event_meta{event_id :: binary(),
                                           correlation_id :: binary() | undefined,
                                           causation_id :: binary() | undefined,
                                           timestamp :: timestamp(),
                                           version :: pos_integer(),
                                           emitter :: atom()},
                           species_id :: species_id(),
                           population_id :: population_id(),
                           founder_id :: individual_id(),
                           generation :: generation()} |
          #lineage_ended{meta ::
                             #event_meta{event_id :: binary(),
                                         correlation_id :: binary() | undefined,
                                         causation_id :: binary() | undefined,
                                         timestamp :: timestamp(),
                                         version :: pos_integer(),
                                         emitter :: atom()},
                         species_id :: species_id(),
                         population_id :: population_id(),
                         final_generation :: generation(),
                         total_generations :: non_neg_integer(),
                         peak_fitness :: fitness(),
                         total_individuals :: non_neg_integer()}.

species_id/0

-type species_id() :: binary().

timestamp/0

-type timestamp() :: integer().

Functions

activation_changed(Data)

-spec activation_changed(map()) ->
                            #activation_changed{meta ::
                                                    #event_meta{event_id :: binary(),
                                                                correlation_id :: binary() | undefined,
                                                                causation_id :: binary() | undefined,
                                                                timestamp :: timestamp(),
                                                                version :: pos_integer(),
                                                                emitter :: atom()},
                                                individual_id :: individual_id(),
                                                neuron_id :: binary(),
                                                old_activation :: atom(),
                                                new_activation :: atom(),
                                                mutation_id :: binary()}.

Create activation_changed event.

bias_perturbed(Data)

-spec bias_perturbed(map()) ->
                        #bias_perturbed{meta ::
                                            #event_meta{event_id :: binary(),
                                                        correlation_id :: binary() | undefined,
                                                        causation_id :: binary() | undefined,
                                                        timestamp :: timestamp(),
                                                        version :: pos_integer(),
                                                        emitter :: atom()},
                                        individual_id :: individual_id(),
                                        neuron_id :: binary(),
                                        old_bias :: float(),
                                        new_bias :: float(),
                                        mutation_id :: binary()}.

Create bias_perturbed event.

breakthrough_achieved(Data)

-spec breakthrough_achieved(map()) ->
                               #breakthrough_achieved{meta ::
                                                          #event_meta{event_id :: binary(),
                                                                      correlation_id ::
                                                                          binary() | undefined,
                                                                      causation_id ::
                                                                          binary() | undefined,
                                                                      timestamp :: timestamp(),
                                                                      version :: pos_integer(),
                                                                      emitter :: atom()},
                                                      individual_id :: individual_id(),
                                                      population_id :: population_id(),
                                                      previous_best :: fitness(),
                                                      new_best :: fitness(),
                                                      improvement_ratio :: float(),
                                                      generation :: generation()}.

Create breakthrough_achieved event.

champion_crowned(Data)

-spec champion_crowned(map()) ->
                          #champion_crowned{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            individual_id :: individual_id(),
                                            population_id :: population_id(),
                                            fitness :: fitness(),
                                            previous_champion_id :: individual_id() | undefined,
                                            previous_champion_fitness :: fitness() | undefined,
                                            generation :: generation()}.

Create champion_crowned event.

clone_produced(Data)

-spec clone_produced(map()) ->
                        #clone_produced{meta ::
                                            #event_meta{event_id :: binary(),
                                                        correlation_id :: binary() | undefined,
                                                        causation_id :: binary() | undefined,
                                                        timestamp :: timestamp(),
                                                        version :: pos_integer(),
                                                        emitter :: atom()},
                                        individual_id :: individual_id(),
                                        parent_id :: individual_id(),
                                        generation :: generation(),
                                        species_id :: species_id(),
                                        population_id :: population_id(),
                                        mutation_applied :: boolean()}.

Create clone_produced event.

connection_added(Data)

-spec connection_added(map()) ->
                          #connection_added{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            individual_id :: individual_id(),
                                            connection_id :: binary(),
                                            from_neuron_id :: binary(),
                                            to_neuron_id :: binary(),
                                            weight :: float(),
                                            mutation_id :: binary()}.

Create connection_added event.

connection_removed(Data)

-spec connection_removed(map()) ->
                            #connection_removed{meta ::
                                                    #event_meta{event_id :: binary(),
                                                                correlation_id :: binary() | undefined,
                                                                causation_id :: binary() | undefined,
                                                                timestamp :: timestamp(),
                                                                version :: pos_integer(),
                                                                emitter :: atom()},
                                                individual_id :: individual_id(),
                                                connection_id :: binary(),
                                                from_neuron_id :: binary(),
                                                to_neuron_id :: binary(),
                                                mutation_id :: binary()}.

Create connection_removed event.

controller_adjusted(Data)

-spec controller_adjusted(map()) ->
                             #controller_adjusted{meta ::
                                                      #event_meta{event_id :: binary(),
                                                                  correlation_id :: binary() | undefined,
                                                                  causation_id :: binary() | undefined,
                                                                  timestamp :: timestamp(),
                                                                  version :: pos_integer(),
                                                                  emitter :: atom()},
                                                  controller_id :: binary(),
                                                  population_id :: population_id(),
                                                  adjustments :: #{atom() => float()},
                                                  trigger ::
                                                      stagnation | diversity_crisis | breakthrough |
                                                      scheduled}.

Create controller_adjusted event.

crossover_performed(Data)

-spec crossover_performed(map()) ->
                             #crossover_performed{meta ::
                                                      #event_meta{event_id :: binary(),
                                                                  correlation_id :: binary() | undefined,
                                                                  causation_id :: binary() | undefined,
                                                                  timestamp :: timestamp(),
                                                                  version :: pos_integer(),
                                                                  emitter :: atom()},
                                                  parent_a_id :: individual_id(),
                                                  parent_b_id :: individual_id(),
                                                  offspring_id :: individual_id(),
                                                  crossover_point :: non_neg_integer() | multiple,
                                                  genes_from_a :: non_neg_integer(),
                                                  genes_from_b :: non_neg_integer()}.

Create crossover_performed event.

evaluation_timeout(Data)

-spec evaluation_timeout(map()) ->
                            #evaluation_timeout{meta ::
                                                    #event_meta{event_id :: binary(),
                                                                correlation_id :: binary() | undefined,
                                                                causation_id :: binary() | undefined,
                                                                timestamp :: timestamp(),
                                                                version :: pos_integer(),
                                                                emitter :: atom()},
                                                individual_id :: individual_id(),
                                                population_id :: population_id(),
                                                timeout_ms :: non_neg_integer(),
                                                generation :: generation()}.

Create evaluation_timeout event.

event_to_map(Event)

-spec event_to_map(behavioral_event()) -> map().

Convert an event record to a map for serialization.

fertility_waned(Data)

-spec fertility_waned(map()) ->
                         #fertility_waned{meta ::
                                              #event_meta{event_id :: binary(),
                                                          correlation_id :: binary() | undefined,
                                                          causation_id :: binary() | undefined,
                                                          timestamp :: timestamp(),
                                                          version :: pos_integer(),
                                                          emitter :: atom()},
                                          individual_id :: individual_id(),
                                          population_id :: population_id(),
                                          previous_stage :: fertile,
                                          new_stage :: senescent,
                                          age_generations :: non_neg_integer(),
                                          offspring_count :: non_neg_integer()}.

Create fertility_waned event.

fitness_declined(Data)

-spec fitness_declined(map()) ->
                          #fitness_declined{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            individual_id :: individual_id(),
                                            population_id :: population_id(),
                                            previous_fitness :: fitness(),
                                            new_fitness :: fitness(),
                                            decline :: float(),
                                            generation :: generation()}.

Create fitness_declined event.

fitness_evaluated(Data)

-spec fitness_evaluated(map()) ->
                           #fitness_evaluated{meta ::
                                                  #event_meta{event_id :: binary(),
                                                              correlation_id :: binary() | undefined,
                                                              causation_id :: binary() | undefined,
                                                              timestamp :: timestamp(),
                                                              version :: pos_integer(),
                                                              emitter :: atom()},
                                              individual_id :: individual_id(),
                                              population_id :: population_id(),
                                              fitness :: fitness(),
                                              fitness_components :: #{atom() => float()},
                                              evaluation_duration_ms :: non_neg_integer(),
                                              generation :: generation()}.

Create fitness_evaluated event.

fitness_improved(Data)

-spec fitness_improved(map()) ->
                          #fitness_improved{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            individual_id :: individual_id(),
                                            population_id :: population_id(),
                                            previous_fitness :: fitness(),
                                            new_fitness :: fitness(),
                                            improvement :: float(),
                                            generation :: generation()}.

Create fitness_improved event.

generation_completed(Data)

-spec generation_completed(map()) ->
                              #generation_completed{meta ::
                                                        #event_meta{event_id :: binary(),
                                                                    correlation_id ::
                                                                        binary() | undefined,
                                                                    causation_id :: binary() | undefined,
                                                                    timestamp :: timestamp(),
                                                                    version :: pos_integer(),
                                                                    emitter :: atom()},
                                                    population_id :: population_id(),
                                                    generation :: generation(),
                                                    statistics ::
                                                        #{population_size => non_neg_integer(),
                                                          species_count => non_neg_integer(),
                                                          mean_fitness => float(),
                                                          max_fitness => float(),
                                                          min_fitness => float(),
                                                          std_fitness => float(),
                                                          mean_complexity => float(),
                                                          diversity_index => float()},
                                                    champion_id :: individual_id(),
                                                    duration_ms :: non_neg_integer()}.

Create generation_completed event.

immigrant_arrived(Data)

-spec immigrant_arrived(map()) ->
                           #immigrant_arrived{meta ::
                                                  #event_meta{event_id :: binary(),
                                                              correlation_id :: binary() | undefined,
                                                              causation_id :: binary() | undefined,
                                                              timestamp :: timestamp(),
                                                              version :: pos_integer(),
                                                              emitter :: atom()},
                                              individual_id :: individual_id(),
                                              source_population_id :: population_id(),
                                              target_population_id :: population_id(),
                                              source_species_id :: species_id(),
                                              target_species_id :: species_id(),
                                              fitness :: fitness()}.

Create immigrant_arrived event.

individual_culled(Data)

-spec individual_culled(map()) ->
                           #individual_culled{meta ::
                                                  #event_meta{event_id :: binary(),
                                                              correlation_id :: binary() | undefined,
                                                              causation_id :: binary() | undefined,
                                                              timestamp :: timestamp(),
                                                              version :: pos_integer(),
                                                              emitter :: atom()},
                                              individual_id :: individual_id(),
                                              population_id :: population_id(),
                                              species_id :: species_id(),
                                              final_fitness :: fitness(),
                                              age_generations :: non_neg_integer(),
                                              cause :: selection | stagnation | overcrowding,
                                              lineage_depth :: non_neg_integer()}.

Create individual_culled event.

individual_matured(Data)

-spec individual_matured(map()) ->
                            #individual_matured{meta ::
                                                    #event_meta{event_id :: binary(),
                                                                correlation_id :: binary() | undefined,
                                                                causation_id :: binary() | undefined,
                                                                timestamp :: timestamp(),
                                                                version :: pos_integer(),
                                                                emitter :: atom()},
                                                individual_id :: individual_id(),
                                                population_id :: population_id(),
                                                previous_stage :: juvenile,
                                                new_stage :: fertile,
                                                age_generations :: non_neg_integer(),
                                                fitness_at_maturity :: fitness()}.

Create individual_matured event.

individual_perished(Data)

-spec individual_perished(map()) ->
                             #individual_perished{meta ::
                                                      #event_meta{event_id :: binary(),
                                                                  correlation_id :: binary() | undefined,
                                                                  causation_id :: binary() | undefined,
                                                                  timestamp :: timestamp(),
                                                                  version :: pos_integer(),
                                                                  emitter :: atom()},
                                                  individual_id :: individual_id(),
                                                  population_id :: population_id(),
                                                  cause :: evaluation_crash | simulation_death | timeout,
                                                  generation :: generation()}.

Create individual_perished event.

lifespan_expired(Data)

-spec lifespan_expired(map()) ->
                          #lifespan_expired{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            individual_id :: individual_id(),
                                            population_id :: population_id(),
                                            age_generations :: non_neg_integer(),
                                            lifecycle_stage :: senescent,
                                            peak_fitness :: fitness(),
                                            offspring_count :: non_neg_integer()}.

Create lifespan_expired event.

lineage_diverged(Data)

-spec lineage_diverged(map()) ->
                          #lineage_diverged{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            new_species_id :: species_id(),
                                            parent_species_id :: species_id(),
                                            founder_individual_id :: individual_id(),
                                            divergence_cause :: structural | behavioral | geographic,
                                            compatibility_distance :: float(),
                                            generation :: generation()}.

Create lineage_diverged event.

lineage_ended(Data)

-spec lineage_ended(map()) ->
                       #lineage_ended{meta ::
                                          #event_meta{event_id :: binary(),
                                                      correlation_id :: binary() | undefined,
                                                      causation_id :: binary() | undefined,
                                                      timestamp :: timestamp(),
                                                      version :: pos_integer(),
                                                      emitter :: atom()},
                                      species_id :: species_id(),
                                      population_id :: population_id(),
                                      final_generation :: generation(),
                                      total_generations :: non_neg_integer(),
                                      peak_fitness :: fitness(),
                                      total_individuals :: non_neg_integer()}.

Create lineage_ended event.

make_meta(Emitter)

-spec make_meta(Emitter :: atom()) ->
                   #event_meta{event_id :: binary(),
                               correlation_id :: binary() | undefined,
                               causation_id :: binary() | undefined,
                               timestamp :: timestamp(),
                               version :: pos_integer(),
                               emitter :: atom()}.

Create event metadata with default values.

make_meta(Emitter, Opts)

-spec make_meta(Emitter :: atom(), Opts :: map()) ->
                   #event_meta{event_id :: binary(),
                               correlation_id :: binary() | undefined,
                               causation_id :: binary() | undefined,
                               timestamp :: timestamp(),
                               version :: pos_integer(),
                               emitter :: atom()}.

Create event metadata with options.

mating_occurred(Data)

-spec mating_occurred(map()) ->
                         #mating_occurred{meta ::
                                              #event_meta{event_id :: binary(),
                                                          correlation_id :: binary() | undefined,
                                                          causation_id :: binary() | undefined,
                                                          timestamp :: timestamp(),
                                                          version :: pos_integer(),
                                                          emitter :: atom()},
                                          parent_a_id :: individual_id(),
                                          parent_b_id :: individual_id(),
                                          offspring_ids :: [individual_id()],
                                          crossover_method :: atom(),
                                          compatibility_distance :: float(),
                                          relatedness_coefficient :: float()}.

Create mating_occurred event.

mutation_applied(Data)

-spec mutation_applied(map()) ->
                          #mutation_applied{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            individual_id :: individual_id(),
                                            mutation_id :: binary(),
                                            mutation_type :: atom(),
                                            generation :: generation()}.

Create mutation_applied event.

neuron_added(Data)

-spec neuron_added(map()) ->
                      #neuron_added{meta ::
                                        #event_meta{event_id :: binary(),
                                                    correlation_id :: binary() | undefined,
                                                    causation_id :: binary() | undefined,
                                                    timestamp :: timestamp(),
                                                    version :: pos_integer(),
                                                    emitter :: atom()},
                                    individual_id :: individual_id(),
                                    neuron_id :: binary(),
                                    layer :: input | hidden | output,
                                    layer_index :: float(),
                                    activation_function :: atom(),
                                    bias :: float(),
                                    mutation_id :: binary()}.

Create neuron_added event.

neuron_removed(Data)

-spec neuron_removed(map()) ->
                        #neuron_removed{meta ::
                                            #event_meta{event_id :: binary(),
                                                        correlation_id :: binary() | undefined,
                                                        causation_id :: binary() | undefined,
                                                        timestamp :: timestamp(),
                                                        version :: pos_integer(),
                                                        emitter :: atom()},
                                        individual_id :: individual_id(),
                                        neuron_id :: binary(),
                                        layer :: input | hidden | output,
                                        mutation_id :: binary()}.

Create neuron_removed event.

offspring_born(Data)

-spec offspring_born(map()) ->
                        #offspring_born{meta ::
                                            #event_meta{event_id :: binary(),
                                                        correlation_id :: binary() | undefined,
                                                        causation_id :: binary() | undefined,
                                                        timestamp :: timestamp(),
                                                        version :: pos_integer(),
                                                        emitter :: atom()},
                                        individual_id :: individual_id(),
                                        parent_ids :: [individual_id()],
                                        generation :: generation(),
                                        species_id :: species_id(),
                                        population_id :: population_id(),
                                        genome_hash :: binary(),
                                        initial_fitness :: fitness() | undefined}.

Create offspring_born event.

pioneer_spawned(Data)

-spec pioneer_spawned(map()) ->
                         #pioneer_spawned{meta ::
                                              #event_meta{event_id :: binary(),
                                                          correlation_id :: binary() | undefined,
                                                          causation_id :: binary() | undefined,
                                                          timestamp :: timestamp(),
                                                          version :: pos_integer(),
                                                          emitter :: atom()},
                                          individual_id :: individual_id(),
                                          population_id :: population_id(),
                                          species_id :: species_id(),
                                          generation :: generation(),
                                          genome_hash :: binary()}.

Create pioneer_spawned event.

population_initialized(Data)

-spec population_initialized(map()) ->
                                #population_initialized{meta ::
                                                            #event_meta{event_id :: binary(),
                                                                        correlation_id ::
                                                                            binary() | undefined,
                                                                        causation_id ::
                                                                            binary() | undefined,
                                                                        timestamp :: timestamp(),
                                                                        version :: pos_integer(),
                                                                        emitter :: atom()},
                                                        population_id :: population_id(),
                                                        initial_size :: non_neg_integer(),
                                                        config :: map()}.

Create population_initialized event.

population_terminated(Data)

-spec population_terminated(map()) ->
                               #population_terminated{meta ::
                                                          #event_meta{event_id :: binary(),
                                                                      correlation_id ::
                                                                          binary() | undefined,
                                                                      causation_id ::
                                                                          binary() | undefined,
                                                                      timestamp :: timestamp(),
                                                                      version :: pos_integer(),
                                                                      emitter :: atom()},
                                                      population_id :: population_id(),
                                                      final_generation :: generation(),
                                                      reason ::
                                                          target_reached | max_generations | manual |
                                                          error,
                                                      final_champion_id :: individual_id(),
                                                      final_champion_fitness :: fitness()}.

Create population_terminated event.

silo_activated(Data)

-spec silo_activated(map()) ->
                        #silo_activated{meta ::
                                            #event_meta{event_id :: binary(),
                                                        correlation_id :: binary() | undefined,
                                                        causation_id :: binary() | undefined,
                                                        timestamp :: timestamp(),
                                                        version :: pos_integer(),
                                                        emitter :: atom()},
                                        silo_type :: atom(),
                                        realm :: binary(),
                                        config :: map()}.

Create silo_activated event.

silo_deactivated(Data)

-spec silo_deactivated(map()) ->
                          #silo_deactivated{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            silo_type :: atom(),
                                            realm :: binary(),
                                            reason :: manual | dependency_removed | error}.

Create silo_deactivated event.

species_emerged(Data)

-spec species_emerged(map()) ->
                         #species_emerged{meta ::
                                              #event_meta{event_id :: binary(),
                                                          correlation_id :: binary() | undefined,
                                                          causation_id :: binary() | undefined,
                                                          timestamp :: timestamp(),
                                                          version :: pos_integer(),
                                                          emitter :: atom()},
                                          species_id :: species_id(),
                                          population_id :: population_id(),
                                          founder_id :: individual_id(),
                                          generation :: generation()}.

Create species_emerged event.

stagnation_detected(Data)

-spec stagnation_detected(map()) ->
                             #stagnation_detected{meta ::
                                                      #event_meta{event_id :: binary(),
                                                                  correlation_id :: binary() | undefined,
                                                                  causation_id :: binary() | undefined,
                                                                  timestamp :: timestamp(),
                                                                  version :: pos_integer(),
                                                                  emitter :: atom()},
                                                  population_id :: population_id(),
                                                  generations_stagnant :: non_neg_integer(),
                                                  best_fitness :: fitness(),
                                                  generation :: generation()}.

Create stagnation_detected event.

stream_id(Type, Id)

-spec stream_id(Type :: atom(), Id :: binary()) -> binary().

Generate stream ID for an entity.

weight_perturbed(Data)

-spec weight_perturbed(map()) ->
                          #weight_perturbed{meta ::
                                                #event_meta{event_id :: binary(),
                                                            correlation_id :: binary() | undefined,
                                                            causation_id :: binary() | undefined,
                                                            timestamp :: timestamp(),
                                                            version :: pos_integer(),
                                                            emitter :: atom()},
                                            individual_id :: individual_id(),
                                            connection_id :: binary(),
                                            old_weight :: float(),
                                            new_weight :: float(),
                                            mutation_id :: binary()}.

Create weight_perturbed event.