pipeline

Documentation

Index

• type ID
  • func (i ID) String() string
• type Pipeline
  • func DirectMessagePipeline() Pipeline
  • func PubSubPipeline(topic string) Pipeline
  • func (p Pipeline) String() string

Types

type ID

type ID int

const (
	PubSub ID = iota + 1
	DirectMessage
)

func (ID) String

func (i ID) String() string

type Pipeline

type Pipeline struct {
	ID    ID     // ID of the pipeline on which the message was received.
	Topic string // optional - topic on which this message was published.
}

func DirectMessagePipeline

func DirectMessagePipeline() Pipeline

func PubSubPipeline

func PubSubPipeline(topic string) Pipeline

func (Pipeline) String

func (p Pipeline) String() string