intake

Documentation

Index

• type Intake
  • func NewIntake(dir string) *Intake
  • func (i *Intake) Write(subject string, data any, headers map[string]string) error

Types

type Intake

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

func NewIntake

func NewIntake(dir string) *Intake

NewIntake creates a new Intake instance.

func (*Intake) Write

func (i *Intake) Write(subject string, data any, headers map[string]string) error

Write will write an event to disk.