memory

Documentation

Index

• func New(args *MemoryArgs, logger *zap.SugaredLogger) backend.Interface
• type MemoryArgs
  • func (ma *MemoryArgs) Validate() error

Functions

func New

func New(args *MemoryArgs, logger *zap.SugaredLogger) backend.Interface

Types

type MemoryArgs

type MemoryArgs struct {
	BufferSize     int    `help:"Number of events that can be hosted in the backend." env:"BUFFER_SIZE" default:"10000"`
	ProduceTimeout string `help:"Maximum wait time for producing an event to the backend." env:"PRODUCE_TIMEOUT" default:"PT5S"`

	ProduceTimeoutDuration time.Duration `kong:"-"`
}

func (*MemoryArgs) Validate

func (ma *MemoryArgs) Validate() error