catch

Documentation

Index

• type Config
• type Factory
  • func NewFactory(ctx context.Context, config Config) (*Factory, error)
  • func (f *Factory) Catch(group string, topic string, uuid uuuid.UUID) (<-chan *model.KafkaResponse, error)

Types

type Config

type Config struct {
	PreRequest   bool
	KafkaBrokers []string
	TimeoutSec   int
}

Config defines the configuration for Catch-Factory.

type Factory

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

Factory handles creating appropriate Kafka-Consumers and creating a result-channel for every request. Check Factory.Catch function.

func NewFactory

func NewFactory(ctx context.Context, config Config) (*Factory, error)

NewFactory returns a new Factory instance.

func (*Factory) Catch

func (f *Factory) Catch(
	group string,
	topic string,
	uuid uuuid.UUID,
) (<-chan *model.KafkaResponse, error)

Catch creates a new Kafka-Consumer if one does not exist for that specific ID. Otherwise an existing cached Consumer is returned. ID here refers to "Group+Topic" for the Consumer. This is not analogous to traditional Consumers that simply forward any Kafka Messages. This returns a new channel for every request. The request's response is then sent on that channel when the response arrives. It determines the correct response for request by using the response-UUID. If a response arrives before the request for it is registered, it caches the response until the request for it is received, and the response is sent out as soon request arrives.