examples

func Batcher_step_example ¶ added in v1.2.0

func Batcher_step_example()

func JobGrouper ¶ added in v1.2.0

func JobGrouper(s, i interface{}, idx int) (interface{}, error)

JobGrouper groups jobs

func JobMapper ¶ added in v1.2.0

func JobMapper(in interface{}) (interface{}, error)

JobMapper transforms a input into a pubsub validation job

func Mapper_step_example ¶

func Mapper_step_example()

Mapper_step_example exhibits the operation of a recently instantiated SubscriberPipeline with an additional mapper step attached, which modifies the data that goes through the pipeline.

The pipeline outputs the contents of a channel, which is channeling *Pubsub.Message messages, in this case. The message then goes through a Mapper step, which is suported by the package, but provided by the client.

A Mapper is particularly useful for consuming the raw *Pubsub.Message contents and transforming them into a more practical custom type (such as myCustomType).

func Publisher_pipeline_example ¶ added in v1.1.1

func Publisher_pipeline_example()

Publisher_pipeline_example shows the operation of a recently instantiated Generics compatible PubsubClient publisher. It accepts any message schema, requiring only that it's type implements ToByteser interface. The message schema, along with a wrapped Pubsub Topic (created with a NewTopicWrapper), must be passed to the PubsubClient builder (MustNewPubSubClient).

func Raw_pipeline_example ¶

func Raw_pipeline_example()

Raw_pipeline_example shows the raw operation of a recently instantiated SubscriberPipeline with no additional steps attached.

The SubscriberPipeline builder (MustNewSubscriberPipeline) requires a Pubsub Subscriber (or something that equally implements it's Receive functionality). The pipeline then outputs the contents of a channel, which in it's turn, channels *Pubsub.Message messages in this case.