event

Documentation

Index

• type CreatedPlanet
  • func NewCreatePlanetProcess(planet planet.ReadUpdater, api swapi.Finder, kafka planet.KafkaWriter, ...) CreatedPlanet
  • func (c CreatedPlanet) Process(data interface{}) error

Types

type CreatedPlanet

type CreatedPlanet struct {
	// contains filtered or unexported fields
}

func NewCreatePlanetProcess

func NewCreatePlanetProcess(
	planet planet.ReadUpdater,
	api swapi.Finder,
	kafka planet.KafkaWriter,
	kafkaTopic string,
	retryProcess int,
) CreatedPlanet

func (CreatedPlanet) Process

func (c CreatedPlanet) Process(data interface{}) error