input

type ChannelInput struct {
	Input <-chan *optimusv1.LogEvent
	// contains filtered or unexported fields
}

type FileInput struct {
	Path    string `hcl:"path"`
	DataDir string `hcl:"data_dir,optional"`
	// contains filtered or unexported fields
}

type HTTPInput struct {
}

type Input struct {
	Kind string   `hcl:"kind,label"`
	ID   string   `hcl:"id,label"`
	Body hcl.Body `hcl:",remain"`

	Broker pubsub.Broker
	// contains filtered or unexported fields
}

type InputProcessor interface {
	Initialize(id string, broker pubsub.Broker) error
	Process(context.Context) error
}