processor

Documentation

Index

• Constants
• func NewEventFrom(ctx goka.Context, in event.EventData) projections.Event
• type Config
  • func DefaultConfig(brokers []string) Config
• type Processor
  • func BuildProcessor(p *projections.Projection, cfg Config) (*Processor, error)
  • func (p *Processor) Start(ctx context.Context) error
  • func (p *Processor) WaitReady(ctx context.Context) error
  • func (p *Processor) WaitShutdown()

Constants

const (
	DefaultReplicationFactor = 3
	DefaultPartitions        = 1
	InMemoryStorage          = ":in-memory:"
)

const (
	MetadataKeyTopicPartition = "topicPartition"
	MetadataKeyTimestamp      = "timestamp"
)

const (
	EventTypeProjectionResult = "Result"
)

Functions

func NewEventFrom

func NewEventFrom(ctx goka.Context, in event.EventData) projections.Event

Types

type Config

type Config struct {
	Brokers     []string
	Replication int
	Partitions  int
	StoragePath string
}

func DefaultConfig

func DefaultConfig(brokers []string) Config

type Processor

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

func BuildProcessor

func BuildProcessor(p *projections.Projection, cfg Config) (*Processor, error)

func (*Processor) Start

func (p *Processor) Start(ctx context.Context) error

func (*Processor) WaitReady

func (p *Processor) WaitReady(ctx context.Context) error

func (*Processor) WaitShutdown

func (p *Processor) WaitShutdown()